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
↓ 8 callersFunctionwal_contents
Create a new [`WalContents`] with the provided arguments that will have a `persisted_timestamp_ns` of `0`.
influxdb3_wal/src/create.rs:6
↓ 8 callersMethodwith_database
(mut self, db: Option<Identifier>)
core/iox_query_influxql_rewrite/src/lib.rs:31
↓ 8 callersMethodwrite
(self, args: fmt::Arguments<'_>)
core/influxdb_line_protocol/src/builder.rs:225
↓ 8 callersFunctionwrite_batch_op
(write_batch: WriteBatch)
influxdb3_wal/src/create.rs:37
↓ 8 callersMethodwrite_lp
Write line protocol data to the specified database.
core/influxdb_iox_client/src/client/batched_write.rs:35
↓ 8 callersMethodwrite_lp
( &self, database: DatabaseName, lp: &str, ingest_time: Time, no_sync:
influxdb3_processing_engine/src/write.rs:22
↓ 8 callersMethodwrite_ops_unconfirmed
Buffer into a single larger operation in memory. Returns before the operation is persisted.
influxdb3_wal/src/object_store.rs:281
↓ 8 callersFunctionwrite_snapshot_to_live_path
Serialize the catalog's current in-memory state as a snapshot file and write it to the live snapshot (checkpoint) path. Mirrors the v2 test helper tha
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3819
↓ 8 callersFunctionws0
Optionally consume all whitespace, single-line or inline comments
core/influxdb_influxql_parser/src/common.rs:188
↓ 7 callersMethodabort
(&mut self)
core/object_store_mock/src/lib.rs:656
↓ 7 callersMethodaccept_partial
Set the `accept_partial` parameter
influxdb3_client/src/lib.rs:1218
↓ 7 callersMethodactions
(&self)
influxdb3_authz/src/permissions.rs:246
↓ 7 callersFunctionactive_database
Look up an active (not deleted, not internal) database by name.
influxdb3_catalog/src/catalog/versions/v3/ops/mod.rs:52
↓ 7 callersFunctionactive_table
Look up an active (not deleted, not internal) database and active table by name.
influxdb3_catalog/src/catalog/versions/v3/ops/mod.rs:73
↓ 7 callersMethodadd_parquet_file
( &mut self, database_id: DbId, table_id: TableId, parquet_file: ParquetFile,
influxdb3_write/src/lib.rs:222
↓ 7 callersMethodadmin_token_recovery_client_addr
Get the URL of admin token recovery service for use with an HTTP client
influxdb3/tests/server/mod.rs:695
↓ 7 callersFunctionand
Boolean AND on ColumnarValues. Handles all combinations of Array/Scalar ColumnarValue.
core/iox_query/src/exec/split.rs:549
↓ 7 callersMethodapply
(&self, catalog: &mut InnerCatalog)
influxdb3_catalog/src/enterprise/format/records/token.rs:53
↓ 7 callersMethodapply_elements
( &'a self, mut f: F, )
core/iox_query/src/exec/series_limit/logical.rs:185
↓ 7 callersMethodas_arrow
(&self)
influxdb3_write/src/write_buffer/table_buffer.rs:575
↓ 7 callersFunctionas_mb
(bytes: u64)
influxdb3_write/src/write_buffer/persisted_files.rs:471
↓ 7 callersMethodbatch
Returns a batch with the specified number of random strings
core/parquet_file/src/writer.rs:254
↓ 7 callersFunctionbenchmark_scenario
( group: &mut BenchmarkGroup<'_, WallTime>, bench_name: &str, table: &str, namespace: &Namespa
core/sharder/benches/sharder.rs:102
↓ 7 callersFunctionbuild_checkpoint
( year_month: &str, parquet_files: Vec<ParquetFile>, pending_removed: Vec<ParquetFile>, )
influxdb3_write/src/write_buffer/persisted_files/tests.rs:380
↓ 7 callersMethodcardinality_min_max
( &self, writer_id: WriterId, writer_count: usize, )
influxdb3_load_generator/src/specification.rs:92
↓ 7 callersFunctioncheck_metric
(registry: &Arc<Registry>, operation_type: &'static str, expected: u64)
influxdb3_catalog/src/catalog/versions/v2/metrics/tests.rs:153
↓ 7 callersFunctionchunk
(n: usize)
object_store_utils/src/adaptive_put.rs:89
↓ 7 callersFunctioncolumn
(name: &str, semantic_type: SemanticType)
core/mutable_batch_pb/src/decode.rs:430
↓ 7 callersMethodcolumn_id_to_name
(&self, column_id: &ColumnIdentifier)
influxdb3_catalog/src/catalog/versions/v2.rs:3537
↓ 7 callersFunctioncompute_mask
(array: &[Option<T>])
core/mutable_batch/tests/writer_fuzz.rs:67
↓ 7 callersFunctionconstruct_with_endpoint
(endpoint: &'static str)
core/catalog_cache/src/api/client.rs:444
↓ 7 callersMethodcreate_database_opts
( &self, name: &str, options: CreateDatabaseOptions, )
influxdb3_catalog/src/catalog/versions/v2/update.rs:399
↓ 7 callersFunctioncreate_gzip_bytes
(data: &str)
influxdb3_server/src/tests.rs:607
↓ 7 callersMethodcreate_table_with_opts
Create a table with an explicit field family mode. Errors if the table already exists (the mode of an existing table is not reconsidered).
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:192
↓ 7 callersFunctioncreate_test_snapshot
( seq: u64, databases: SerdeVecMap<DbId, DatabaseTables>, removed_files: SerdeVecMap<DbId, Databas
influxdb3_write/src/write_buffer/checkpoint/tests.rs:19
↓ 7 callersMethoddb_schema
(&self)
influxdb3_catalog/src/catalog/versions/v1/update.rs:1005
↓ 7 callersMethodderef
(&self)
core/influxdb_line_protocol/src/lib.rs:502
↓ 7 callersFunctiondouble_quoted_string
Parse a double-quoted identifier string.
core/influxdb_influxql_parser/src/string.rs:84
↓ 7 callersFunctionerror_statement
(error: Error)
core/iox_v1_query_api/src/handler.rs:627
↓ 7 callersMethodeval_type
(&self, expr: &Expr)
core/iox_query_influxql/src/plan/expr_type_evaluator.rs:58
↓ 7 callersMethodevent
Record an event on this `Span`
core/trace/src/span.rs:93
↓ 7 callersMethodevict
Evict entries, returning an [EvictionAttempt] with the result.
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:817
↓ 7 callersMethodextract
(data: &mut ColumnData)
core/mutable_batch/src/writer.rs:79
↓ 7 callersFunctionfill_clause
Parse a `FILL(option)` clause. ```text fill_clause ::= "FILL" "(" fill_option ")" fill_option ::= "NULL" | "NONE" | "PREVIOUS" | "LINEAR" | number nu
core/influxdb_influxql_parser/src/select.rs:701
↓ 7 callersFunctionfilter_vec
(ranges: &[Range<usize>], src: &[T])
core/mutable_batch/tests/writer_fuzz.rs:90
↓ 7 callersMethodfinalize
Emit any pending per-table `AddColumns` records and return the inner [`CatalogTransaction`].
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:332
↓ 7 callersMethodformat_jaeger
(&self)
core/trace_http/src/ctx.rs:321
↓ 7 callersMethodget
(&self, op_res: OpResult)
core/object_store_metrics/src/metrics.rs:134
↓ 7 callersMethodget
(&self, location: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:108
↓ 7 callersMethodget_cached_checkpoint
Test helper: Get the cached checkpoint
influxdb3_write/src/persister.rs:1048
↓ 7 callersMethodget_with_retries
( &self, path: &Path, context_message: String, retry_params: RetryParams,
object_store_utils/src/retryable_object_store.rs:140
↓ 7 callersMethodhead
Returns the first element.
core/influxdb_influxql_parser/src/common.rs:453
↓ 7 callersMethodinputs
(&self)
core/iox_query/src/exec/sleep.rs:63
↓ 7 callersMethodinto_inner
(self)
influxdb3_authz/src/role/role.rs:75
↓ 7 callersMethodis_allowed
(&self, perm: &Self)
influxdb3_authz/src/permissions.rs:310
↓ 7 callersMethoditer
(&self)
core/arrow_util/src/string.rs:129
↓ 7 callersMethodlabels
Extract the value for the given label set, or panic. # Usage ```rust # use test_helpers::prometheus::*; # # let m = parse(r#"bananas{path="/write",s
core/test_helpers/src/prometheus.rs:96
↓ 7 callersMethodlen
Returns the length of the sort key
core/schema/src/sort.rs:124
↓ 7 callersMethodlen
(&self)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:106
↓ 7 callersFunctionload_catalog
( prefix: Arc<str>, store: &ObjectStoreCatalog, )
influxdb3_catalog/src/serialize/versions/v2.rs:28
↓ 7 callersFunctionload_token_from_file
Load the token from a file, trimming whitespace. Returns `Ok(None)` if the file is empty after trimming. Returns `Ok(Some(token))` if a non-empty tok
core/influxdb_iox_client/src/client/reloadable_token.rs:156
↓ 7 callersFunctionmake_any_wrapped_proto_ticket
(read_info: &proto::ReadInfo)
core/service_grpc_flight/src/request.rs:1137
↓ 7 callersFunctionmake_json_ticket
(json: &str)
core/service_grpc_flight/src/request.rs:1153
↓ 7 callersFunctionmake_proto_ticket
(read_info: &proto::ReadInfo)
core/service_grpc_flight/src/request.rs:1147
↓ 7 callersMethodmax_row
Return the max (as [`Row`]) at the specified index
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:322
↓ 7 callersFunctionmaybe_array
Randomly may return an array containing randomly generated, nullable data
core/mutable_batch/tests/writer_fuzz.rs:50
↓ 7 callersMethodname
(&self)
core/panic_logging/src/lib.rs:144
↓ 7 callersMethodname
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:87
↓ 7 callersFunctionnanos_to_timestamp
Returns `nanos` as a timestamp.
core/influxdb_influxql_parser/src/literal.rs:362
↓ 7 callersMethodnew_lock
(self: &Arc<Self>, t: T)
core/tracker/src/lock.rs:78
↓ 7 callersMethodnext_error
(&self)
influxdb3_clap_blocks/src/object_store/tests.rs:493
↓ 7 callersMethodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3499
↓ 7 callersMethodord_id
Return the legacy column ordinal ID when one is assigned.
influxdb3_catalog/src/catalog/versions/v2.rs:3797
↓ 7 callersMethodoutput_plan
(&self)
core/iox_query/src/physical_optimizer/test_util.rs:69
↓ 7 callersFunctionparse_fields
(exprs: Vec<&str>)
core/iox_query_influxql/src/plan/field.rs:126
↓ 7 callersFunctionpartition_keys
Returns an iterator of partition keys for the given table batch. This function performs deduplication on returned keys; the returned iterator yields
core/partition/src/lib.rs:75
↓ 7 callersMethodpersist
(&self, object_store: Arc<dyn ObjectStore>)
influxdb3_write/src/table_index.rs:161
↓ 7 callersMethodpersist_log
Persist a log file at `sequence_number` using create-only semantics.
influxdb3_catalog/src/object_store/versions/v3.rs:299
↓ 7 callersFunctionplan
()
core/iox_query/src/query_log.rs:7631
↓ 7 callersMethodpredicate
Returns the [`DeletePredicate`]
core/dml/src/lib.rs:254
↓ 7 callersMethodpush
Append a new (key, value) pair # Panics Panics if this would exceed the capacity provided to new
core/data_types/src/snapshot/hash.rs:138
↓ 7 callersMethodpush
Push a [`Row`] from the WAL into the cache, if the row contains all of the cached columns.
influxdb3_cache/src/distinct_cache/cache.rs:120
↓ 7 callersMethodput_opts
( &self, location: &Path, bytes: PutPayload, opts: PutOptions, )
influxdb3_cache/src/parquet_cache/mod.rs:707
↓ 7 callersMethodput_with_default_retries
( &self, path: &Path, payload: PutPayload, context_message: String, )
object_store_utils/src/retryable_object_store.rs:222
↓ 7 callersMethodquery_sql
(&self, db: &str, query_str: &str)
influxdb3_server/tests/lib.rs:338
↓ 7 callersMethodrecord_invocation
(&self, key: &PluginTriggerInvocationKey)
influxdb3_processing_engine/src/plugin_telemetry.rs:78
↓ 7 callersMethodregister_in_current_thread
Registers capture in current thread.
core/test_helpers/src/tracing.rs:138
↓ 7 callersFunctionregistered_and_stopped
Carry the node through to terminal `Stopped` via RequestStopNode + AckStopNode.
influxdb3_catalog/src/format/records/node/tests.rs:51
↓ 7 callersFunctionremove_args
(node_id: &str)
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:313
↓ 7 callersMethodremove_snapshot_wal_files
( &self, snapshot_details: SnapshotDetails, snapshot_permit: OwnedSemaphorePermit,
influxdb3_wal/src/object_store.rs:483
↓ 7 callersFunctionrequest
(query: RunQuery, authorization: &'static str)
core/service_grpc_flight/src/lib.rs:1938
↓ 7 callersMethodreset
(&mut self)
influxdb3_telemetry/src/stats.rs:53
↓ 7 callersFunctionretry_operation
( retry_params: RetryParams, context_message: String, operation_label: &'static str, path: &Pa
object_store_utils/src/retryable_object_store.rs:89
↓ 7 callersFunctionrun_tests
(bytes: &[u8], offset: usize, name: &'static str, c: &mut Criterion)
core/arrow_util/benches/iter_set_positions.rs:8
↓ 7 callersFunctionsample_create_table
(database_id: u32, table_id: u32, sequence: u64)
influxdb3_catalog/src/format/apply/tests.rs:254
↓ 7 callersMethodschema
(&self)
core/iox_query/src/exec/gapfill/mod.rs:210
↓ 7 callersMethodselect
Returns a Schema that represents selecting some of the columns in this schema. An error is returned if the selection refers to columns that do not exi
core/schema/src/lib.rs:830
↓ 7 callersFunctionset_position_iterator
(valid_mask: &[u8], to_insert: usize)
core/mutable_batch/src/writer.rs:926
↓ 7 callersFunctionsetup_cache_optional
( start: Time, object_store: Arc<dyn ObjectStore>, wal_config: WalConfig, use_cache: bool, )
influxdb3_write/src/write_buffer/tests.rs:2770
↓ 7 callersFunctionshared_store
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1645
← previousnext →1,001–1,100 of 11,906, ranked by callers