MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
↓ 3 callersMethodpoll
(self: std::pin::Pin<&mut Self>, cx: &mut Context<'_>)
core/iox_time/src/lib.rs:305
↓ 3 callersFunctionpredicate_mixed
(schema: &SchemaRef)
core/iox_query/src/physical_optimizer/predicate_pushdown.rs:515
↓ 3 callersMethodprefix
(host_prefix: &str, db_id: u32, table_id: u32)
influxdb3_write/src/paths.rs:132
↓ 3 callersMethodprefix
Resolve the catalog object-store prefix: --catalog-prefix, then --cluster-id, then --node-id.
influxdb3_commands/src/debug/catalog/mod.rs:85
↓ 3 callersFunctionprev_fill_strategy
(idx: usize)
core/iox_query/src/exec/gapfill/algo.rs:1639
↓ 3 callersMethodproject_with_exprs
adds a ProjectionExec node to the plan with the specified exprs
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2434
↓ 3 callersMethodproperties
(&self)
core/iox_query/src/exec/sleep.rs:220
↓ 3 callersMethodproperties
(&self)
core/iox_query/src/exec/gapfill/mod.rs:548
↓ 3 callersMethodprune_closed
(&mut self)
influxdb3_catalog/src/catalog/versions/v3/events.rs:450
↓ 3 callersMethodpurge_db
Remove all traces of the specified database from the cache and object store for the current node.
influxdb3_write/src/table_index_cache.rs:748
↓ 3 callersMethodpush_str
(&mut self, value: &str)
core/table_batch/src/builder/column_writer/dictionary.rs:27
↓ 3 callersMethodput
(&self, location: &Path, payload: PutPayload)
core/object_store_mock/src/lib.rs:478
↓ 3 callersMethodput
(&self, location: &Path, payload: PutPayload)
object_store_limit/src/lib.rs:92
↓ 3 callersFunctionput_adaptive_impl
The underlying implementation, taking an explicit `chunk_size` for test coverage at small sizes. Production callers should use [`AdaptivePutExt::put_a
object_store_utils/src/adaptive_put.rs:56
↓ 3 callersMethodput_opts_with_retries
( &self, path: &Path, payload: PutPayload, options: PutOptions, contex
object_store_utils/src/retryable_object_store.rs:249
↓ 3 callersMethodput_with_retries
( &self, path: &Path, payload: PutPayload, context_message: String, re
object_store_utils/src/retryable_object_store.rs:275
↓ 3 callersMethodquery_analyze
Analyze Query
core/influxdb2_client/src/api/query.rs:91
↓ 3 callersMethodquery_ast
Get Query AST Repsonse
core/influxdb2_client/src/api/query.rs:118
↓ 3 callersMethodquery_duration_recorder
( &self, db: impl Into<Cow<'static, str>>, )
influxdb3_cache/src/last_cache/metrics.rs:35
↓ 3 callersFunctionrandom_bool
(rng: &mut StdRng)
core/mutable_batch/tests/writer_fuzz.rs:45
↓ 3 callersMethodread
(registry: &Registry)
core/iox_query/src/exec.rs:697
↓ 3 callersMethodread_bytes
Number of read bytes since last snapshot.
core/tracker/src/disk_metric.rs:58
↓ 3 callersFunctionread_stored_snapshot
( store: &Arc<dyn object_store::ObjectStore>, prefix: &str, )
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1469
↓ 3 callersMethodread_to_batches
Read data into [`RecordBatch`]es. This is mostly meant for testing!
core/iox_query/src/lib.rs:211
↓ 3 callersFunctionready_ok
()
core/tracker/src/task.rs:558
↓ 3 callersMethodrecord_bytes
(&self, db: D, bytes: u64)
influxdb3_write/src/write_buffer/metrics.rs:49
↓ 3 callersMethodrecord_file_additions
(&self, size_bytes: u64, n_files: u64)
influxdb3_cache/src/parquet_cache/metrics.rs:70
↓ 3 callersMethodrecord_lines
(&self, db: D, lines: u64)
influxdb3_write/src/write_buffer/metrics.rs:37
↓ 3 callersMethodrecord_lines_rejected
(&self, db: D, lines: u64)
influxdb3_write/src/write_buffer/metrics.rs:42
↓ 3 callersMethodrecord_string
(&mut self, key: &str, value: String)
core/test_helpers/src/tracing.rs:231
↓ 3 callersMethodrecord_trigger_invocation
(&self)
influxdb3_processing_engine/src/plugins.rs:252
↓ 3 callersFunctionrecord_views
Full decoded record views for every record in the file.
influxdb3_catalog/src/format/view.rs:126
↓ 3 callersFunctionreduce_expr
(ctx: &ReduceContext, expr: &Expr)
core/influxdb_influxql_parser/src/time_range.rs:483
↓ 3 callersMethodrefresh_tokens
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:132
↓ 3 callersMethodremove
Remove the specified [`SequenceNumber`] to the set, if present. This is a no-op if `n` was not part of `self`.
core/data_types/src/sequence_number_set.rs:23
↓ 3 callersFunctionrender_snapshot
( store: CatalogStore, format: CatalogFormat, opts: Render, )
influxdb3_commands/src/debug/catalog/snapshot.rs:55
↓ 3 callersFunctionrepartition_exec
( input: &Arc<dyn ExecutionPlan>, partitioning: Partitioning, )
core/iox_query/src/test.rs:1519
↓ 3 callersMethodreplay
Loads the WAL files in order from object store, calling the file notifier on each one and populating the snapshot tracker with the WAL periods.
influxdb3_wal/src/object_store.rs:148
↓ 3 callersMethodreport
Record the current state of every metric in this registry to the provided `Reporter` Will iterate through all registered metrics in alphabetical orde
core/metric/src/lib.rs:249
↓ 3 callersMethodreport
(&self, reporter: &mut dyn Reporter)
core/tokio_metrics_bridge/src/bridge.rs:99
↓ 3 callersMethodreport
View this `Metrics` paired with an elapsed duration for `Display` rendering: counts + throughput.
influxdb3_commands/src/write.rs:184
↓ 3 callersMethodrequests
(&self)
core/influxdb_iox_client/src/client/batched_write.rs:287
↓ 3 callersFunctionrequired_header
Decodes and parses a given required header from the provided HeaderMap - Returns Err if the header fails to decode to a string, fails to parse, or do
core/trace_http/src/ctx.rs:267
↓ 3 callersMethodreset
(&self)
core/metric/src/duration.rs:130
↓ 3 callersMethodreset_metrics_1h
(&self)
influxdb3_telemetry/src/store.rs:180
↓ 3 callersMethodresolve_dbrp
(&self)
core/iox_query_influxql_rewrite/src/lib.rs:61
↓ 3 callersMethodresolve_node_spec
Resolve name-based [`ApiNodeSpec`] to the id-based [`NodeSpec`].
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2514
↓ 3 callersMethodresource_iter
(&self)
influxdb3_catalog/src/catalog/versions/v2/update.rs:2137
↓ 3 callersMethodretention_period
(mut self, retention_period: Duration)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:267
↓ 3 callersMethodrewrite_field_exprs
Rewrites the predicate. See the description on [`FieldProjectionRewriter`] for more details.
core/predicate/src/rpc_predicate/field_rewrite.rs:61
↓ 3 callersFunctionrewrite_select
Transform a `SelectStatement` to a `Select`, which is an intermediate representation used by the InfluxQL planner. Transformations include expanding w
core/iox_query_influxql/src/plan/rewriter.rs:66
↓ 3 callersMethodrollup_events_1m
(&self)
influxdb3_telemetry/src/store.rs:175
↓ 3 callersFunctionround_trip
That `window_duration` survives encoding and decoding
core/query_functions/src/window.rs:292
↓ 3 callersFunctionrun
Starts the delete manager, which processes hard deletion tasks for database objects.
influxdb3_write/src/deleter.rs:38
↓ 3 callersFunctionrun
(c: &mut Criterion, initial: &str, new: &[&str], id: &str)
core/mutable_batch_pb/benches/write_table_batch.rs:26
↓ 3 callersFunctionrun
(args: Args)
influxdb3_commands/src/debug/catalog/list.rs:33
↓ 3 callersMethodrun
Run the test cases, and populate the results in [`TestCase::result_per_partition`].
core/iox_query/src/statistics/partition_statistics/mod.rs:618
↓ 3 callersFunctionrun_delta_time_test
(delta_test_cases: Vec<DeltaTimeCase>)
core/iox_query_influxql/src/lib.rs:59
↓ 3 callersMethodrun_trigger
( self: Arc<Self>, db_id: DbId, trigger_id: TriggerId, )
influxdb3_processing_engine/src/lib.rs:621
↓ 3 callersFunctionrun_upload_and_count_max_active_tasks
Test: perform and assert `upload()` or `parallel_upload()` while counting active tasks.
core/parquet_file/src/storage.rs:580
↓ 3 callersFunctionrun_with_inputs
( schema: SchemaRef, aggs: Vec<Expr>, inputs: Vec<RecordBatch>, )
core/query_functions/src/selectors.rs:1557
↓ 3 callersFunctionrunning_node
(id: u32, name: &str, registered_time_ns: i64)
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:79
↓ 3 callersFunctionsample
()
influxdb3_catalog/src/format/records/restore/tests.rs:49
↓ 3 callersFunctionsample_all_metrics
(sampler: &mut CpuAndMemorySampler, store: &Arc<TelemetryStore>)
influxdb3_telemetry/src/sampler.rs:101
↓ 3 callersMethodsanitized_text
Returns a sanitized textual form of the query suitable for downstream capture / logging consumers that must not see raw catalog / schema / table names
core/service_grpc_flight/src/request.rs:167
↓ 3 callersFunctionschema
()
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:261
↓ 3 callersFunctionschema
()
core/iox_query/src/exec/gapfill/params.rs:428
↓ 3 callersMethodschema
Return the schema of the generated batches
core/parquet_file/src/writer.rs:272
↓ 3 callersMethodschema
(&self)
influxdb3_query_executor/src/query_planner.rs:132
↓ 3 callersFunctionselect
()
core/iox_query_influxql_rewrite/src/lib.rs:410
↓ 3 callersMethodselect_aggregate
( &self, ctx: &Context<'_>, mut input: LogicalPlan, fields: &[Field],
core/iox_query_influxql/src/plan/planner.rs:1459
↓ 3 callersMethodsend_get_bytes
Send an HTTP request with the specified parameters, return the bytes read from the response body.
influxdb3_client/src/lib.rs:1043
↓ 3 callersMethodsend_shutdown
Send a shutdown to the running trigger's task. Returns `Err(())` if the receiving task is already gone.
influxdb3_processing_engine/src/lib.rs:165
↓ 3 callersMethodsequence_number
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:260
↓ 3 callersMethodset
(&self, value: Duration)
core/metric/src/duration.rs:61
↓ 3 callersMethodset
(&self, variant: QueryVariant)
core/trace_http/src/query_variant.rs:26
↓ 3 callersFunctionset_field_metadata
Sets the metadata for a field - replacing any existing metadata
core/schema/src/lib.rs:1021
↓ 3 callersMethodset_influxql_filled
(&mut self, filled: bool)
core/iox_query_influxql/src/plan/planner/metadata.rs:47
↓ 3 callersMethodset_retention_period_for_database
( &self, db_name: &str, duration: Duration, )
influxdb3_catalog/src/catalog/versions/v2/update.rs:1236
↓ 3 callersFunctionset_signal_handler
(signal: libc::c_int, handler: unsafe extern "C" fn(libc::c_int))
influxdb3/src/lib.rs:725
↓ 3 callersMethodset_storage_mode
(&self, storage_mode: StorageMode)
influxdb3_catalog/src/catalog/versions/v2/update.rs:209
↓ 3 callersFunctionsetup_database
(catalog: &mut InnerCatalog, db_id: u32, name: &str)
influxdb3_catalog/src/format/records/repository/tests.rs:18
↓ 3 callersFunctionsetup_database
Helper: create a database.
influxdb3_catalog/src/format/records/table/tests.rs:21
↓ 3 callersMethodsetup_dir
Setup the results directory for the load generation run. This will be used to store all results files generated.
influxdb3_load_generator/src/commands/common.rs:177
↓ 3 callersFunctionsetup_line_builder
Sets up the LineBuilder class in Python's environment for access by all plugins. Executes the LineBuilder code in `__main__` and adds it to builtins
influxdb3_py_api/src/line_builder/mod.rs:11
↓ 3 callersFunctionsetup_python_venv
(venv_path: &Path)
influxdb3/tests/server/packages.rs:87
↓ 3 callersMethodsetup_query
Setup the `query` results file along with its path and the [`QuerierSpec`]
influxdb3_load_generator/src/commands/common.rs:205
↓ 3 callersMethodsetup_write
Setup the `write` results file along with its path and the [`DataSpec`]
influxdb3_load_generator/src/commands/common.rs:191
↓ 3 callersMethodshard
( &self, table: &str, namespace: &NamespaceName<'_>, payload: &MutableBatch,
core/sharder/src/mock.rs:72
↓ 3 callersMethodshow_deleted
(mut self, show: bool)
influxdb3/tests/cli/api.rs:239
↓ 3 callersMethodshrink
(&self, amount: usize)
core/iox_query/src/memory_pool.rs:29
↓ 3 callersMethodshutdown
signals shutdown of this executor and any Clones
core/executor/src/lib.rs:340
↓ 3 callersMethodshutdown
(&self)
influxdb3_wal/src/object_store.rs:661
↓ 3 callersMethodshutdown_all_for_db
(&self, db_id: DbId)
influxdb3_processing_engine/src/lib.rs:213
↓ 3 callersMethodsize
(&self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/fifo.rs:112
↓ 3 callersMethodsize
Return the approximate memory size of the metadata, in bytes. This includes `Self`.
core/dml/src/lib.rs:49
↓ 3 callersMethodsnapshot_path
(&self)
influxdb3_commands/src/debug/catalog/mod.rs:130
↓ 3 callersFunctionsoft_delete_db_now
(catalog: &Catalog, db: &str)
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:94
↓ 3 callersMethodsoft_delete_table
Soft-delete a table. The table is renamed in place and scheduled for hard deletion at the resolved time.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1844
↓ 3 callersFunctionsoft_delete_table_now
(catalog: &Catalog, db: &str, table: &str)
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:82
← previousnext →2,101–2,200 of 11,906, ranked by callers