Functions — github.com/influxdata/influxdb

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4

Methodcheck_arg_count_range

( name: &str, args: &[IQLExpr], min: usize, max: usize,

core/iox_query_influxql/src/plan/planner.rs:2676

Methodcheck_arrow

Returns `Ok(true)` if the Arrow Flight service is serving

core/influxdb_iox_client/src/client/health.rs:47

Methodcheck_for_deplicates

(columns: &[ColumnId])

core/data_types/src/columns.rs:850

Methodcheck_name

Check if the column name is available and not a reserved name.

influxdb3_catalog/src/catalog/versions/v2.rs:3294

Functioncheck_table_batch_size

()

core/data_types/src/partition.rs:712

Methodcheckpoint

The Catalog checkpoint file is periodically persisted to object store at the same location

influxdb3_catalog/src/object_store/versions/v2.rs:352

Methodcheckpoint

The Catalog checkpoint file is periodically persisted to object store at the same location

influxdb3_catalog/src/object_store/versions/v1.rs:181

Methodcheckpoint_exists

Check if the catalog checkpoint file is present in this store, which would indicate that the catalog has been initialized, and is used to check if the

influxdb3_catalog/src/object_store/versions/v1.rs:151

Methodcheckpoint_for_backup

Read the live snapshot file and return its sequence number together with the snapshot path, for use as a backup starting checkpoint. In v3 the snapsh

influxdb3_catalog/src/object_store/versions/v3.rs:398

Functioncheckpoint_for_backup_reads_checkpoint_sequence_and_bytes

()

influxdb3_catalog/src/object_store/versions/v2/tests.rs:40

Methodchildren

(&self)

core/iox_query_influxql/src/frontend/planner.rs:142

Methodchildren

(&self)

core/iox_query/src/exec.rs:619

Methodchildren

(&self)

core/iox_query/src/exec/split.rs:244

Methodchildren

(&self)

core/iox_query/src/exec/series_limit/physical.rs:480

Methodchildren

(&self)

core/iox_query/src/provider/progressive_eval.rs:190

Methodchildren

(&self)

core/iox_query/src/provider/deduplicate.rs:251

Methodchildren

(&self)

core/iox_query/src/provider/record_batch_exec.rs:165

Methodchildren

(&self)

core/iox_query/src/provider/reorder_partitions.rs:141

Methodchildren

(&self)

core/iox_system_tables/src/system_tables.rs:164

Methodchildren

(&self)

influxdb3_query_executor/src/query_planner.rs:140

Methodchildren

(&self)

influxdb3_cache/src/distinct_cache/table_function.rs:389

Methodchildren

(&self)

influxdb3_cache/src/last_cache/table_function.rs:443

Functionchildren_and_timestamps

()

core/iox_query/src/exec/query_tracing.rs:387

Functionchunk_ids

(chunks: &[Arc<dyn QueryChunk>])

core/iox_query/src/physical_optimizer/chunk_extraction.rs:390

Methodchunk_type

(&self)

influxdb3_write/src/chunk.rs:52

Methodchunk_type

(&self)

core/iox_query/src/ingester.rs:254

Methodchunk_type

(&self)

core/iox_query/src/test.rs:1225

Functionclean_migration_writes_v3_snapshot_and_fences_v2

()

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1703

Methodcleanup_old_checkpoints_for_month

Cleans up old checkpoints for a given month, keeping only the N most recent. This is called after successfully persisting a new checkpoint to prevent

influxdb3_write/src/persister.rs:823

Methodclear

Clear notification status.

core/catalog_cache/src/local/limit.rs:111

Methodclear

Wipe everything.

core/catalog_cache/src/local/mod.rs:153

Methodclear

Clears this dictionary removing all elements

core/arrow_util/src/dictionary.rs:136

Methodclear_buffer_for_db

(&self, db_id: &DbId)

influxdb3_write/src/write_buffer/queryable_buffer.rs:464

Functionclear_db_retention_round_trip

()

influxdb3_catalog/src/format/records/retention/tests.rs:42

Functionclear_table_retention_round_trip

()

influxdb3_catalog/src/enterprise/format/records/retention/tests.rs:56

Methodclear_timestamp_if_max_range

Removes the timestamp range from this predicate, if the range is for the entire min/max valid range. This is used in certain cases to retain compatib

core/predicate/src/rpc_predicate.rs:115

Methodcli_params

(&self)

influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:118

Methodclone_inner

(&self)

influxdb3_catalog/src/catalog/versions/v1.rs:264

Functionclone_inner_returns_disconnected_copy

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2122

Methodclose

(mut self)

core/test_helpers_authz/src/authz.rs:71

Functionclosed_subscriber_causes_send_failure

()

influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:202

Methodcoerce_types

(&self, arg_types: &[DataType])

core/query_functions/src/to_timestamp.rs:57

Functioncollect_output

(stream: impl Stream<Item = Response> + Send)

core/iox_v1_query_api/src/response/chunked.rs:445

Functioncollect_output

(stream: impl Stream<Item = Response> + Send)

core/iox_v1_query_api/src/response/buffered.rs:382

Functioncollect_output

(stream: S)

core/iox_v1_query_api/src/response/json.rs:448

Functioncollect_output

(stream: S)

core/iox_v1_query_api/src/response/msgpack.rs:319

Functioncollect_via_futures_buffered_steam

(chunks: Vec<BoxFuture<'static, ()>>)

core/futures_test_utils/benches/buffered_stream.rs:125

Functioncollect_via_futures_concurrency_co_steam

(chunks: Vec<BoxFuture<'static, ()>>)

core/futures_test_utils/benches/buffered_stream.rs:133

Methodcolumn

(&self, column: &str)

core/partition/src/traits/record_batch.rs:59

Methodcolumn_by_index

Returns a reference to the column at the specified index

core/mutable_batch/src/lib.rs:225

Methodcolumn_count

Return number of columns in the set.

core/data_types/src/columns.rs:89

Methodcolumn_count

Total number of columns in this line, including fields, tags, and timestamp (timestamp is always present). ``` use influxdb_line_protocol::{ParsedLin

core/influxdb_line_protocol/src/lib.rs:312

Methodcolumn_count

Total number of columns in this line, including fields, tags, and timestamp (timestamp is always present). ``` use influxdb_line_protocol::{ParsedLin

core/influxdb_line_protocol/src/v3/mod.rs:80

Methodcolumn_definition

TODO(trevor): remove thid API in favour of the Repository APIs

influxdb3_catalog/src/catalog/versions/v1.rs:1763

Methodcolumn_definition_by_id

TODO(trevor): remove thid API in favour of the Repository APIs

influxdb3_catalog/src/catalog/versions/v1.rs:1768

Methodcolumn_definition_by_id

(&self, column_id: &ColumnId)

influxdb3_catalog/src/catalog/versions/v3/legacy.rs:61

Functioncolumn_definition_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:50

Methodcolumn_exists

Check if the column exists in the [`TableDefinition`]

influxdb3_catalog/src/catalog/versions/v2.rs:3381

Methodcolumn_exists

Check if the column exists in the [`TableDefinition`]

influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:232

Methodcolumn_id

(&self)

influxdb3_catalog/src/snapshot/versions/v4.rs:188

Methodcolumn_id

(&self)

influxdb3_catalog/src/format/records/types.rs:103

Methodcolumn_id_map

Create `ID->name` map for columns.

core/data_types/src/lib.rs:890

Methodcolumn_id_to_name

TODO(trevor): remove thid API in favour of the Repository APIs

influxdb3_catalog/src/catalog/versions/v1.rs:1758

Methodcolumn_id_to_name

(&self, column_id: &ColumnId)

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:87

Methodcolumn_id_to_name

(&self, column_id: &ColumnId)

influxdb3_catalog/src/catalog/versions/v3/legacy.rs:79

Methodcolumn_id_to_name

(&self, column_id: &ColumnIdentifier)

influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:396

Functioncolumn_identifier_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:37

Methodcolumn_ids

Returns the columns IDs

core/data_types/src/snapshot/partition.rs:253

Functioncolumn_is_field

()

core/predicate/src/rpc_predicate/column_rewrite.rs:78

Methodcolumn_name_to_id

TODO(trevor): remove thid API in favour of the Repository APIs

influxdb3_catalog/src/catalog/versions/v1.rs:1753

Methodcolumn_name_to_id

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:76

Methodcolumn_name_to_id

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v3/legacy.rs:68

Methodcolumn_name_to_id

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:400

Methodcolumn_name_to_id_unchecked

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:80

Methodcolumn_name_to_id_unchecked

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v3/legacy.rs:72

Methodcolumn_name_to_id_unchecked

(&self, column_name: impl AsRef<str>)

influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:404

Methodcolumn_names

Return the set of column names for this table. Used in combination with a write operation's column names to determine whether a write would exceed the

core/data_types/src/lib.rs:901

Methodcolumn_names

Return the set of column names for this table. Used in combination with a write operation's column names to determine whether a write would exceed the

core/mutable_batch/src/lib.rs:160

Methodcolumn_or_create

( &mut self, table_name: &str, column_name: &str, column_type: FieldDataType,

influxdb3_catalog/src/catalog/versions/v1/update.rs:859

Functioncolumn_or_create_enforces_column_limit

()

influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:244

Functioncolumn_or_create_for_each_column_kind

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:572

Methodcolumn_per_table_limit

(&self, current: &CurrentCatalogUsage)

influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:102

Methodcolumn_type

(&self)

influxdb3_catalog/src/format/records/types.rs:119

Functioncolumn_type_conflict_returns_invalid_column_type

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:607

Functioncolumn_type_serde

()

core/data_types/src/columns.rs:1224

Functioncolumn_update_from_boolean

()

core/data_types/src/lib.rs:3227

Functioncolumn_update_from_u64

()

core/data_types/src/lib.rs:3251

Methodcolumns

Returns an iterator of the columns in this table

core/data_types/src/snapshot/table.rs:171

Functioncombine_adjacent_ranges_from_same_filegroup

If the partitioned files (a.k.a. scanned ranges) are adjacent to each other, than combine into a single range scan. This is required to handle the li

core/iox_query/src/physical_optimizer/sort/regroup_files.rs:208

Functioncommand

(config: Config)

influxdb3_commands/src/enable.rs:57

Functioncommand

(config: Config)

influxdb3_commands/src/write.rs:94

Functioncommand

(config: Config)

influxdb3_commands/src/install.rs:20

Functioncommand

(config: Config)

influxdb3_commands/src/disable.rs:57

Functioncommand

(config: Config)

influxdb3_commands/src/test.rs:110

Functioncommand

(config: Config)

influxdb3_commands/src/query.rs:92

Functioncommand

(config: Config)

influxdb3_commands/src/debug/mod.rs:18

Functioncommand

(config: Config)

influxdb3_commands/src/debug/catalog/mod.rs:36

Functioncommand

(config: WriteFixedConfig)

influxdb3_load_generator/src/commands/write_fixed.rs:157

Functioncommand

(mut config: Config)

influxdb3_load_generator/src/commands/write.rs:112

Functioncommand

(mut config: Config)

influxdb3_load_generator/src/commands/query.rs:58

← previous next →5,401–5,500 of 11,906, ranked by callers