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
Method
event
(&self)
influxdb3_catalog/src/format/records/table.rs:69
Method
event
(&self)
influxdb3_catalog/src/format/records/node.rs:111
Method
event
(&self)
influxdb3_catalog/src/format/records/database.rs:81
Method
event
(&self)
influxdb3_catalog/src/format/records/retention.rs:37
Method
event
(&self)
influxdb3_catalog/src/format/records/restore.rs:56
Method
event
(&self)
influxdb3_catalog/src/format/records/token.rs:83
Function
event_carries_restore_id
()
influxdb3_catalog/src/format/records/restore/tests.rs:13
Function
event_fields_errors
()
core/logfmt/tests/logging.rs:144
Function
event_fields_numeric
()
core/logfmt/tests/logging.rs:118
Function
event_fields_repeated
()
core/logfmt/tests/logging.rs:131
Function
event_fields_strings
()
core/logfmt/tests/logging.rs:67
Function
event_fields_strings_quoting
()
core/logfmt/tests/logging.rs:84
Function
event_fields_structs
()
core/logfmt/tests/logging.rs:161
Method
event_msg
Record an event on the inner `Span` with the specified `msg`.
core/trace/src/span.rs:309
Function
event_multi_span
()
core/logfmt/tests/logging.rs:195
Function
event_spans
()
core/logfmt/tests/logging.rs:177
Function
every_category_roundtrips_through_packing
()
object_store_utils/src/object_store_health/tests.rs:160
Method
evict
A key removed.
core/object_store_mem_cache/src/cache_system/hook/mod.rs:39
Method
evict_unused
Evict all entries not accessed with [`CatalogCache::get`] or updated since the last call to this function Periodically calling this provides a Not-Re
core/catalog_cache/src/local/mod.rs:148
Function
exact_boundary_takes_single_part_branch
()
object_store_utils/src/adaptive_put.rs:172
Function
example_spec_lp
()
influxdb3_load_generator/src/line_protocol_generator/tests.rs:7
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
core/iox_query_influxql/src/frontend/planner.rs:153
Method
execute
( &self, _partition: usize, _context: Arc<datafusion::execution::TaskConte
core/iox_query/src/query_log.rs:7676
Method
execute
( &self, _partition: usize, _context: Arc<datafusion::execution::TaskConte
core/iox_query/src/exec.rs:630
Method
execute
( &self, _partition: usize, _context: Arc<datafusion::execution::context::
core/iox_query/src/physical_optimizer/projection_pushdown.rs:1989
Method
execute
( &self, _partition: usize, _context: Arc<TaskContext>, )
core/iox_query/src/exec/query_tracing.rs:687
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
core/iox_query/src/exec/gapfill/mod.rs:596
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
core/iox_query/src/provider/deduplicate.rs:268
Method
execute
( &self, partition: usize, _context: Arc<TaskContext>, )
core/iox_query/src/provider/record_batch_exec.rs:179
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
core/iox_query/src/provider/reorder_partitions.rs:156
Method
execute
( &self, _partition: usize, context: Arc<TaskContext>, )
core/iox_system_tables/src/system_tables.rs:176
Method
execute
( &self, partition: usize, context: Arc<TaskContext>, )
influxdb3_query_executor/src/query_planner.rs:151
Method
execute
( &self, partition: usize, context: Arc<datafusion::execution::TaskContext>, )
influxdb3_cache/src/distinct_cache/table_function.rs:406
Method
execute
( &self, partition: usize, context: Arc<datafusion::execution::TaskContext>, )
influxdb3_cache/src/last_cache/table_function.rs:460
Method
execute_with_config
( session_ctx: &Arc<SessionContext>, plan: Arc<GapFillExec>, )
core/iox_query/src/exec/gapfill/exec_tests.rs:1559
Method
execution_props
(&self)
core/iox_query_influxql/src/frontend/planner.rs:72
Method
executor
Returns the underlying [`DedicatedExecutor`].
core/iox_query/src/exec.rs:354
Function
executor_clone_join
()
core/executor/src/lib.rs:627
Function
executor_join
()
core/executor/src/lib.rs:612
Function
executor_join2
()
core/executor/src/lib.rs:619
Function
executor_shutdown_while_task_running
()
core/executor/src/lib.rs:550
Function
executor_submit_task_after_clone_shutdown
()
core/executor/src/lib.rs:592
Function
executor_submit_task_after_shutdown
()
core/executor/src/lib.rs:574
Function
existing_bad_time_format_deserializes_without_error
()
core/data_types/src/partition_template.rs:2644
Function
existing_custom_table_template_does_not_require_time_specified
()
core/data_types/src/partition_template.rs:2628
Function
existing_time_format_validation_fn_allows_good_formats
()
core/data_types/src/partition_template.rs:2539
Function
existing_time_format_validation_fn_allows_questionable_serialized_formats
()
core/data_types/src/partition_template.rs:2533
Function
expansion_disabled
()
influxdb3/src/lib_tests.rs:134
Method
expect_bucket
(&self)
core/partition/src/lib.rs:1533
Method
expect_string
(&self)
core/partition/src/lib.rs:1517
Method
expect_ts_range
(&self)
core/partition/src/lib.rs:1525
Method
expecting
(&self, formatter: &mut std::fmt::Formatter<'_>)
influxdb3_id/src/serialize.rs:201
Function
explain
()
core/iox_query_influxql_rewrite/src/lib.rs:487
Function
explicitly_set_object_store_to_memory
()
influxdb3_clap_blocks/src/object_store/tests.rs:38
Function
exponential_value
(i: &str)
core/influxdb_line_protocol/src/lib.rs:851
Method
export
(&self, span: Span)
core/trace/src/lib.rs:38
Function
expr_col
(name: &str, schema: &SchemaRef)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:804
Function
expr_col
(name: &str, schema: &SchemaRef)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2544
Function
expr_dict_const
(val: String)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:808
Function
expr_error
Map an [`ExprError`] to a DataFusion error.
core/iox_query_influxql/src/error.rs:61
Method
expr_planners
(&self)
core/query_functions/src/registry.rs:147
Method
expr_sql_string
Format expr to SQL string.
core/data_types/src/lib.rs:1518
Method
expressions
(&self, expr_args: ExpressionArgs<'_>)
core/query_functions/src/non_negative.rs:76
Method
expressions
(&self)
core/iox_query/src/exec/split.rs:132
Method
expressions
(&self)
core/iox_query/src/exec/gapfill/mod.rs:214
Method
extend_from
Extends this [`BitSet`] by the context of `other`
core/arrow_util/src/bitset.rs:86
Function
extend_projection_for_filters
Ensures all columns referred to in `filters` are in the `projection`, if any, adding them if necessary.
core/datafusion_util/src/lib.rs:128
Method
external
Generate metadata for a file generated from some process other than IOx ingesting. This metadata will not have valid catalog values; inserting files
core/parquet_file/src/metadata.rs:425
Function
extract_attributes
(job: &i32)
core/tracker/src/task/metrics.rs:280
Method
extract_query_request
( &self, req: Request, )
influxdb3_server/src/http.rs:1368
Function
extract_query_request_db_in_form_body
()
core/iox_v1_query_api/src/handler.rs:1070
Function
extract_query_request_db_in_multipart_body
()
core/iox_v1_query_api/src/handler.rs:1085
Function
extract_query_request_db_in_url
()
core/iox_v1_query_api/src/handler.rs:1056
Function
extract_query_request_debug_redacts_token_and_query
()
core/iox_v1_query_api/src/handler.rs:1113
Function
extract_query_request_empty_db_collapses_to_none
()
core/iox_v1_query_api/src/handler.rs:1144
Function
extract_sqlite_argument_i32
(argument_value: &sqlx::sqlite::SqliteArgumentValue<'_>)
core/data_types/src/service_limits.rs:272
Function
extract_sqlite_argument_text
( argument_value: &sqlx::sqlite::SqliteArgumentValue<'_>, )
core/data_types/src/partition_template.rs:2693
Function
f64_interval
(lower: Option<f64>, upper: Option<f64>)
core/iox_query/src/util.rs:222
Method
f64_lit
Ensure that any literal parameter is a Float64, otherwise type coercion might choose to coerce to a Float32 instead.
core/iox_query_influxql/src/plan/planner.rs:3201
Function
f64s
(vals: &[Option<f64>])
core/influxdb_iox_client/src/format/influxql.rs:220
Method
f_down
(&mut self, node: Self::Node)
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:117
Method
f_down
(&mut self, expr: Expr)
core/iox_query/src/analyzer/handle_gapfill.rs:441
Method
f_down
(&mut self, node: &'n Self::Node)
core/iox_query/src/analyzer/handle_gapfill/virtual_function.rs:68
Method
f_down
(&mut self, plan: &LogicalPlan)
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:42
Method
f_down
(&mut self, expr: &Expr)
core/predicate/src/rpc_predicate/field_rewrite.rs:235
Method
f_up
(&mut self, expr: Expr)
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:615
Method
f_up
(&mut self, node: Self::Node)
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:126
Method
f_up
(&mut self, expr: Expr)
core/iox_query/src/analyzer/extract_sleep.rs:69
Method
f_up
(&mut self, expr: Expr)
core/iox_query/src/analyzer/handle_gapfill.rs:450
Method
f_up
(&mut self, expr: Expr)
core/iox_query/src/logical_optimizer/influx_regex_to_datafusion_regex.rs:70
Method
f_up
(&mut self, expr: Expr)
core/predicate/src/rpc_predicate/value_rewrite.rs:25
Function
factor
Parse precedence priority 1 operators. These are the highest precedence operators, and include parenthesis and the unary operators.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:571
Method
fail
(current: usize, expected: usize)
core/object_store_mem_cache/src/cache_system/hook/notify/test_utils.rs:49
Function
fail_cluster_id
(_: &str)
influxdb3/src/commands/serve.rs:658
Function
fail_next_with_retries
()
object_store_utils/src/retryable_object_store/tests.rs:657
Function
fails_when_auto_cache_already_exists
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1523
Function
fails_when_auto_cache_not_found
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1745
Function
fails_when_database_not_found
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1481
Function
fails_when_table_not_found
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1502
Function
fails_with_empty_tag_ids
()
influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:1433
← previous
next →
6,101–6,200 of 11,906, ranked by callers