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
record_data_buffer_too_short
()
influxdb3_catalog/src/format/record/tests.rs:51
Method
record_debug
(&mut self, field: &Field, value: &dyn fmt::Debug)
core/test_helpers/src/tracing.rs:237
Method
record_debug
(&mut self, field: &Field, value: &dyn std::fmt::Debug)
core/logfmt/src/lib.rs:268
Method
record_error
(&mut self, field: &Field, value: &(dyn std::error::Error + 'static))
core/logfmt/src/lib.rs:246
Function
record_error_at_epoch_zero_is_readable
()
object_store_utils/src/object_store_health/tests.rs:184
Function
record_error_overwrites_both_fields
()
object_store_utils/src/object_store_health/tests.rs:133
Function
record_error_roundtrips_realistic_timestamp
()
object_store_utils/src/object_store_health/tests.rs:104
Method
record_f64
(&mut self, field: &Field, value: f64)
core/test_helpers/src/tracing.rs:246
Method
record_follows_from
(&self, _span: &Id, _follows: &Id)
core/test_helpers/src/tracing.rs:199
Function
record_header_buffer_too_short
()
influxdb3_catalog/src/format/record/tests.rs:36
Function
record_header_byte_layout
()
influxdb3_catalog/src/format/record/tests.rs:95
Function
record_header_round_trip
()
influxdb3_catalog/src/format/record/tests.rs:4
Method
record_i64
(&mut self, field: &Field, value: i64)
core/test_helpers/src/tracing.rs:251
Method
record_i64
(&mut self, field: &Field, value: i64)
core/logfmt/src/lib.rs:206
Function
record_id
()
influxdb3_catalog/src/format/records/feature_level/tests.rs:11
Function
record_id_and_flags
()
influxdb3_catalog/src/format/records/restore/tests.rs:7
Function
record_id_kind
()
influxdb3_catalog/src/format/record_id/tests.rs:53
Function
record_ids
()
influxdb3_catalog/src/enterprise/format/records/token/tests.rs:53
Function
record_ids
()
influxdb3_catalog/src/enterprise/format/records/retention/tests.rs:67
Function
record_ids
()
influxdb3_catalog/src/format/records/cache/tests.rs:107
Function
record_ids
()
influxdb3_catalog/src/format/records/database/tests.rs:61
Function
record_ids
()
influxdb3_catalog/src/format/records/generation/tests.rs:50
Function
record_ids
()
influxdb3_catalog/src/format/records/repository/tests.rs:77
Function
record_ids
()
influxdb3_catalog/src/format/records/trigger/tests.rs:91
Function
record_ids
()
influxdb3_catalog/src/format/records/table/tests.rs:108
Function
record_ids
()
influxdb3_catalog/src/format/records/token/tests.rs:69
Function
record_ids
()
influxdb3_catalog/src/format/records/retention/tests.rs:47
Function
record_ids
()
influxdb3_catalog/src/format/records/node/tests.rs:122
Function
record_lines
()
influxdb3_write/src/write_buffer/metrics/tests.rs:6
Function
record_lines_rejected
()
influxdb3_write/src/write_buffer/metrics/tests.rs:30
Function
record_names_are_unique
()
influxdb3_catalog/src/format/records/tests.rs:4
Method
record_ref
(&self, v: &u64)
core/iox_query/src/query_log.rs:452
Function
record_round_trip
()
influxdb3_catalog/src/format/record/tests.rs:19
Method
record_str
(&mut self, field: &Field, value: &str)
core/logfmt/src/lib.rs:236
Method
record_u64
(&mut self, field: &Field, value: u64)
core/test_helpers/src/tracing.rs:260
Method
record_u64
(&mut self, field: &Field, value: u64)
core/logfmt/src/lib.rs:216
Method
recorder
(&self)
core/metric/src/histogram.rs:131
Method
recorder
(&self)
core/metric/src/counter.rs:31
Method
records
Return recorded interactions.
core/object_store_mem_cache/src/cache_system/hook/test_utils.rs:68
Function
recovery_completes_after_partial_failure
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1759
Function
regenerate_admin_token_round_trip
()
influxdb3_catalog/src/format/records/token/tests.rs:52
Function
regex_literal
Parse regular expression literal characters. Consumes i until reaching and escaped delimiter ("\/"), newline or eof.
core/influxdb_influxql_parser/src/string.rs:136
Function
regex_match
Returns a regex_match expression arg ~= pattern
core/predicate/src/rpc_predicate/field_rewrite.rs:501
Function
regex_match_expr_invalid_regex
()
core/query_functions/src/regex.rs:306
Function
regex_not_match
Returns a regex_match expression arg !~= pattern
core/predicate/src/rpc_predicate/field_rewrite.rs:506
Function
register_bundles_advance_when_consensus_exceeds_committed
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:182
Method
register_callsite
( &self, _metadata: &'static tracing::Metadata<'static>, )
core/logfmt/src/lib.rs:89
Function
register_does_not_bundle_advance_when_already_at_committed
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:202
Method
register_node
( &self, node_id: &str, core_count: u64, mode: Vec<NodeMode>, process_
influxdb3_catalog/src/catalog/versions/v1/update.rs:146
Function
register_node_carries_row_delete_predicate_version
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:334
Function
register_node_minimal
()
influxdb3_catalog/src/format/records/node/tests.rs:89
Function
register_node_round_trip
()
influxdb3_catalog/src/format/records/node/tests.rs:66
Function
register_replaces_existing_slot_in_consensus
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:214
Function
register_then_stop_round_trip
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2376
Function
registry_is_accessible
()
influxdb3_catalog/src/format/registry/tests.rs:15
Function
rejects_record_above_committed_level
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1834
Function
remove_aggr_count_from_error
(error: DataFusionError)
core/iox_query_influxql/src/plan/planner.rs:4524
Method
remove_entry
Removes a parameter from the map by name, returning the name-value pair if the parameter name was previously in the map.
core/iox_query_params/src/params.rs:207
Function
remove_idempotent_when_removing
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:507
Method
remove_node
Mark a fully-stopped node for permanent removal from the cluster. Returns [`CatalogError::IdempotentNoOp`] when the node is already in `Removing`; HT
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1625
Function
remove_node_idempotent_when_removing
()
influxdb3_catalog/src/format/records/node/tests.rs:586
Function
remove_node_rejects_running
()
influxdb3_catalog/src/format/records/node/tests.rs:505
Function
remove_node_rejects_stopping
()
influxdb3_catalog/src/format/records/node/tests.rs:538
Function
remove_node_round_trip
()
influxdb3_catalog/src/format/records/node/tests.rs:284
Function
remove_node_transitions_stopped_to_removing
()
influxdb3_catalog/src/format/records/node/tests.rs:555
Function
remove_rejected_when_compact
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:452
Function
remove_rejected_when_running
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:424
Function
remove_rejected_when_stopping
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:439
Function
remove_request_trigger_clears_path_index
()
influxdb3_processing_engine/src/tests.rs:2062
Function
remove_rr_repartition_if_exists
Remove any RoundRobin repartition nodes that may interfere with optimization. If the current node is a RepartitionExec with Partitioning::RoundRobinB
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:196
Function
remove_succeeds_when_stopped
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:481
Method
remove_union
(plan: Arc<dyn ExecutionPlan>)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2346
Method
rename
(&self, _from: &Path, _to: &Path)
core/object_store_mem_cache/src/store.rs:381
Method
rename
(&self, from: &Path, to: &Path)
core/object_store_metrics/src/cache_metrics.rs:398
Method
rename
(&self, from: &Path, to: &Path)
influxdb3_cache/src/parquet_cache/mod.rs:849
Method
rename
(&self, from: &Path, to: &Path)
influxdb3_clap_blocks/src/object_store.rs:313
Method
rename
(&self, from: &Path, to: &Path)
influxdb3_test_helpers/src/object_store/mock.rs:511
Method
rename
(&self, from: &Path, to: &Path)
object_store_utils/src/test_object_store.rs:408
Method
rename
(&self, from: &Path, to: &Path)
object_store_utils/src/observed_object_store.rs:186
Method
rename
(&self, from: &Path, to: &Path)
object_store_limit/src/lib.rs:213
Method
rename_if_not_exists
(&self, _from: &Path, _to: &Path)
core/object_store_mem_cache/src/store.rs:389
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
core/object_store_metrics/src/cache_metrics.rs:406
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
core/object_store_mock/src/lib.rs:595
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
influxdb3_cache/src/parquet_cache/mod.rs:857
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
influxdb3_clap_blocks/src/object_store.rs:321
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:181
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
influxdb3_test_helpers/src/object_store/mock.rs:519
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
object_store_utils/src/test_object_store.rs:428
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
object_store_utils/src/observed_object_store.rs:198
Method
rename_if_not_exists
(&self, from: &Path, to: &Path)
object_store_limit/src/lib.rs:223
Method
repeated
(self, field: impl Into<String>)
core/generated_types/src/google.rs:685
Function
repeated_tag_name_value_is_invalid
()
core/data_types/src/partition_template.rs:1737
Method
replace_col
Returns a new [`Expr`] with the reference to the `_value` column replaced with the specified column name
core/predicate/src/lib.rs:341
Method
repo
(&self)
influxdb3_catalog/src/catalog.rs:219
Method
repo
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/tokens.rs:22
Method
repo
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:124
Method
repo_mut
(&mut self)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:128
Method
report
(&self, reporter: &mut dyn Reporter)
core/metric/src/metric.rs:95
Method
report
(&self, reporter: &mut dyn Reporter)
influxdb3/src/commands/serve/jemalloc.rs:40
Method
report_observation
(&mut self, attributes: &Attributes, observation: Observation)
core/metric_exporters/src/lib.rs:74
← previous
next →
8,701–8,800 of 11,906, ranked by callers