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
Methodas_database
(&self)
influxdb3_catalog/src/log/versions/v4.rs:184
Methodas_delete
(&self)
influxdb3_catalog/src/log/versions/v3.rs:114
Methodas_delete
(&self)
influxdb3_catalog/src/log/versions/v4.rs:198
Methodas_generation
(&self)
influxdb3_catalog/src/log/versions/v3.rs:144
Methodas_generation
(&self)
influxdb3_catalog/src/log/versions/v4.rs:234
Functionas_mib
(bytes: f64)
influxdb3_load_generator/src/commands/write_fixed.rs:141
Methodas_node
(&self)
influxdb3_catalog/src/log/versions/v2.rs:91
Methodas_node
(&self)
influxdb3_catalog/src/log/versions/v3.rs:134
Methodas_node
(&self)
influxdb3_catalog/src/log/versions/v4.rs:222
Methodas_option
Returns `None` if the scope is `DataAndCatalog`, otherwise `Some(scope)`.
influxdb3_catalog/src/catalog/versions/v2.rs:4689
Methodas_primitive_opt
(&self)
core/iox_v1_query_api/src/value.rs:85
Methodas_record_batch
Creates record batch for given event type `E`, this avoids any unnecessary allocation but events need to implement [`ToRecordBatch`] trait
influxdb3_sys_events/src/lib.rs:101
Methodas_ref
(&self)
influxdb3_catalog/src/object_store/versions/v1.rs:200
Methodas_soft_delete_database
(&self)
influxdb3_catalog/src/log/versions/v4.rs:418
Methodas_soft_delete_table
(&self)
influxdb3_catalog/src/log/versions/v4.rs:425
Methodas_sort_expr
creates a DataFusion SortExpr
core/datafusion_util/src/lib.rs:57
Methodas_storage_mode
(&self)
influxdb3_catalog/src/log/versions/v4.rs:246
Methodas_store
(self: Arc<Self>)
influxdb3_test_helpers/src/object_store/mock.rs:329
Methodas_str
(self)
object_store_utils/src/object_store_health.rs:24
Methodas_str
(&self)
influxdb3_catalog/src/log/versions/v3.rs:327
Methodas_str
(&self)
influxdb3_catalog/src/log/versions/v4.rs:468
Methodas_str
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:968
Functionas_str_renders_four_strings
()
influxdb3_catalog/src/catalog/versions/v3/schema/node/node_state_tests.rs:51
Methodas_token
(&self)
influxdb3_catalog/src/log/versions/v4.rs:191
Methodas_vec
Creates an intermediate `Vec` by cloning events. To create a record batch instead use [`Self::as_record_batch`]
influxdb3_sys_events/src/lib.rs:80
Methodas_write
(&self)
influxdb3_wal/src/lib.rs:278
Functionassert_delete_op_eq
Asserts `a` contains a [`DmlDelete`] equal to `b`
core/dml/src/lib.rs:333
Functionassert_disk_usage_ratio
()
core/tracker/src/disk_metric.rs:293
Methodassert_log_matches
Assert that the captured logs match a regex pattern
influxdb3/tests/server/mod.rs:816
Functionassert_op_eq
Asserts two operations are equal
core/dml/src/lib.rs:296
Functionassert_send
()
core/linear_buffer/src/linear_buffer.rs:529
Functionassert_send
()
core/predicate/src/rpc_predicate.rs:593
Functionassert_sync
()
core/linear_buffer/src/linear_buffer.rs:530
Functionassert_write_op_eq
Asserts `a` contains a [`DmlWrite`] equal to `b`
core/dml/src/lib.rs:305
Methodasync_drop
(self)
core/object_store_mem_cache/src/store.rs:141
Methodasync_drop
Drop an `Arc<T>`. Note that if this reference is still used elsewhere, it will not drop the inner value. This is expected behavior and can be compens
core/object_store_mem_cache/src/cache_system/mod.rs:180
Methodasync_drop
(self)
core/object_store_mem_cache/src/cache_system/test_utils.rs:715
Methodasync_drop
(self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:138
Functionat_boundary_for_timezone
()
core/query_functions/src/date_bin_wallclock.rs:601
Methodaugment_args
we're not flattening so these can just return command()
influxdb3/src/commands/create/token.rs:336
Methodaugment_args_for_update
(_cmd: clap::Command)
influxdb3/src/commands/create/token.rs:340
Functionauth_grpc
()
influxdb3/tests/server/auth.rs:196
Functionauth_http
()
influxdb3/tests/server/auth.rs:13
Methodauthorize
( &self, token: Option<Vec<u8>>, perms: &[IoxPermission], )
influxdb3_authz/src/authorizer.rs:191
Methodauthorize
( &self, request: Request<AuthorizeRequest>, )
core/test_helpers_authz/src/authz.rs:158
Methodauthorize
( &self, token: Option<Vec<u8>>, perms: &[Permission], )
core/authz/src/instrumentation.rs:56
Methodauthorize
( &self, _token: Option<Vec<u8>>, perms: &[Permission],
core/iox_http/src/write/single_tenant/mod.rs:200
Methodauto_cache_name
Get the reserved name for auto-generated caches
influxdb3_catalog/src/log/versions/v4.rs:1074
Methodauto_cache_name
Get the reserved name for auto-generated caches
influxdb3_catalog/src/catalog/versions/v3/schema/cache.rs:432
Functionauto_family_rolls_to_next
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:103
Functionauto_mode
()
influxdb3_catalog/src/catalog/migrations/v2/tests.rs:317
Functionauto_mode_does_not_parse_double_colon
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:777
Methodavailable_disk_space
The available space in bytes on the disk.
core/tracker/src/disk_metric.rs:41
Functionavg_float_test
()
influxdb3_telemetry/src/stats/tests.rs:32
Functionavg_float_test_max
()
influxdb3_telemetry/src/stats/tests.rs:39
Functionavg_num_test
()
influxdb3_telemetry/src/stats/tests.rs:27
Functionavg_num_test_max
()
influxdb3_telemetry/src/stats/tests.rs:46
Functionavg_test
()
influxdb3_telemetry/src/stats/tests.rs:82
Functionavg_test_new_value_lower
()
influxdb3_telemetry/src/stats/tests.rs:71
Functionaware_mode_ddl_routes_qualified_fields_to_named_families
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1611
Functionaware_mode_ddl_unqualified_field_uses_auto_family
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1649
Functionaware_mode_malformed_qualifier_treated_as_unqualified
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:751
Functionaware_mode_named_family_enforces_field_limit
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:798
Functionaware_mode_routes_qualified_field_to_named_family
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:694
Functionaware_mode_unqualified_field_uses_auto_family
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:728
Functionazure_config_missing_params
()
influxdb3_clap_blocks/src/object_store/tests.rs:311
Methodbackground_update
(&self, duration: Duration, shutdown_token: ShutdownToken)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:310
Methodbackup_view
Read the checkpoint bytes and its decoded sequence together so the backup flow gets a stable checkpoint image. Returning only the live checkpoint path
influxdb3_catalog/src/catalog/versions/v2.rs:596
Functionbackup_view_errors_when_checkpoint_is_ahead_of_live_sequence
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:374
Functionbackup_view_errors_when_checkpoint_is_ahead_of_live_sequence
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:4055
Functionbackup_view_keeps_checkpoint_bytes_stable_after_live_checkpoint_changes
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:140
Functionbackup_view_keeps_checkpoint_bytes_stable_after_live_checkpoint_changes
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3870
Functionbackup_view_returns_checkpoint_bytes_and_following_logs
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:78
Functionbackup_view_returns_checkpoint_bytes_and_following_logs
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3831
Functionbare_debug_expands
()
influxdb3/src/lib_tests.rs:94
Functionbare_trace_expands
()
influxdb3/src/lib_tests.rs:101
Methodbase_url
Return the base URL this client is bound to.
influxdb3_client/src/lib.rs:215
Functionbasic
()
core/executor/src/lib.rs:394
Functionbasic_clone
()
core/executor/src/lib.rs:413
Functionbasic_distinct_cache
()
influxdb3_catalog/src/catalog/migrations/v2/tests.rs:886
Functionbasic_integers_functionality
()
core/table_batch/src/builder/column_writer/mod.rs:327
Functionbasic_operations
()
object_store_limit/src/tests.rs:11
Functionbasic_strings
()
core/table_batch/src/builder/column_writer/mod.rs:402
Functionbasic_tags
()
core/table_batch/src/builder/column_writer/mod.rs:436
Functionbasic_times
()
core/table_batch/src/builder/column_writer/mod.rs:374
Methodbatch
Converts this to a [`RecordBatch`]
core/mutable_batch/tests/writer_fuzz.rs:125
Methodbatch
(&self)
influxdb3_catalog/src/log/versions/v3.rs:219
Methodbatch
(&self)
influxdb3_catalog/src/log/versions/v4.rs:354
Functionbatch_creation_continues_after_line_error_limit
()
core/mutable_batch_lp/src/lib.rs:807
Functionbatch_filter
Filter data from RecordBatch Borrowed from DF's <https://github.com/apache/arrow-datafusion/blob/ecd0081bde98e9031b81aa6e9ae2a4f309fcec12/datafusion/
core/datafusion_util/src/lib.rs:402
Functionbatches_to_sorted_lines
Converts the [`RecordBatch`]es into a pretty printed output suitable for comparing in tests where sorting does not matter.
core/arrow_util/src/test_util.rs:96
Methodbegin
Alias for [`Self::begin_database_transaction`], matching v2's `begin(db_name)` shape so consumers (write-buffer validators, write path) compile agains
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2627
Functionbegin_auto_creates_missing_database
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:512
Functionbegin_database_transaction_rejected_at_db_limit
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1807
Functionbegin_on_existing_database_does_not_stage_create
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:534
Functionbench_add_files
Benchmark: add_persisted_snapshot_files with new files. Measures performance of adding files via snapshot.
influxdb3_write/benches/persisted_files_bench.rs:164
Functionbench_add_files_existing
Benchmark: add_persisted_snapshot_files with existing db/table structure. Unlike bench_add_files which starts empty, this benchmark pre-populates the
influxdb3_write/benches/persisted_files_bench.rs:202
Functionbench_column_lookup_hits
Benchmark column lookups that already exist (hits)
influxdb3_catalog/benches/column_or_create.rs:158
Functionbench_column_lookup_misses
Benchmark column lookups that miss (not found)
influxdb3_catalog/benches/column_or_create.rs:191
Functionbench_column_lookup_mixed
Benchmark mixed workload (90% hits, 10% misses)
influxdb3_catalog/benches/column_or_create.rs:221
← previousnext →5,201–5,300 of 11,906, ranked by callers