MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
↓ 2 callersMethodsequence_number
(&self)
core/trace_exporters/src/thrift/zipkincore.rs:835
↓ 2 callersMethodserialize
(&self, serializer: S)
influxdb3_write/src/lib.rs:459
↓ 2 callersFunctionserialize_records
(records: &[Record])
influxdb3_catalog/src/format/apply.rs:100
↓ 2 callersFunctionserialize_to_file_bytes
(contents: &WalContents)
influxdb3_wal/src/serialize.rs:82
↓ 2 callersMethodserialize_to_parquet
( &self, batches: SendableRecordBatchStream, )
influxdb3_write/src/persister.rs:167
↓ 2 callersMethodseries
Get the definition of the Series this chunk is part of.
core/iox_v1_query_api/src/response.rs:102
↓ 2 callersFunctionserve
( server: Server<'_>, shutdown: CancellationToken, startup_timer: Instant, without_auth: bool,
influxdb3_server/src/lib.rs:369
↓ 2 callersFunctionserve_main
( serve_config: commands::serve::Config, matches: &clap::ArgMatches, runtime_config: TokioIoConfig
influxdb3/src/lib.rs:323
↓ 2 callersMethodservice
Returns HTTP service.
core/catalog_cache/src/api/server.rs:279
↓ 2 callersMethodset
(&mut self, _key: &str, value: &str)
core/iox_query/src/config.rs:173
↓ 2 callersMethodset_auto_field_family
(&mut self, id: FieldFamilyId, name: u16)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:440
↓ 2 callersMethodset_metadata
Record an event on the span recorder
core/iox_query/src/exec/context.rs:719
↓ 2 callersMethodset_partial
(&mut self, partial: bool)
core/iox_v1_query_api/src/response.rs:361
↓ 2 callersMethodset_percentile
(&mut self, array: ArrayRef)
core/iox_query_influxql/src/aggregate/percentile.rs:114
↓ 2 callersMethodset_retention_period_for_database
( &self, req: Request, )
influxdb3_server/src/http.rs:2028
↓ 2 callersMethodset_retention_period_for_database
Apply a retention policy to an active database.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1723
↓ 2 callersMethodset_retention_period_for_table
Apply a per-table retention policy. Errors if the database or table is missing or soft-deleted.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1904
↓ 2 callersFunctionset_send_buffer_size
Attempt to increase the socket send buffer size to `want`. If the buffer size cannot be set, a lower value is attempted until the buffer is expanded
core/trace_exporters/src/jaeger.rs:179
↓ 2 callersMethodset_state
(&mut self, state: WalBufferState)
influxdb3_wal/src/object_store.rs:814
↓ 2 callersMethodset_state_shutdown
Flip the catalog's lifecycle state to `Shutdown`.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:941
↓ 2 callersMethodset_success
(&mut self)
influxdb3_cache/src/last_cache/metrics.rs:66
↓ 2 callersFunctionsetup_database
Helper: create a database.
influxdb3_catalog/src/enterprise/format/records/token/tests.rs:23
↓ 2 callersFunctionsetup_database
Helper: create a database.
influxdb3_catalog/src/format/records/trigger/tests.rs:22
↓ 2 callersFunctionsetup_db_and_table
Helper: create a database + empty table for cache tests.
influxdb3_catalog/src/format/records/cache/tests.rs:24
↓ 2 callersFunctionsetup_metric_registry
()
influxdb3/src/commands/serve.rs:1720
↓ 2 callersFunctionsetup_table
(catalog: &mut InnerCatalog, db_id: u32, db_name: &str, table_id: u32, name: &str)
influxdb3_catalog/src/format/records/repository/tests.rs:28
↓ 2 callersFunctionsetup_tls
( tcp_listener: TcpListener, key_file: &PathBuf, cert_file: &PathBuf, )
influxdb3_server/src/lib.rs:565
↓ 2 callersFunctionsha256
Get SHA256 of given file.
core/iox_query_udf/build.rs:123
↓ 2 callersMethodshow_databases
(&self, req: Request)
influxdb3_server/src/http.rs:1769
↓ 2 callersFunctionshow_retention_policies
( i: &str, )
core/influxdb_influxql_parser/src/show_retention_policies.rs:31
↓ 2 callersMethodshutdown
Triggers and waits for graceful shutdown
core/catalog_cache/src/api/server.rs:458
↓ 2 callersFunctionsimplify_predicate
Special purpose `Expr` rewrite rules for an Expr that is used as a predicate. In general the rewrite rules in Datafusion and IOx attempt to preserve
core/predicate/src/rpc_predicate/rewrite.rs:70
↓ 2 callersMethodsize
(&self)
core/iox_query/src/chunk_statistics.rs:42
↓ 2 callersMethodsize
The approximate memory size of the data in the column. This includes the size of `self`.
core/mutable_batch/src/column.rs:201
↓ 2 callersFunctionsize_of_precision
Calculate the size of `datafusion::common::stats::Precision<Scalar>` in bytes.
core/iox_query/src/chunk_statistics.rs:55
↓ 2 callersMethodsmall_queue_keys
(&self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:582
↓ 2 callersMethodsnapshot
Create a snapshot of the S3Fifo cache state. This function serializes the locked_state using bincode, allowing for persistence and recovery of the ca
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:169
↓ 2 callersMethodsnapshot
(catalog_prefix: &str)
influxdb3_catalog/src/object_store/versions/v3.rs:562
↓ 2 callersMethodsnapshot
Returns the max_time and the last_wal_file_sequence_number that can be snapshot along with the wal periods. The `SnapshotDetails` get handed over to t
influxdb3_wal/src/snapshot_tracker.rs:60
↓ 2 callersFunctionsnapshot_exists_in_store
Helper to check if a snapshot exists in object store
influxdb3_write/src/table_index_cache/tests.rs:790
↓ 2 callersFunctionsnapshot_records
(file: &CatalogFile)
influxdb3_catalog/src/format/apply/tests.rs:28
↓ 2 callersFunctionsoft_delete_table
Mark a table as soft-deleted within a database schema. Sets `deleted = true`, renames the table with a deletion timestamp suffix, and sets the `hard_
influxdb3_catalog/src/catalog/versions/v2.rs:2641
↓ 2 callersMethodsort_columns_ordered
Combination of all columns within the sort key and potentially the chunk order column. This is similar to [`sort_columns`](Self::sort_columns) but al
core/iox_query/src/provider/deduplicate.rs:166
↓ 2 callersMethodsort_key_ids
The sort key IDs, if the sort key has been set
core/data_types/src/partition.rs:589
↓ 2 callersFunctionsort_order_two_cols
()
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:977
↓ 2 callersMethodsource
(&self)
core/error_reporting/src/lib.rs:121
↓ 2 callersFunctionspawn_buffered
todo: this is a copy from DF code. When this ProgressiveEval operator is moved to DF, this can be removed If running in a tokio context spawns the exe
core/iox_query/src/provider/progressive_eval.rs:547
↓ 2 callersFunctionsplit_partition_key
Returns exploded parts of the given partition key on the "|" character ([`PARTITION_KEY_DELIMITER`]). Any uses of the "|" character within the partit
core/data_types/src/partition_template.rs:413
↓ 2 callersMethodstart_triggers
(self: Arc<Self>)
influxdb3_processing_engine/src/lib.rs:747
↓ 2 callersMethodstate
Return a snapshot of the currently recorded state.
core/service_grpc_flight/src/observer.rs:167
↓ 2 callersMethodstatement
(&self)
core/iox_query_influxql_rewrite/src/lib.rs:53
↓ 2 callersFunctionstatements_to_response
( executing_statements: Vec<StatementFuture>, chunk_size: Option<usize>, epoch: Option<Precision>,
core/iox_v1_query_api/src/handler.rs:541
↓ 2 callersMethodstatistics
(&self)
core/iox_query/src/provider/deduplicate.rs:317
↓ 2 callersMethodstatistics
(&self)
influxdb3_query_executor/src/query_planner.rs:159
↓ 2 callersFunctionstats
Generic function to calculate min/max/avg from a new sampled value. This function works for all types of numbers (unsigned/signed/floats). One thing t
influxdb3_telemetry/src/stats.rs:127
↓ 2 callersMethodstop
Set the state of this receiver to stopped This will have broadcasted messages from the catalog ignore this channel. This is useful for cases like app
influxdb3_catalog/src/channel/versions/v2.rs:64
↓ 2 callersMethodstop_node
Administratively stop a node in the cluster (permanent removal)
influxdb3_catalog/src/catalog/versions/v2/update.rs:368
↓ 2 callersFunctionstore_with_snapshot
()
influxdb3_commands/src/debug/catalog/tests.rs:99
↓ 2 callersFunctionstream_from_batches
Create a SendableRecordBatchStream from Vec of RecordBatches with the same schema
core/datafusion_util/src/lib.rs:301
↓ 2 callersMethodstring_array
Makes a string array with `count` entries of data with different values (parquet is super efficient at encoding the same value)
core/parquet_file/src/writer.rs:266
↓ 2 callersMethodstruct_fields
(&self, col: usize)
core/iox_query/src/exec/gapfill/exec_tests.rs:1374
↓ 2 callersMethodsuccess
(self: Box<Self>)
core/service_grpc_flight/src/observer.rs:173
↓ 2 callersFunctionsum_values
Computes a sum of two numeric [ScalarValue]s as 64-bit floating point numbers.
core/iox_query_influxql/src/window/integral.rs:351
↓ 2 callersMethodsync_central_reservation
Resize the central memory reservation to the currently allocated amount. It does not matter whether a thread attempts to grow or shrink the allocatio
core/iox_query/src/memory_pool.rs:150
↓ 2 callersFunctionsynthesize_absent_column_stats
`ColumnStatistics` for a column absent from a chunk but present in the outer schema. Min/max use a typed null derived from `field.data_type()` so synt
core/iox_query/src/statistics/stats_utils.rs:17
↓ 2 callersFunctiontable_1
()
influxdb3_write/src/table_index/test_table_index_operations.rs:179
↓ 2 callersFunctiontable_deletion_status
( db_schema: &DatabaseSchema, table_id: TableId, time_provider: &dyn TimeProvider, )
influxdb3_catalog/src/catalog/versions/v2.rs:4731
↓ 2 callersMethodtable_id_by_name
(&mut self, table_name: &str)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:348
↓ 2 callersMethodtable_name
(&self)
core/iox_query/src/test.rs:1166
↓ 2 callersMethodtable_names
Returns the table names this predicate is restricted to if any
core/predicate/src/rpc_predicate.rs:183
↓ 2 callersFunctiontable_scan
()
core/iox_query/src/exec/gapfill/mod.rs:726
↓ 2 callersMethodtables
Returns an iterator over the per-table writes within this [`DmlWrite`] in no particular order
core/dml/src/lib.rs:177
↓ 2 callersMethodtables
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:123
↓ 2 callersFunctiontag_from_meta
(key: String, value: MetaValue)
core/trace_exporters/src/jaeger/span.rs:143
↓ 2 callersMethodtake
Takes the vector out of the receiver, leaving a default vector value in its place.
core/influxdb_influxql_parser/src/common.rs:540
↓ 2 callersMethodtelemetry_snapshot_response
(&self)
influxdb3/tests/server/mod.rs:1070
↓ 2 callersFunctiontest_catalog
Helper to create a test catalog.
influxdb3_catalog/src/enterprise/format/records/token/tests.rs:18
↓ 2 callersFunctiontest_catalog
Helper to create a test catalog.
influxdb3_catalog/src/format/records/cache/tests.rs:19
↓ 2 callersFunctiontest_catalog
()
influxdb3_catalog/src/format/records/user/tests.rs:12
↓ 2 callersFunctiontest_catalog
Helper to create a test catalog.
influxdb3_catalog/src/format/records/generation/tests.rs:12
↓ 2 callersFunctiontest_catalog
Helper to create a test catalog.
influxdb3_catalog/src/format/records/trigger/tests.rs:17
↓ 2 callersFunctiontest_catalog
()
influxdb3_catalog/src/format/records/role/tests.rs:15
↓ 2 callersFunctiontest_chunk
test chunk with time range and field1's value range
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:816
↓ 2 callersFunctiontest_chunk
test chunk with time range and field1's value range
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2549
↓ 2 callersFunctiontest_io_runtime_multi_thread_impl
(dedicated: DedicatedExecutor)
core/executor/src/lib.rs:751
↓ 2 callersFunctiontest_stream
Build an observed stream plus shared state
core/service_grpc_flight/src/observer.rs:183
↓ 2 callersMethodthen_with_opt
(self, f: F)
core/datafusion_util/src/lib.rs:350
↓ 2 callersMethodtime_column
(&self)
core/partition/src/traits.rs:217
↓ 2 callersMethodtime_iter
Returns an iterator of `&Field` for all the timestamp columns of this schema, in order. At the time of writing there should be only one or 0 such colu
core/schema/src/lib.rs:789
↓ 2 callersMethodtime_provider
(&self)
core/object_store_metrics/src/metrics.rs:494
↓ 2 callersMethodtime_provider
(&self)
influxdb3_sys_events/src/lib.rs:52
↓ 2 callersFunctiontime_range_to_df_expr
Assumes the provided nanosecond i64 value is in UTC. Returns a datafusion expression in UTC, relying upon the datafusion engine to perform any castin
core/iox_query_influxql/src/plan/planner_time_range_expression.rs:46
↓ 2 callersFunctiontimestamp
(i: &str)
core/influxdb_line_protocol/src/lib.rs:868
↓ 2 callersFunctiontimestamp_min_max
(chunk: &dyn QueryChunk)
core/iox_query/src/provider/overlap.rs:94
↓ 2 callersFunctiontimestamp_to_datetime
Converts a nanosecond UTC timestamp into a DateTime structure (which can have year, month, etc. extracted) This is roughly equivelnt to ConvertTime f
core/query_functions/src/window/internal.rs:143
↓ 2 callersFunctiontimezone_clause
Parse a timezone clause. ```text timezone_clause ::= "TZ" "(" single_quoted_string ")" ``` ## NOTE There are some differences with how the IANA tim
core/influxdb_influxql_parser/src/select.rs:826
↓ 2 callersFunctiontls_env_lock
()
influxdb3_clap_blocks/src/object_store/tests.rs:18
↓ 2 callersFunctionto_2_decimal_places
(avg: T)
influxdb3_telemetry/src/store.rs:399
↓ 2 callersMethodto_create_last_cache
(self)
influxdb3_catalog/src/log/versions/v3.rs:276
↓ 2 callersMethodto_database
(self)
influxdb3_catalog/src/log/versions/v3.rs:124
← previousnext →2,901–3,000 of 11,906, ranked by callers