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
role_user_action_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:254
Function
rollup_stats_test
()
influxdb3_telemetry/src/stats/tests.rs:61
Method
root
Create new root span.
core/trace/src/span.rs:87
Function
round_trip
()
influxdb3_catalog/src/format/records/restore/tests.rs:34
Function
round_trip
()
influxdb3_catalog/src/format/records/feature_level/tests.rs:17
Function
round_trip_flightsql
()
core/service_grpc_flight/src/request.rs:1030
Function
round_trip_influxql
()
core/service_grpc_flight/src/request.rs:1014
Function
round_trip_sql
()
core/service_grpc_flight/src/request.rs:982
Function
round_trip_sql_is_debug
()
core/service_grpc_flight/src/request.rs:998
Function
route_admin_token_recovery_request
( recovery_api: Arc<RecoveryHttpApi>, req: hyper::Request<hyper::body::Incoming>, )
influxdb3_server/src/http.rs:2908
Method
row_count
(&self)
influxdb3_wal/src/lib.rs:373
Method
row_counts
(&self, _column: &Column)
core/iox_query/src/pruning.rs:224
Method
rows
The total number of rows in all row groups in this chunk.
core/parquet_file/src/chunk.rs:75
Function
run
(args: Args)
influxdb3_commands/src/debug/catalog/snapshot.rs:40
Function
run
(args: Args)
influxdb3_commands/src/debug/catalog/sequence.rs:42
Method
run
Query the given database with the SQL query constructed by this builder, returning a struct that can stream Arrow [`arrow::record_batch::RecordBatch`]
core/influxdb_iox_client/src/client/flight/query.rs:130
Method
run
(self)
core/iox_query/src/exec/gapfill/exec_tests.rs:1494
Method
run_asynchronous
(mut self, async_run: bool)
influxdb3/tests/cli/api.rs:692
Method
run_at_time
( plugin: TriggerPlugin, trigger_time: DateTime<Utc>, db_schema: Arc<DatabaseSchema>,
influxdb3_processing_engine/src/plugins.rs:908
Method
run_do_get
( server: Arc<dyn QueryDatabase>, span_ctx: Option<SpanContext>, external_span_ctx: Op
core/service_grpc_flight/src/lib.rs:698
Method
run_inner
(exec: DedicatedExecutor, fut: Fut)
core/iox_query/src/exec/context.rs:695
Method
run_optimise
Reduce the memory usage of this set (trading off immediate CPU time) by efficiently re-encoding the set (using run-length encoding).
core/data_types/src/sequence_number_set.rs:41
Method
running
(&self)
core/tracker/src/task/registry.rs:115
Method
running
(&self)
core/tracker/src/task/history.rs:58
Function
running_node_emits_register_only
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:300
Method
runtime
Returns the runtime associated with this `Executor`
core/iox_query/src/exec.rs:344
Function
s3_config_missing_params
()
influxdb3_clap_blocks/src/object_store/tests.rs:154
Function
s3_fifo_entry_overhead_size
Returns the overhead size of the [`S3FifoEntry`] placed into the S3 Fifo cache manager. This is useful for testing, since it's the size used for evic
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:156
Function
s3_url_signer_config_missing_params
()
influxdb3_clap_blocks/src/object_store/tests.rs:196
Function
same_input_and_output
()
core/iox_query/src/provider/adapter.rs:289
Function
sample_event
()
influxdb3_catalog/src/catalog/versions/v3/events/tests.rs:9
Method
scalar
Scalar value.
core/data_types/src/lib.rs:1583
Function
scalar_value_passthrough
()
core/query_functions/src/date_bin_wallclock.rs:533
Function
scalar_value_with_timezone
()
core/query_functions/src/date_bin_wallclock.rs:562
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/databases.rs:47
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/queries.rs:33
Method
scan
Scans the influxdb_schema system table to return schema information. This method iterates through all tables in the current database, extracting colu
influxdb3_system_tables/src/influxdb_schema.rs:116
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/distinct_caches.rs:51
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/plugins.rs:42
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/tokens.rs:34
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/generations.rs:31
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/python_call.rs:52
Method
scan
( &self, filters: Option<Vec<Expr>>, limit: Option<usize>, )
influxdb3_system_tables/src/parquet_files.rs:48
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/tables.rs:50
Method
scan
( &self, _filters: Option<Vec<Expr>>, _limit: Option<usize>, )
influxdb3_system_tables/src/last_caches.rs:61
Method
scan
( &self, ctx: &dyn Session, projection: Option<&Vec<usize>>, filters: &[Expr],
core/iox_query/src/test.rs:382
Method
scan
( &self, ctx: &dyn Session, projection: Option<&Vec<usize>>, filters: &[Expr],
influxdb3_query_executor/src/lib.rs:791
Method
scan
( &self, ctx: &dyn Session, projection: Option<&Vec<usize>>, filters: &[Expr],
influxdb3_cache/src/distinct_cache/table_function.rs:67
Method
scan
( &self, ctx: &dyn Session, projection: Option<&Vec<usize>>, filters: &[Expr],
influxdb3_cache/src/last_cache/table_function.rs:71
Function
scan_filter_not_part_of_projection
()
core/iox_query/src/analyzer/handle_gapfill.rs:1220
Method
schema
(&self)
influxdb3_system_tables/src/nodes.rs:31
Method
schema
(&self)
influxdb3_system_tables/src/plugins.rs:38
Method
schema
(&self)
influxdb3_system_tables/src/tokens.rs:30
Method
schema
(&self)
influxdb3_system_tables/src/generations.rs:27
Method
schema
(&self)
influxdb3_system_tables/src/python_call.rs:48
Method
schema
(&self)
core/iox_query/src/ingester.rs:136
Method
schema
(&self)
core/iox_query/src/query_log.rs:7657
Method
schema
(&self, name: &str)
influxdb3_query_executor/src/lib.rs:679
Method
schema
()
influxdb3_sys_events/benches/store_benchmark.rs:77
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/predicate_pushdown.rs:148
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/cached_parquet_data.rs:104
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/projection_pushdown.rs:50
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/dedup/split.rs:105
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/dedup/dedup_null_columns.rs:95
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/dedup/dedup_sort_order.rs:161
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/union/nested_union.rs:74
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:61
Method
schema_check
(&self)
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:86
Method
schema_names
(&self)
influxdb3_query_executor/src/lib.rs:674
Method
scope
Re-scopes this error as the child of another field
core/ingester_query_grpc/src/lib.rs:55
Function
scrape
Make a HTTP GET request to the Prometheus metric endpoint at `url` and parse the result into a [`MetricSet`]. The provided URL should include any pat
core/test_helpers/src/prometheus.rs:227
Function
select_failure_modes
()
core/iox_query_influxql_rewrite/src/lib.rs:463
Method
select_given_and_pk_columns
Return names of the columns of given indexes with all PK columns (tags and time) If the columns are not provided, return all columns
core/schema/src/lib.rs:839
Method
select_window
Generate a plan for any window functions, such as `moving_average` or `difference`.
core/iox_query_influxql/src/plan/planner.rs:1844
Method
send_compressed
Send compression. Only ONE compression can be send. Ask your server operator which encodings are supported.
core/influxdb_iox_client/src/client/flight/mod.rs:253
Method
send_disable_trigger
This sends the disable trigger command to the processing engine manager, it is done in a separate task so that the caller can send back shutdown.
influxdb3_processing_engine/src/plugins.rs:375
Function
send_request_routes_by_path
()
influxdb3_processing_engine/src/tests.rs:2085
Method
send_update
( &self, update: Arc<CatalogUpdate>, )
influxdb3_catalog/src/channel/versions/v2.rs:185
Method
separated_list1
Parse a list of one or more `T`, separated by commas. Returns an error using `msg` if `separated_list1` fails to parse any elements.
core/influxdb_influxql_parser/src/common.rs:487
Function
sequence_defaults_to_latest_and_decodes
()
influxdb3_commands/src/debug/catalog/tests.rs:150
Method
sequence_from_path
Parse the sequence number out of a `logs/NN...N.catalog` path.
influxdb3_commands/src/debug/catalog/mod.rs:143
Function
sequence_headers_only_json_has_histogram
()
influxdb3_commands/src/debug/catalog/tests.rs:168
Function
sequence_headers_only_pretty_renders_histogram
()
influxdb3_commands/src/debug/catalog/tests.rs:189
Function
sequence_missing_log_errors
()
influxdb3_commands/src/debug/catalog/tests.rs:209
Method
sequence_number
(&self)
influxdb3_catalog/src/log/versions/v2.rs:131
Method
sequence_number
(&self)
influxdb3_catalog/src/log/versions/v3.rs:215
Method
sequence_number
(&self)
influxdb3_catalog/src/log/versions/v4.rs:350
Method
sequence_number
(&self)
influxdb3_catalog/src/snapshot/versions/v4.rs:46
Function
sequence_number_vec
Yield vec's of [`SequenceNumber`] derived from u64 values. This matches how the ingester allocates [`SequenceNumber`] - from a u64 source.
core/data_types/src/sequence_number_set.rs:253
Method
sequenced
Create a new [`DmlMeta`] for a sequenced operation
core/dml/src/lib.rs:21
Function
serde_vec_map_with_json
()
influxdb3_id/src/serialize/tests.rs:6
Function
serde_vec_set_with_json
()
influxdb3_id/src/serialize/tests.rs:44
Method
serialize
(&self, serializer: S)
influxdb3_server/src/http.rs:547
Method
serialize
(&self, serializer: S)
influxdb3_id/src/serialize.rs:148
Method
serialize
(&self, serializer: S)
core/iox_v1_query_api/src/response.rs:212
Method
serialize
(&self, serializer: S)
influxdb3_types/src/write.rs:171
Method
serialize
(&self, serializer: S)
influxdb3_types/src/http.rs:29
Method
serialize
(&self, serializer: S)
influxdb3_catalog/src/log/versions/v2.rs:531
Method
serialize
(&self, serializer: S)
influxdb3_catalog/src/log/versions/v1.rs:313
Method
serialize
(&self, serializer: S)
influxdb3_catalog/src/log/versions/v3.rs:646
← previous
next →
8,901–9,000 of 11,906, ranked by callers