Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/influxdata/influxdb
/ functions
Functions
11,906 in github.com/influxdata/influxdb
⨍
Functions
11,906
◇
Types & classes
2,644
↳
Endpoints
4
Function
bench_column_set_insert
Benchmark ColumnSet insertion performance
influxdb3_catalog/benches/column_or_create.rs:262
Function
bench_encode_list
(c: &mut Criterion)
core/catalog_cache/benches/list_encode.rs:22
Function
bench_get_files
Benchmark: get_files across varying file counts. Measures retrieval performance as the number of stored files increases.
influxdb3_write/benches/persisted_files_bench.rs:142
Function
bench_remove_files
Benchmark: add_persisted_snapshot_files with file removals. Measures performance of removing files via snapshot.
influxdb3_write/benches/persisted_files_bench.rs:247
Function
benchmark_inserts
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:71
Function
benchmark_iteration
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:113
Function
benchmark_lookups
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:27
Function
benchmark_mixed_workload
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:149
Function
benchmark_serialization
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:187
Method
benefits_from_input_partitioning
(&self)
core/iox_query/src/provider/progressive_eval.rs:168
Method
benefits_from_input_partitioning
(&self)
core/iox_query/src/provider/deduplicate.rs:247
Function
better_error_messages
()
core/influxdb_line_protocol/src/lib.rs:1227
Function
between
(expr: Expr, low: Expr, high: Expr)
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:290
Method
bind
Create a new [`CatalogCacheServer`] bound to the provided [`SocketAddr`]
core/catalog_cache/src/api/server.rs:394
Method
bind
Create a new [`CatalogCacheServer`] bound to the provided [`SocketAddr`]
core/catalog_cache/src/api/quorum.rs:887
Method
bind_ephemeral
Create a new [`TestCacheServer`] bound to an ephemeral port
core/catalog_cache/src/api/server.rs:389
Method
bind_ephemeral
Create a new [`TestCacheServer`] bound to an ephemeral port
core/catalog_cache/src/api/quorum.rs:882
Method
bitor_assign
(&mut self, rhs: Self)
influxdb3_authz/src/permissions.rs:340
Method
bool_field
Add a boolean field to the line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:106
Method
bottom
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:276
Method
bounded_try_from
Constructs a [`NamespaceServiceProtectionLimitsOverride`] from the provided `value`, performing validation and applying `column_limit_upper_bound` to
core/data_types/src/service_limits.rs:180
Function
box_response
Turn any response into a boxed trait object request with boxed errors.
core/iox_http_util/src/lib.rs:67
Function
broadcast_waits_for_every_subscriber_to_drop
()
influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:94
Function
broadcast_waits_for_message_drop_not_recv
()
influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:47
Function
broadcasts_each_applied_log_to_subscribers
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2313
Function
bucket
(id: u32, num_buckets: u32)
core/partition/src/lib.rs:961
Function
bucket
(id: u32, num_buckets: u32)
core/data_types/src/partition_template.rs:1922
Method
bucket_count
Return the bucket count for the bucket that would hold `v`.
core/test_helpers/src/prometheus.rs:194
Function
bucket_empty_tag_name_is_invalid
()
core/data_types/src/partition_template.rs:1875
Method
bucket_pruning_oracle
(&self)
core/iox_query/src/chunk_statistics.rs:114
Function
bucket_time_tag_name_is_invalid
()
core/data_types/src/partition_template.rs:1861
Function
bucket_too_high_num_buckets_is_invalid
()
core/data_types/src/partition_template.rs:1903
Function
bucket_zero_num_buckets_is_invalid
()
core/data_types/src/partition_template.rs:1889
Function
bucketing_on_fields_panics
()
core/partition/src/lib.rs:916
Method
buckets
Return all buckets in the histogram.
core/test_helpers/src/prometheus.rs:189
Function
buffer_too_short_for_header
()
influxdb3_catalog/src/format/reader/tests.rs:89
Function
buffer_too_short_for_payload
()
influxdb3_catalog/src/format/reader/tests.rs:104
Function
buffer_too_short_rejected
()
influxdb3_catalog/src/format/header/tests.rs:107
Method
buffered_input
(offset: usize)
core/iox_query/src/exec/gapfill/algo.rs:969
Method
build
( &mut self, table_partition_template: Option<&TablePartitionTemplateOverride>, )
core/iox_query/src/pruning_oracle.rs:114
Method
build
(&self)
core/trace_exporters/src/lib.rs:138
Method
build
Build the line protocol string.
influxdb3_py_api/src/line_builder/line_builder.py:117
Method
build_actions_for_type
( resource_type: ResourceType, actions: &[String], )
influxdb3_authz/src/permissions.rs:155
Method
build_from_key
Reverse a `partition_key` generated from the `template` used to create this builder, reconstructing the set of tag values and bucket IDs the `partitio
core/data_types/src/partition_template.rs:1161
Function
build_partition_with_multiple_sort_keys
Build min/maxes for a partition with three sort keys: 1. An integer sort key 2. A string sort key 3. A timestamp sort key (nanoseconds)
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:517
Function
build_partition_with_single_sort_key
(ints: (Option<i64>, Option<i64>))
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:505
Method
build_resource_ids_for_type
( resource_type: ResourceType, name_to_id_provider: Arc<dyn ResourceNameToIdProvider>,
influxdb3_authz/src/permissions.rs:133
Function
build_venv
Create the venv at [`VENV_PATH`] if it does not already exist. This is the seconds-long step; it runs once and is shared by every [`PendingVenv::ready
influxdb3_processing_engine/src/environment.rs:253
Function
build_with_uri
()
core/client_util/src/connection.rs:301
Method
builder
Create a builder to incrementally construct a `DataPoint`.
core/influxdb2_client/src/models/data_point.rs:104
Method
builder
Set up builder with the given remote endpoint.
core/catalog_cache/src/api/client.rs:179
Method
builder
Create a [`LexicalRangeBuilder`]
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:55
Method
builder_testing
(catalog_id: impl Into<Arc<str>>)
influxdb3_catalog/src/catalog/versions/v2.rs:1350
Method
builder_testing
Create a [`CatalogBuilder`] for assembling a `Catalog`. # Implementation Note This is intended for tests.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:524
Method
bytes_read
Returns the number of bytes read from the wire if relevant
core/dml/src/lib.rs:42
Method
cache
(&self, py: Python<'_>)
influxdb3_py_api/src/system_py.rs:318
Method
cache_already_exists
(reason: impl Into<String>)
influxdb3_cache/src/last_cache/mod.rs:39
Function
cache_create_committed_reports_applied_metadata
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3644
Function
cache_evicts_lru_when_full
()
influxdb3_cache/src/parquet_cache/tests.rs:235
Function
cache_hit_while_fetching
()
influxdb3_cache/src/parquet_cache/tests.rs:359
Function
cache_key_column_predicates
()
influxdb3_cache/src/last_cache/tests.rs:114
Function
cache_metrics
()
influxdb3_cache/src/parquet_cache/tests.rs:498
Function
cache_pruning
()
influxdb3_cache/src/distinct_cache/tests.rs:221
Function
cache_source_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:22
Function
cache_ttl
()
influxdb3_cache/src/last_cache/tests.rs:483
Function
caches_emitted_between_add_columns_and_soft_delete
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1057
Function
calculate_hash
(t: &T)
core/influxdb_line_protocol/src/lib.rs:1464
Function
call
(called: &AtomicBool)
core/trogging/src/lib.rs:544
Method
call
(&mut self, req: Request<Incoming>)
influxdb3_server/src/unified_service/service.rs:57
Method
call
(&mut self, mut req: Request<B>)
influxdb3_server/src/unified_service/remote_addr_layer.rs:51
Method
call
(&mut self, mut request: Request<ReqBody>)
core/client_util/src/tower.rs:72
Method
call
(&self, req: HttpRequest)
core/object_store_mock/src/interceptor.rs:112
Method
call
(&mut self, mut request: Request<ReqBody>)
core/tower_trailer/src/lib.rs:47
Method
call
(&self, args: &[Expr])
influxdb3_cache/src/distinct_cache/table_function.rs:232
Method
call
(&self, args: &[Expr])
influxdb3_cache/src/last_cache/table_function.rs:306
Function
call_expression
Parse a function call expression. The `name` field of the [`Expr::Call`] variant is guaranteed to be in lowercase.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:471
Method
calls
(&self)
core/iox_http/src/write.rs:61
Method
calls
(&self)
core/sharder/src/mock.rs:61
Function
can_create_after_deleting_previous
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1557
Function
can_re_register_matrix
()
influxdb3_catalog/src/catalog/versions/v3/schema/node/node_definition_tests.rs:19
Function
can_read_slice_after_buffer_drop
()
core/linear_buffer/src/linear_buffer.rs:400
Function
catalog_file_path_logs_dir_returns_logs_dir
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:237
Function
catalog_file_path_restore_staging_dir_returns_staging_dir
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:245
Method
catalog_id
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:268
Function
catalog_initialization
()
influxdb3_cache/src/last_cache/tests.rs:1115
Function
catalog_limits_new_returns_stored_values_regardless_of_usage
()
influxdb3_catalog/src/catalog/versions/v3/usage/tests.rs:21
Function
catalog_limits_none_is_effectively_unbounded
()
influxdb3_catalog/src/catalog/versions/v3/usage/tests.rs:12
Function
catalog_serialization
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:22
Function
catalog_service_parquet_file_serde_roundtrip
()
core/data_types/src/lib.rs:3520
Function
catalog_snapshots_only_if_updated
()
influxdb3_write/src/write_buffer/tests.rs:720
Function
catalog_storage_service_namespace_serde_roundtrip
()
core/data_types/src/lib.rs:3546
Function
catalog_storage_service_table_serde_roundtrip
()
core/data_types/src/lib.rs:3585
Function
catalog_supports_more_than_255_tag_columns
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:4987
Method
catalog_update_if_not_exists
( &self, path: CatalogFilePath, content: Bytes, )
influxdb3_catalog/src/object_store/versions/v1.rs:111
Method
catalog_uuid
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:174
Function
catch_up_broadcasts_events_from_other_writer
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:217
Function
catches_up_after_remote_writer_lands_a_log
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2182
Method
categorize
Classify an [`object_store::Error`] into an operator-friendly category. Note: this does **not** return [`ErrorCategory::Timeout`]. The `object_store`
object_store_utils/src/object_store_health.rs:67
Function
categorize_maps_object_store_errors
()
object_store_utils/src/object_store_health/tests.rs:53
Method
check_arg_count
(name: &str, args: &[IQLExpr], count: usize)
core/iox_query_influxql/src/plan/planner.rs:2665
← previous
next →
5,301–5,400 of 11,906, ranked by callers