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
Methodempty
Create a new empty [`ColumnSet`]
core/data_types/src/columns.rs:618
Methodempty
Create a new empty sort key
core/schema/src/sort.rs:71
Methodempty
An empty preload — sufficient for batches that do not contain a restore record. Passing this to [`apply_records`] errors on the first restore record e
influxdb3_catalog/src/format/apply.rs:185
Functionempty_array_missing_lower_bound
()
core/iox_query/src/exec/gapfill/date_bin_gap_expander.rs:255
Functionempty_array_missing_lower_bound
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:308
Functionempty_array_missing_uppper_bound
()
core/iox_query/src/exec/gapfill/date_bin_gap_expander.rs:232
Functionempty_array_missing_uppper_bound
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:285
Functionempty_array_with_bounds
()
core/iox_query/src/exec/gapfill/date_bin_gap_expander.rs:162
Functionempty_array_with_bounds
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:215
Functionempty_buffer
()
core/linear_buffer/src/linear_buffer.rs:448
Functionempty_database_emits_no_table_records
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:583
Functionempty_parts_is_invalid
()
core/data_types/src/partition_template.rs:1562
Functionempty_payload_takes_single_part_branch
()
object_store_utils/src/adaptive_put.rs:138
Functionempty_schema
Build an empty iterator
core/schema/src/lib.rs:1640
Functionempty_slice
()
core/linear_buffer/src/linear_buffer.rs:367
Functionempty_stream
()
core/iox_v1_query_api/src/response/json.rs:99
Functionempty_stream
()
core/iox_v1_query_api/src/response/msgpack.rs:84
Functionempty_strftime_format_is_invalid
()
core/data_types/src/partition_template.rs:1824
Functionempty_tag_value_is_invalid
()
core/data_types/src/partition_template.rs:1848
Functionempty_transaction_commit_is_a_no_op
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:628
Functionempty_transaction_commit_is_no_op
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:265
Methodenable_iceberg
Enable iceberg exports for a table
core/influxdb_iox_client/src/client/table.rs:106
Functionenable_trigger_round_trip
()
influxdb3_catalog/src/format/records/trigger/tests.rs:67
Methodenabled
(&self, _metadata: &tracing::Metadata<'_>)
core/test_helpers/src/tracing.rs:193
Methodencode
( &self, encoder: &mut E, )
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:90
Methodencode
( &self, encoder: &mut E, )
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/ordered_set.rs:161
Methodencode
Create a new [`PartitionSnapshot`] from the provided state
core/data_types/src/snapshot/partition.rs:94
Methodencode
Create a new [`TableSnapshot`] from the provided state
core/data_types/src/snapshot/table.rs:84
Methodencode
Create a new [`NamespaceSnapshot`] from the provided state
core/data_types/src/snapshot/namespace.rs:85
Methodencode
Encode `values` to a [`MessageList`]
core/data_types/src/snapshot/list.rs:102
Functionencode_basic_header
(token: String)
core/iox_http/src/write/single_tenant/auth.rs:110
Methodencode_by_ref
( &self, buf: &mut <sqlx::Postgres as sqlx::database::Database>::ArgumentBuffer<'_>, )
core/data_types/src/partition.rs:196
Methodencode_by_ref
( &self, buf: &mut DB::ArgumentBuffer<'q>, )
core/data_types/src/columns.rs:377
Methodencode_by_ref
( &self, buf: &mut DB::ArgumentBuffer<'q>, )
core/data_types/src/partition_template.rs:1025
Functionencode_write
Convert a [`DmlWrite`] to a [`DatabaseBatch`]
core/mutable_batch_pb/src/encode.rs:16
Functionend_to_end_begin_add_finalize_commit_applies_records
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:650
Functionendpoint
()
influxdb3_clap_blocks/src/object_store/tests.rs:390
Functionensure_schema
Create a new [`RecordBatch`] that has the specified schema, adding null values for columns that don't appear in the batch.
core/arrow_util/src/util.rs:11
Methodenterprise
Create an enterprise record ID. Raw value = seq | 0x8000 (bit 15 = 1). # Panics Panics at compile time if seq is 0 or >= 0x8000.
influxdb3_catalog/src/format/record_id.rs:35
Functionenterprise_bit_mask
()
influxdb3_catalog/src/format/record_id/tests.rs:44
Functionenterprise_id_raw_value
()
influxdb3_catalog/src/format/record_id/tests.rs:11
Methodeq
(&self, other: &Self)
influxdb3_write/src/async_collections.rs:99
Methodeq
(&self, other: &Self)
core/influxdb_influxql_parser/src/keywords.rs:36
Methodeq
(&self, other: &Self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:1117
Methodeq
(&self, other: &Self)
core/query_functions/src/non_negative.rs:27
Methodeq
(&self, other: &Self)
core/arrow_util/src/test_util.rs:605
Methodeq
(&self, other: &Self)
core/arrow_util/src/dictionary.rs:42
Methodeq
(&self, other: &Self)
core/object_store_mock/src/lib.rs:28
Methodeq
(&self, other: &Self)
core/iox_v1_query_api/src/value.rs:170
Methodeq
(&self, got: &InfluxColumnType)
core/data_types/src/columns.rs:516
Methodeq
(&self, other: &T)
core/data_types/src/partition_template.rs:1117
Methodeq
(&self, other: &Self)
core/influxdb_line_protocol/src/lib.rs:517
Methodeq
(&self, other: &Self)
core/trace/src/ctx.rs:113
Methodeq
(&self, other: &Self)
influxdb3_cache/src/parquet_cache/mod.rs:599
Methodeq
(&self, other: &Self)
influxdb3_test_helpers/src/object_store/mock.rs:23
Methodeq
(&self, other: &usize)
influxdb3_catalog/src/log/versions/v2.rs:502
Methodeq
(&self, other: &usize)
influxdb3_catalog/src/log/versions/v1.rs:284
Methodeq
(&self, other: &usize)
influxdb3_catalog/src/log/versions/v3.rs:617
Methodeq
(&self, other: &usize)
influxdb3_catalog/src/log/versions/v4.rs:887
Methodeq
(&self, other: &usize)
influxdb3_catalog/src/catalog/versions/v3/schema/cache.rs:192
Methodeq
(&self, other: &Self)
influxdb3_wal/src/lib.rs:420
Functionequalize_batch_schemas
Equalize batch schemas by creating NULL columns.
core/arrow_util/src/test_util.rs:170
Methodequivalent
(&self, key: &Entry<T>)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/ordered_set.rs:279
Functionerr_accepted_sender_dropped
()
core/object_store_mem_cache/src/buffer_channel.rs:127
Functionerror
Print an error message formatted like the logging system output.
influxdb3_startup/src/early_logging.rs:36
Methoderror
Trigger an error.
core/influxdb_iox_client/src/client/test.rs:46
Methoderror
(&self, py: Python<'_>, args: &Bound<'_, PyTuple>)
influxdb3_py_api/src/system_py.rs:99
Methoderror_behavior
(mut self, behavior: impl Into<String>)
influxdb3/tests/cli/api.rs:697
Functionerror_behavior_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:147
Functionerror_then_success_is_ok
()
object_store_utils/src/object_store_health/tests.rs:44
Functionerror_variants_carry_error_code
()
influxdb3_internal_api/src/sll/tests.rs:28
Functionescaped_str_basic
()
core/influxdb_line_protocol/src/lib.rs:1414
Functionescaped_str_multi
()
core/influxdb_line_protocol/src/lib.rs:1427
Functionescaped_str_multi_to_string
()
core/influxdb_line_protocol/src/lib.rs:1524
Methodestimate_size
Estimate memory consumption in bytes of the schema. This includes the size of `Self` as well as the inner [`Arc`]ed arrow schema.
core/schema/src/lib.rs:991
Methodestimated_size_bytes
Returns the estimated size of the partition in bytes.
core/data_types/src/snapshot/partition.rs:266
Methodetag
(&self)
core/catalog_cache/src/lib.rs:176
Methodevaluate
(&mut self)
core/iox_query_influxql/src/aggregate/spread.rs:142
Methodevaluate
(&mut self)
core/iox_query_influxql/src/aggregate/percentile.rs:138
Methodevaluate_all
(&mut self, values: &[ArrayRef], num_rows: usize)
core/iox_query_influxql/src/window/percent_row_number.rs:69
Methodevaluate_all
(&mut self, values: &[ArrayRef], _num_rows: usize)
core/iox_query_influxql/src/window/integral.rs:112
Methodevaluate_all
(&mut self, values: &[ArrayRef], _num_rows: usize)
core/iox_query_influxql/src/window/elapsed.rs:59
Methodevaluate_all
(&mut self, values: &[ArrayRef], num_rows: usize)
core/iox_query_influxql/src/window/cumulative_sum.rs:65
Methodevaluate_all
(&mut self, values: &[ArrayRef], _num_rows: usize)
core/iox_query_influxql/src/window/moving_average.rs:66
Methodevaluate_all
( &mut self, values: &[Arc<dyn Array>], num_rows: usize, )
core/query_functions/src/non_negative.rs:109
Methodevaluate_all
(&mut self, values: &[ArrayRef], _num_rows: usize)
core/query_functions/src/difference.rs:85
Methodevaluate_all_with_rank
( &self, num_rows: usize, ranks_in_partition: &[Range<usize>], )
core/query_functions/src/non_negative.rs:129
Functionevaluate_identical_times_returns_infinity
()
core/query_functions/src/derivative.rs:420
Functionevaluate_identical_times_zero_delta_returns_nan
()
core/query_functions/src/derivative.rs:444
Functionevaluate_predicates
()
influxdb3_cache/src/distinct_cache/tests.rs:19
Methodevent
(&self, event: &Event<'_>)
core/test_helpers/src/tracing.rs:201
Methodevent
(&self)
influxdb3_catalog/src/enterprise/format/records/login_identity_oauth.rs:48
Methodevent
(&self)
influxdb3_catalog/src/enterprise/format/records/retention.rs:44
Methodevent
(&self)
influxdb3_catalog/src/enterprise/format/records/token.rs:127
Methodevent
(&self)
influxdb3_catalog/src/format/records/feature_level.rs:28
Methodevent
(&self)
influxdb3_catalog/src/format/records/generation.rs:43
Methodevent
(&self)
influxdb3_catalog/src/format/records/repository.rs:127
Methodevent
(&self)
influxdb3_catalog/src/format/records/trigger.rs:76
Methodevent
(&self)
influxdb3_catalog/src/format/records/user.rs:50
Methodevent
(&self)
influxdb3_catalog/src/format/records/cache.rs:90
← previousnext →6,001–6,100 of 11,906, ranked by callers