MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

Functionbench_column_set_insert
Benchmark ColumnSet insertion performance
influxdb3_catalog/benches/column_or_create.rs:262
Functionbench_encode_list
(c: &mut Criterion)
core/catalog_cache/benches/list_encode.rs:22
Functionbench_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
Functionbench_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
Functionbenchmark_inserts
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:71
Functionbenchmark_iteration
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:113
Functionbenchmark_lookups
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:27
Functionbenchmark_mixed_workload
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:149
Functionbenchmark_serialization
(c: &mut Criterion)
influxdb3_id/benches/serde_vec_map_comparison.rs:187
Methodbenefits_from_input_partitioning
(&self)
core/iox_query/src/provider/progressive_eval.rs:168
Methodbenefits_from_input_partitioning
(&self)
core/iox_query/src/provider/deduplicate.rs:247
Functionbetter_error_messages
()
core/influxdb_line_protocol/src/lib.rs:1227
Functionbetween
(expr: Expr, low: Expr, high: Expr)
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:290
Methodbind
Create a new [`CatalogCacheServer`] bound to the provided [`SocketAddr`]
core/catalog_cache/src/api/server.rs:394
Methodbind
Create a new [`CatalogCacheServer`] bound to the provided [`SocketAddr`]
core/catalog_cache/src/api/quorum.rs:887
Methodbind_ephemeral
Create a new [`TestCacheServer`] bound to an ephemeral port
core/catalog_cache/src/api/server.rs:389
Methodbind_ephemeral
Create a new [`TestCacheServer`] bound to an ephemeral port
core/catalog_cache/src/api/quorum.rs:882
Methodbitor_assign
(&mut self, rhs: Self)
influxdb3_authz/src/permissions.rs:340
Methodbool_field
Add a boolean field to the line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:106
Methodbottom
(call: &'a Call)
core/iox_query_influxql/src/plan/planner/select.rs:276
Methodbounded_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
Functionbox_response
Turn any response into a boxed trait object request with boxed errors.
core/iox_http_util/src/lib.rs:67
Functionbroadcast_waits_for_every_subscriber_to_drop
()
influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:94
Functionbroadcast_waits_for_message_drop_not_recv
()
influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:47
Functionbroadcasts_each_applied_log_to_subscribers
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2313
Functionbucket
(id: u32, num_buckets: u32)
core/partition/src/lib.rs:961
Functionbucket
(id: u32, num_buckets: u32)
core/data_types/src/partition_template.rs:1922
Methodbucket_count
Return the bucket count for the bucket that would hold `v`.
core/test_helpers/src/prometheus.rs:194
Functionbucket_empty_tag_name_is_invalid
()
core/data_types/src/partition_template.rs:1875
Methodbucket_pruning_oracle
(&self)
core/iox_query/src/chunk_statistics.rs:114
Functionbucket_time_tag_name_is_invalid
()
core/data_types/src/partition_template.rs:1861
Functionbucket_too_high_num_buckets_is_invalid
()
core/data_types/src/partition_template.rs:1903
Functionbucket_zero_num_buckets_is_invalid
()
core/data_types/src/partition_template.rs:1889
Functionbucketing_on_fields_panics
()
core/partition/src/lib.rs:916
Methodbuckets
Return all buckets in the histogram.
core/test_helpers/src/prometheus.rs:189
Functionbuffer_too_short_for_header
()
influxdb3_catalog/src/format/reader/tests.rs:89
Functionbuffer_too_short_for_payload
()
influxdb3_catalog/src/format/reader/tests.rs:104
Functionbuffer_too_short_rejected
()
influxdb3_catalog/src/format/header/tests.rs:107
Methodbuffered_input
(offset: usize)
core/iox_query/src/exec/gapfill/algo.rs:969
Methodbuild
( &mut self, table_partition_template: Option<&TablePartitionTemplateOverride>, )
core/iox_query/src/pruning_oracle.rs:114
Methodbuild
(&self)
core/trace_exporters/src/lib.rs:138
Methodbuild
Build the line protocol string.
influxdb3_py_api/src/line_builder/line_builder.py:117
Methodbuild_actions_for_type
( resource_type: ResourceType, actions: &[String], )
influxdb3_authz/src/permissions.rs:155
Methodbuild_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
Functionbuild_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
Functionbuild_partition_with_single_sort_key
(ints: (Option<i64>, Option<i64>))
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:505
Methodbuild_resource_ids_for_type
( resource_type: ResourceType, name_to_id_provider: Arc<dyn ResourceNameToIdProvider>,
influxdb3_authz/src/permissions.rs:133
Functionbuild_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
Functionbuild_with_uri
()
core/client_util/src/connection.rs:301
Methodbuilder
Create a builder to incrementally construct a `DataPoint`.
core/influxdb2_client/src/models/data_point.rs:104
Methodbuilder
Set up builder with the given remote endpoint.
core/catalog_cache/src/api/client.rs:179
Methodbuilder
Create a [`LexicalRangeBuilder`]
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:55
Methodbuilder_testing
(catalog_id: impl Into<Arc<str>>)
influxdb3_catalog/src/catalog/versions/v2.rs:1350
Methodbuilder_testing
Create a [`CatalogBuilder`] for assembling a `Catalog`. # Implementation Note This is intended for tests.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:524
Methodbytes_read
Returns the number of bytes read from the wire if relevant
core/dml/src/lib.rs:42
Methodcache
(&self, py: Python<'_>)
influxdb3_py_api/src/system_py.rs:318
Methodcache_already_exists
(reason: impl Into<String>)
influxdb3_cache/src/last_cache/mod.rs:39
Functioncache_create_committed_reports_applied_metadata
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3644
Functioncache_evicts_lru_when_full
()
influxdb3_cache/src/parquet_cache/tests.rs:235
Functioncache_hit_while_fetching
()
influxdb3_cache/src/parquet_cache/tests.rs:359
Functioncache_key_column_predicates
()
influxdb3_cache/src/last_cache/tests.rs:114
Functioncache_metrics
()
influxdb3_cache/src/parquet_cache/tests.rs:498
Functioncache_pruning
()
influxdb3_cache/src/distinct_cache/tests.rs:221
Functioncache_source_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:22
Functioncache_ttl
()
influxdb3_cache/src/last_cache/tests.rs:483
Functioncaches_emitted_between_add_columns_and_soft_delete
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1057
Functioncalculate_hash
(t: &T)
core/influxdb_line_protocol/src/lib.rs:1464
Functioncall
(called: &AtomicBool)
core/trogging/src/lib.rs:544
Methodcall
(&mut self, req: Request<Incoming>)
influxdb3_server/src/unified_service/service.rs:57
Methodcall
(&mut self, mut req: Request<B>)
influxdb3_server/src/unified_service/remote_addr_layer.rs:51
Methodcall
(&mut self, mut request: Request<ReqBody>)
core/client_util/src/tower.rs:72
Methodcall
(&self, req: HttpRequest)
core/object_store_mock/src/interceptor.rs:112
Methodcall
(&mut self, mut request: Request<ReqBody>)
core/tower_trailer/src/lib.rs:47
Methodcall
(&self, args: &[Expr])
influxdb3_cache/src/distinct_cache/table_function.rs:232
Methodcall
(&self, args: &[Expr])
influxdb3_cache/src/last_cache/table_function.rs:306
Functioncall_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
Methodcalls
(&self)
core/iox_http/src/write.rs:61
Methodcalls
(&self)
core/sharder/src/mock.rs:61
Functioncan_create_after_deleting_previous
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1557
Functioncan_re_register_matrix
()
influxdb3_catalog/src/catalog/versions/v3/schema/node/node_definition_tests.rs:19
Functioncan_read_slice_after_buffer_drop
()
core/linear_buffer/src/linear_buffer.rs:400
Functioncatalog_file_path_logs_dir_returns_logs_dir
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:237
Functioncatalog_file_path_restore_staging_dir_returns_staging_dir
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:245
Methodcatalog_id
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:268
Functioncatalog_initialization
()
influxdb3_cache/src/last_cache/tests.rs:1115
Functioncatalog_limits_new_returns_stored_values_regardless_of_usage
()
influxdb3_catalog/src/catalog/versions/v3/usage/tests.rs:21
Functioncatalog_limits_none_is_effectively_unbounded
()
influxdb3_catalog/src/catalog/versions/v3/usage/tests.rs:12
Functioncatalog_serialization
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:22
Functioncatalog_service_parquet_file_serde_roundtrip
()
core/data_types/src/lib.rs:3520
Functioncatalog_snapshots_only_if_updated
()
influxdb3_write/src/write_buffer/tests.rs:720
Functioncatalog_storage_service_namespace_serde_roundtrip
()
core/data_types/src/lib.rs:3546
Functioncatalog_storage_service_table_serde_roundtrip
()
core/data_types/src/lib.rs:3585
Functioncatalog_supports_more_than_255_tag_columns
()
influxdb3_catalog/src/catalog/versions/v2/tests.rs:4987
Methodcatalog_update_if_not_exists
( &self, path: CatalogFilePath, content: Bytes, )
influxdb3_catalog/src/object_store/versions/v1.rs:111
Methodcatalog_uuid
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:174
Functioncatch_up_broadcasts_events_from_other_writer
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:217
Functioncatches_up_after_remote_writer_lands_a_log
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2182
Methodcategorize
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
Functioncategorize_maps_object_store_errors
()
object_store_utils/src/object_store_health/tests.rs:53
Methodcheck_arg_count
(name: &str, args: &[IQLExpr], count: usize)
core/iox_query_influxql/src/plan/planner.rs:2665
← previousnext →5,301–5,400 of 11,906, ranked by callers