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
↓ 13 callersMethodcatalog_update_with_retry
Perform a catalog update and retry if the catalog has been updated elsewhere until the operation succeeds or fails
influxdb3_catalog/src/catalog/versions/v1/update.rs:778
↓ 13 callersMethodchecked_sub
Subtracts the given [`Duration`] from the current date and time. Returns `None` if it would result in overflow
core/iox_time/src/lib.rs:149
↓ 13 callersMethodclient_addr
Get the URL of the running service for use with an HTTP client
influxdb3/tests/server/mod.rs:687
↓ 13 callersMethodcontains_name
(&self, name: &str)
influxdb3_catalog/src/catalog/versions/v2/update.rs:2089
↓ 13 callersFunctioncreate_test_series_limit
()
core/iox_query/src/exec/series_limit/logical.rs:888
↓ 13 callersFunctioncreate_usage
( total_db_count: u32, total_table_count: u32, total_column_count: u32, )
influxdb3_catalog/src/catalog/versions/v2/enterprise/tests.rs:425
↓ 13 callersMethoddecode
Decode [Apache Parquet] metadata from [Apache Thrift]-encoded, and [Zstandard]-compressed bytes. [Apache Parquet]: https://parquet.apache.org/ [Apach
core/parquet_file/src/metadata.rs:689
↓ 13 callersMethodid
(&self)
influxdb3_write/src/chunk.rs:40
↓ 13 callersMethodinner
(&self)
influxdb3_write/src/write_buffer/validator.rs:93
↓ 13 callersFunctioninterval
(ns: i64)
core/iox_query/src/exec/gapfill/params.rs:375
↓ 13 callersMethodinto_grpc_connection
Consume `self` and return a [`GrpcConnection`] (suitable for use in tonic clients)
core/client_util/src/connection.rs:29
↓ 13 callersMethodis_empty
(&self)
influxdb3_catalog/src/format/record.rs:195
↓ 13 callersMethoditer
Returns an iterator over the columns in this key
core/schema/src/sort.rs:119
↓ 13 callersMethodload_or_create_catalog
Try loading the catalog, if there is no catalog generate new instance id and create a new catalog and persist it immediately
influxdb3_catalog/src/object_store/versions/v2.rs:58
↓ 13 callersFunctionmetadata
(sql: &str)
core/iox_query_influxql/src/plan/planner.rs:4656
↓ 13 callersMethodname
(&self)
core/iox_query/src/provider/deduplicate.rs:221
↓ 13 callersFunctionnew_cursor_with_batch_size
(params: &GapFillParams, batch_size: usize)
core/iox_query/src/exec/gapfill/algo.rs:1620
↓ 13 callersFunctionnormalize_predicate
Predicate that has been "specialized" / normalized for a particular table. Specifically: all references to the [MEASUREMENT_COLUMN_NAME] column in an
core/predicate/src/rpc_predicate.rs:233
↓ 13 callersFunctionordering
(cols: [&str; N], schema: &SchemaRef)
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:668
↓ 13 callersMethodparse
(i: &str)
core/influxdb_influxql_parser/src/select.rs:202
↓ 13 callersFunctionpending
()
core/tracker/src/task.rs:554
↓ 13 callersMethodpush
Push a single value. If it is not of the same type as we are already storing in this builder, this function will return an error.
core/table_batch/src/builder/column_writer/mod.rs:53
↓ 13 callersFunctionquery
( server: impl Into<String> + Send, database: impl Into<String> + Send, query: impl Into<String> +
influxdb3_server/src/tests.rs:1543
↓ 13 callersMethodresource_iter
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/column.rs:406
↓ 13 callersFunctionsample_register_node
()
influxdb3_catalog/src/format/apply/tests.rs:33
↓ 13 callersFunctionschema_with_influxql_filled
( schema: DFSchemaRef, filled: &[bool], )
core/iox_query_influxql/src/plan/planner/metadata.rs:93
↓ 13 callersMethodsequence_number
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:900
↓ 13 callersMethodset_permissions
enterprise only
influxdb3_authz/src/lib.rs:320
↓ 13 callersFunctionsorted
(mut input: Vec<TaskTracker<i32>>)
core/tracker/src/task.rs:1123
↓ 13 callersMethodsql
Plan a SQL query and return a DataFusion physical plan
influxdb3_query_executor/src/query_planner.rs:38
↓ 13 callersMethodstats
(&self)
core/iox_query/src/test.rs:1178
↓ 13 callersMethodtable
Gets the write for a given table
core/dml/src/lib.rs:187
↓ 13 callersMethodtables
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2389
↓ 13 callersFunctiontest_registry
()
core/tracker/src/task.rs:562
↓ 13 callersFunctiontest_time_provider
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:27
↓ 13 callersMethodtruncate
Truncates the bitset to the provided length
core/arrow_util/src/bitset.rs:75
↓ 13 callersMethodudf
(&self, name: &str)
core/query_functions/src/registry.rs:102
↓ 13 callersMethodunwrap_success
(self)
influxdb3_catalog/src/catalog/versions/v2/update.rs:2058
↓ 13 callersMethodwait_for
Wait for count. # Panic Will panic after timeout.
core/object_store_mem_cache/src/cache_system/hook/notify/test_utils.rs:57
↓ 13 callersMethodwith_bad_tls
Set whether to use bad tls certs or not for the [`TestServer`]
influxdb3/tests/server/mod.rs:192
↓ 13 callersMethodwith_line_protocol
(mut self, lp: impl Into<String>)
influxdb3/tests/cli/api.rs:908
↓ 13 callersMethodwith_tag_column_with_nulls_and_full_stats
Register a tag column with stats with the test chunk
core/iox_query/src/test.rs:656
↓ 13 callersMethodwrite_to_rows
(&self, lp: impl AsRef<str>, ingest_time_sec: i64)
influxdb3_write/src/write_buffer/table_buffer/tests.rs:27
↓ 12 callersMethodacquire
Acquire a single permit. See [`tokio::sync::Semaphore::acquire`] for details.
core/tracker/src/async_semaphore.rs:220
↓ 12 callersMethodapi_v3_query_influxql
(&self, params: &[(&str, &str)])
influxdb3/tests/server/mod.rs:961
↓ 12 callersFunctionarg_to_fields
(args: &[ColumnarValue])
core/query_functions/src/tz.rs:531
↓ 12 callersMethodbuild
Build store from parameters.
core/object_store_mem_cache/src/store.rs:191
↓ 12 callersMethodcmp
(&self, other: &Self)
influxdb3_catalog/src/log/versions/v2.rs:155
↓ 12 callersMethodcolumn_mut
(&mut self, name: &str, influx_type: InfluxColumnType)
core/mutable_batch/src/writer.rs:833
↓ 12 callersMethodcolumn_type
Return the InfluxDB type of the column.
influxdb3_catalog/src/catalog/versions/v3/schema/column.rs:90
↓ 12 callersMethodcommit
Commit an accumulated database transaction atomically. Returns `Prompt::Retry` when the catalog advanced between `begin_database_transaction()` and `
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2684
↓ 12 callersMethodconvert_lines_to_buffer
Convert a set of valid parsed `v3` lines to a [`ValidatedLines`] which will be buffered and written to the WAL, if configured. This involves splittin
influxdb3_write/src/write_buffer/validator.rs:366
↓ 12 callersMethoddec
Decrements the value of this U64Gauge by the specified amount. # Underflow / Overflow This operation wraps around on over/underflow.
core/metric/src/gauge.rs:31
↓ 12 callersMethoddescription
(&self)
core/generated_types/src/google.rs:437
↓ 12 callersMethoddo_get_with_cmd
Implements the canonical interaction for most FlightSQL messages: 1. Call `GetFlightInfo` with the provided message, and get a [`FlightInfo`] and emb
core/influxdb_iox_client/src/client/flightsql.rs:398
↓ 12 callersMethoddrain
Triggers shutdown of this `AsyncExporter` and waits until all in-flight spans have been published to the `AsyncExport`
core/trace_exporters/src/export.rs:68
↓ 12 callersMethodend
Return the timestamp exclusive range's end.
core/data_types/src/lib.rs:2319
↓ 12 callersMethodfield
( ff_id: FieldFamilyId, name: impl Into<Arc<str>>, data_type: InfluxFieldType, )
influxdb3_catalog/src/catalog/versions/v2.rs:3706
↓ 12 callersMethodget
(self)
influxdb3_authz/src/permissions.rs:254
↓ 12 callersMethodget
(&self, location: &Path)
object_store_utils/src/test_object_store.rs:298
↓ 12 callersMethodget_by_id
(&self, id: &ColumnId)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:143
↓ 12 callersMethodget_by_name
(&self, name: &str)
influxdb3_catalog/src/repository.rs:155
↓ 12 callersFunctionidentifier
Parses an InfluxQL [Identifier]. EBNF for an identifier is approximately: ```text identifier ::= whitespace? ( quoted_identifier | unquoted
core/influxdb_influxql_parser/src/identifier.rs:84
↓ 12 callersMethodinner
return a reference to the inner plan
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2527
↓ 12 callersMethodinvoke_with_args
(&self, args: ScalarFunctionArgs)
core/query_functions/src/tz.rs:147
↓ 12 callersMethodis_deleted
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:41
↓ 12 callersMethodlen
Number of stored entries. # Concurrency This method is mostly lockless, except for internal locks within [`DashMap`].
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:454
↓ 12 callersMethodlen
The number of strings in this array
core/arrow_util/src/string.rs:137
↓ 12 callersFunctionlit_dict
Creates an `Expr` that represents a Dictionary encoded string (e.g the type of constant that a tag would be compared to)
core/datafusion_util/src/lib.rs:97
↓ 12 callersMethodlog
(&self, log_level: LogLevel, log_line: impl Into<String>)
influxdb3_py_api/src/logging.rs:107
↓ 12 callersMethodlogically_planned
Record that this query got logically planned.
core/iox_query/src/query_log.rs:1137
↓ 12 callersMethodmake_object_store
(&self)
influxdb3_clap_blocks/src/object_store/tests.rs:24
↓ 12 callersFunctionmake_record_stream
(records: Option<usize>)
influxdb3_server/src/http/tests.rs:342
↓ 12 callersFunctionmake_schema
()
core/iox_query_influxql/src/plan/planner/metadata.rs:214
↓ 12 callersMethodmock_next
(self: Arc<Self>, call: MockCall)
influxdb3_test_helpers/src/object_store/mock.rs:311
↓ 12 callersMethodname
Specify a cache name
influxdb3_client/src/lib.rs:1608
↓ 12 callersFunctionnew_schema
()
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:714
↓ 12 callersMethodpermissions
Get the subset of requested permissions that were granted by the token. Error::Forbidden is returned if the authorization has no granted permissions.
core/authz/src/authorization.rs:34
↓ 12 callersMethodphysically_planned
Record that this query got physically planned.
core/iox_query/src/query_log.rs:1178
↓ 12 callersFunctionproject_select_subset_of_column_statistics
Determine the output statistics based upon a subset of columns. [`Statistics`] have column_statistics indexed to the plan's schema fields. When the o
core/iox_query/src/statistics/partition_statistics/project_schema.rs:156
↓ 12 callersMethodraw
The raw `u16` value persisted in record headers.
influxdb3_catalog/src/format/record_id.rs:61
↓ 12 callersFunctionregistry
Return an [`FunctionRegistry`] with the implementations of IOx UDFs and the datafusion-provided UDFs
core/query_functions/src/lib.rs:112
↓ 12 callersMethodremove
(&mut self, token_id: &TokenId)
influxdb3_authz/src/permissions.rs:702
↓ 12 callersMethodreserve
Reserve space for `count` further bits
core/arrow_util/src/bitset.rs:42
↓ 12 callersFunctionreturn_field
(dt: DataType)
core/query_functions/src/tz.rs:538
↓ 12 callersMethodrun_with_confirmation
(&self, commands: Vec<&str>, args: &[&str])
influxdb3/tests/cli/api.rs:45
↓ 12 callersMethodscan
Creates a plan like the following: ```text Project (keep only columns needed in the rest of the plan) Filter (optional, apply any push down predicate
core/iox_query/src/provider.rs:202
↓ 12 callersFunctionschema
()
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs_for_constants.rs:791
↓ 12 callersFunctionschema
()
core/iox_query/src/physical_optimizer/sort/parquet_sortness.rs:633
↓ 12 callersMethodset_next_id
(&mut self, id: RoleId)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:42
↓ 12 callersFunctionsetup
()
object_store_utils/src/observed_object_store/tests.rs:6
↓ 12 callersMethodshard
( &self, table: &str, namespace: &NamespaceName<'_>, _payload: &MutableBatch,
core/sharder/src/jumphash.rs:133
↓ 12 callersMethodstate
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2208
↓ 12 callersFunctiontest_catalog
()
influxdb3_catalog/src/format/apply/tests.rs:19
↓ 12 callersMethodunwrap_field
(self, field: impl Into<String>)
core/generated_types/src/google.rs:728
↓ 12 callersFunctionvalidate_path_within_plugin_dir
Validates that a user-provided path stays within the plugin directory. Prevents path traversal attacks via "..", absolute paths, and symlinks.
influxdb3_processing_engine/src/lib.rs:54
↓ 12 callersMethodwith_auth_token
Set the auth token for this [`TestServer`]
influxdb3/tests/server/mod.rs:121
↓ 12 callersMethodwith_hard_delete
(mut self, when: impl Into<String>)
influxdb3/tests/cli/api.rs:321
↓ 12 callersMethodwrite
Write line protocol to the database this trigger is attached to. Legacy api that batches writes and writes them at the end of plugin execution.
influxdb3_py_api/src/system_py.rs:112
↓ 12 callersMethodwrite
(&self, db_name: impl Into<String>)
influxdb3/tests/cli/api.rs:1131
← previousnext →601–700 of 11,906, ranked by callers