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
Methodload_or_create_catalog
Load an existing catalog, or initialize a fresh one by writing an initial snapshot at sequence 0. Two processes racing to initialize the same prefix a
influxdb3_catalog/src/object_store/versions/v3.rs:259
Functionload_or_create_catalog_existing_catalog
()
influxdb3_catalog/src/object_store/versions/v2/tests.rs:22
Functionload_or_create_catalog_new_catalog
()
influxdb3_catalog/src/object_store/versions/v2/tests.rs:9
Functionload_or_create_initializes_fresh_catalog
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:140
Functionload_or_create_is_idempotent
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:169
Functionload_or_create_migrates_v2_catalog_in_place
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1985
Functionload_or_create_rejects_committed_above_local
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1939
Functionload_or_create_resolves_concurrent_init
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:177
Functionload_or_create_round_trip
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:461
Functionload_or_create_succeeds_when_committed_equals_local
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1973
Methodload_or_create_with_observer
( catalog_id: impl Into<Arc<str>>, current_node_id: Option<Arc<str>>, store: Arc<dyn O
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:664
Functionload_snapshot_returns_none_when_missing
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:86
Functionload_snapshot_works_with_no_exising_snapshots
()
influxdb3_write/src/persister/tests.rs:287
Methodload_split_persist
Load a persisted snapshot from object store and split it into table index snapshots
influxdb3_write/src/table_index.rs:187
Methodlocal
Returns a reference to the local [`CatalogCache`]
core/catalog_cache/src/api/quorum.rs:398
Functionlocal_url_signer
()
influxdb3_clap_blocks/src/object_store/tests.rs:349
Functionlocf
(arg: Expr)
core/query_functions/src/gapfill.rs:442
Functionlocf_errs
()
core/query_functions/src/gapfill.rs:450
Methodlock_exclusive
Acquires an exclusive lock, blocking the current thread until it is able to do so.
core/tracker/src/lock.rs:192
Methodlock_shared
Acquires a shared lock, blocking the current thread until it is able to do so.
core/tracker/src/lock.rs:152
Methodlock_upgradable
(&self)
core/tracker/src/lock.rs:249
Methodlog
Catalog files are persisted as a monotonically increasing sequence of files, whose name is `<sequence>.catalog`; `<sequence>` is zero-padded to 20 cha
influxdb3_catalog/src/object_store/versions/v2.rs:342
Methodlog
Catalog files are persisted as a monotonically increasing sequence of files, whose name is `<sequence>.catalog`; `<sequence>` is zero-padded to 20 cha
influxdb3_catalog/src/object_store/versions/v1.rs:171
Methodlog
(catalog_prefix: &str, sequence_number: CatalogSequenceNumber)
influxdb3_catalog/src/object_store/versions/v3.rs:555
Methodlog_files_for_backup
Get the list of log files after the `after` sequence (`after + 1`) and up to and including the `through` sequence. Used in the backup flow to determin
influxdb3_catalog/src/object_store/versions/v3.rs:416
Functionlog_files_for_backup_returns_exact_sequence_range
()
influxdb3_catalog/src/object_store/versions/v2/tests.rs:58
Functionlog_filter_expanded_via_log_filter_env_var
()
influxdb3/tests/cli/log_filter.rs:31
Functionlog_view_decodes_records
()
influxdb3_catalog/src/format/view/tests.rs:19
Methodlogical_plan
Logically plan an InfluxQL query against the catalogs registered with `ctx`, and return a DataFusion logical plan that runs on the query executor.
core/iox_query_influxql/src/frontend/planner.rs:187
Methodlogs_dir
(catalog_prefix: &str)
influxdb3_catalog/src/object_store/versions/v3.rs:568
Functionlong
(c: &mut Criterion)
core/arrow_util/benches/iter_set_positions.rs:38
Functionlookup_namespace_by_id
()
core/data_types/src/snapshot/root.rs:192
Methodlookup_namespace_by_id
Look up a [`RootSnapshotNamespace`] by `NamespaceId` using binary search of the list of namespaces. _Does_ include soft-deleted entries. Hard-deleted
core/data_types/src/snapshot/root.rs:117
Methodlookup_namespace_by_name
Lookup a [`RootSnapshotNamespace`] by name. Does not include deleted entries.
core/data_types/src/snapshot/root.rs:127
Methodlookup_partition_by_key
Lookup a [`TableSnapshotPartition`] by [`PartitionKey`] This currently performs a linear scan of the partitions in this snapshot, but could in future
core/data_types/src/snapshot/table.rs:190
Methodlookup_table_by_id
Look up a [`NamespaceSnapshotTable`] by `TableId` using binary search of the list of tables. _Does_ include soft-deleted entries. Hard-deleted tables
core/data_types/src/snapshot/namespace.rs:192
Methodlookup_table_by_name
Lookup a [`NamespaceSnapshotTable`] by name. Does not include deleted entries.
core/data_types/src/snapshot/namespace.rs:202
Methodlp
(lp: LP, time_seconds: i64)
influxdb3_server/tests/lib.rs:312
Functionlp_to_mutable_batch
Converts the line protocol for a single table into a WritePayload
core/mutable_batch_lp/src/lib.rs:417
Functionmain
()
core/ingester_query_grpc/build.rs:9
Functionmain
()
core/influxdb2_client/examples/health.rs:5
Functionmain
()
core/influxdb2_client/examples/ready.rs:5
Functionmain
()
core/influxdb2_client/examples/label.rs:7
Functionmain
()
core/influxdb2_client/examples/write.rs:7
Functionmain
()
core/influxdb2_client/examples/setup.rs:5
Functionmain
()
core/influxdb2_client/examples/query.rs:7
Functionmain
()
core/object_store_mem_cache/benches/s3_fifo_concurrency.rs:186
Functionmain
()
core/futures_test_utils/benches/buffered_stream.rs:20
Functionmain
()
core/generated_types/build.rs:9
Functionmain
()
core/iox_query_udf/build.rs:41
Functionmain
()
influxdb3_process/build.rs:7
Functionmain
()
influxdb3_load_generator/src/main.rs:80
Functionmain
()
influxdb3/src/main.rs:4
Methodmaintains_input_order
(&self)
core/iox_query/src/exec/series_limit/physical.rs:559
Methodmaintains_input_order
(&self)
core/iox_query/src/exec/gapfill/mod.rs:569
Methodmaintains_input_order
ProgressiveEvalExec will only accept sorted input and will maintain the input order
core/iox_query/src/provider/progressive_eval.rs:186
Methodmaintains_input_order
(&self)
core/iox_query/src/provider/deduplicate.rs:243
Functionmake_field
(name: &str, filled: bool)
core/iox_query_influxql/src/plan/planner/metadata.rs:210
Functionmake_field
( name: &str, data_type: arrow::datatypes::DataType, nullable: bool, column_ty
core/schema/src/lib.rs:1298
Functionmake_panics_fatal
Ensure panics are fatal events by exiting the process with an exit code of 1 after calling the existing panic handler, if any.
core/panic_logging/src/lib.rs:113
Methodmake_request_process_future
Create a boxed future for processing HTTP request events.
influxdb3_processing_engine/src/plugins.rs:575
Methodmake_sort_key
(series_key_names: &[Arc<str>], add_time: bool)
influxdb3_catalog/src/catalog/versions/v2.rs:3270
Methodmake_sort_key
(series_key_names: &[Arc<str>], add_time: bool)
influxdb3_catalog/src/catalog/versions/v1.rs:1579
Methodmake_sort_key
(series_key_names: &[Arc<str>], add_time: bool)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:200
Functionmake_temp_file
Writes the specified string to a new temporary file, returning the Path to the file
core/test_helpers/src/lib.rs:47
Functionmake_time
(v: i64)
core/query_functions/src/window/internal.rs:381
Methodmake_wal_process_future
Create a boxed future for processing WAL data events. Returns the future without awaiting it, allowing caller to choose sync/async execution.
influxdb3_processing_engine/src/plugins.rs:260
Functionmake_window_bound_expr
Create a DataFusion `Expr` that invokes `window_bounds` with the appropriate every and offset arguments at runtime
core/query_functions/src/lib.rs:89
Functionmany_chunks
()
core/iox_v1_query_api/src/response/chunked.rs:260
Functionmany_chunks
()
core/iox_v1_query_api/src/response/json.rs:261
Functionmany_chunks
()
core/iox_v1_query_api/src/response/msgpack.rs:133
Functionmany_chunks_many_measurements
()
core/iox_v1_query_api/src/response/json.rs:303
Functionmany_chunks_many_measurments
()
core/iox_v1_query_api/src/response/msgpack.rs:175
Functionmany_chunks_with_groups
()
core/iox_v1_query_api/src/response/chunked.rs:300
Functionmany_statements
()
core/iox_v1_query_api/src/response/chunked.rs:340
Functionmany_statements
()
core/iox_v1_query_api/src/response/buffered.rs:272
Functionmany_statements
()
core/iox_v1_query_api/src/response/json.rs:345
Functionmany_statements
()
core/iox_v1_query_api/src/response/msgpack.rs:217
Methodmap_exprs
( c: C, exprs: &mut impl Iterator<Item = Expr>, )
core/iox_query/src/exec/series_limit/logical.rs:631
Methodmatches_arrow_type
returns true if the column matches the Arrow data type
core/data_types/src/columns.rs:272
Methodmatches_field_type
returns true if the column type matches the line protocol field value type
core/data_types/src/columns.rs:208
Methodmatches_node
(&self, node: &NodeDefinition)
influxdb3_catalog/src/log/versions/v2.rs:416
Methodmatches_node
(&self, node: &NodeDefinition)
influxdb3_catalog/src/log/versions/v3.rs:531
Methodmatches_node
(&self, node: &NodeDefinition)
influxdb3_catalog/src/log/versions/v4.rs:801
Methodmatches_node
(&self, node: &NodeDefinition)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:274
Methodmatches_node_id
(&self, node_catalog_id: NodeId)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:281
Methodmatches_node_spec
(&self, node_spec: &NodeSpec)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:301
Functionmatches_node_spec_all_and_explicit
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2520
Functionmatches_node_spec_explicit_without_current_node_errors
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2541
Methodmatches_type
Returns true if `mb_column` is of the same type as `self`.
core/data_types/src/columns.rs:277
Methodmax
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:315
Methodmax_as_str
Return the maximum value, if any, formatted as a string
core/data_types/src/lib.rs:2795
Methodmax_columns_per_table
Returns the maximum number of columns allowed per table in this namespace
core/data_types/src/snapshot/namespace.rs:245
Functionmax_float_test
()
influxdb3_telemetry/src/stats/tests.rs:22
Methodmax_level_hint
(&self)
core/logfmt/src/lib.rs:106
Functionmax_num_test
()
influxdb3_telemetry/src/stats/tests.rs:17
Functionmax_parquet_fanout
()
influxdb3_clap_blocks/src/datafusion/tests.rs:7
Methodmax_permits
Returns the configured maximum number of permits.
object_store_limit/src/lib.rs:64
Functionmax_split
()
core/iox_query/src/physical_optimizer/dedup/split.rs:584
Methodmax_tables
Returns the maximum number of tables allowed in this namespace
core/data_types/src/snapshot/namespace.rs:240
← previousnext →7,301–7,400 of 11,906, ranked by callers