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
↓ 1 callersMethodis_snapshot
Returns true if this file is a snapshot.
influxdb3_catalog/src/format/header.rs:195
↓ 1 callersMethodis_subquery
(&self)
core/iox_query_influxql/src/plan/rewriter.rs:201
↓ 1 callersMethodis_tag_field
Returns `true` if the schema contains a tag column with the specified name.
core/iox_query_influxql/src/plan/util.rs:63
↓ 1 callersMethodis_tag_type
Returns true if the receiver is a data type that identifies as a tag type.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:267
↓ 1 callersMethodis_token_allowed_access
( &self, _token_id: &TokenId, _access_request: crate::AccessRequest, )
influxdb3_authz/src/authorizer/tests.rs:70
↓ 1 callersMethodis_unbounded
Returns `true` if the `lower` and `upper` bounds are `None`.
core/influxdb_influxql_parser/src/time_range.rs:388
↓ 1 callersMethodis_used
(&self, idx: usize)
core/schema/src/lib.rs:402
↓ 1 callersFunctionis_utc
Returns whether a timezone is a known UTC variant. At least enough that date_bin_wallclock would work exactly the same as date_bin would.
core/query_functions/src/date_bin_wallclock.rs:404
↓ 1 callersFunctionis_valid_character_after_escape
(c: char)
core/query_functions/src/regex.rs:122
↓ 1 callersFunctionis_valid_date_part_call
Returns true if `expr` is a valid [`Expr::Call`] expression for the `date_part` function.
core/influxdb_influxql_parser/src/select.rs:320
↓ 1 callersFunctionis_valid_now_call
Returns true if `expr` is a valid [`Expr::Call`] expression for the `now` function.
core/influxdb_influxql_parser/src/select.rs:312
↓ 1 callersMethoditer
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:216
↓ 1 callersFunctionjaeger_exporter
(config: &TracingConfig)
core/trace_exporters/src/lib.rs:178
↓ 1 callersFunctionjson_content_type
Check that the content type is application/json
influxdb3_server/src/http.rs:2183
↓ 1 callersMethodkey
(&self)
core/data_types/src/snapshot/partition.rs:231
↓ 1 callersMethodkey
Returns the partition key for this partition without decoding it. This is a no-op operation and should be rather fast. See [`partition_key`](Self::p
core/data_types/src/snapshot/table.rs:237
↓ 1 callersMethodlabels_by_org
List all Labels by organization ID
core/influxdb2_client/src/api/label.rs:16
↓ 1 callersMethodlast_assigned_bucket
The last bucket assigned by the [`BucketHasher`].
core/partition/src/template/bucket.rs:26
↓ 1 callersFunctionlast_caches_schema
()
influxdb3_system_tables/src/last_caches.rs:25
↓ 1 callersFunctionlast_day_of_month
(month: i32)
core/query_functions/src/window/internal.rs:167
↓ 1 callersMethodlast_error_at
Return the timestamp of the most recent recorded error, or `None` if no error has ever been recorded. Paired with [`last_error_category`](Self::last_e
object_store_utils/src/object_store_health.rs:156
↓ 1 callersMethodlast_output_row
Returns the row-oriented representation of the last buffered row that may appear in the next output batch. Since this row may be used multiple times,
core/iox_query/src/exec/gapfill/buffered_input.rs:248
↓ 1 callersMethodlast_output_row_offset
Given that the cursor points at the input row that will be the first row in the next output batch, return the offset of last input row that could poss
core/iox_query/src/exec/gapfill/algo.rs:118
↓ 1 callersMethodlast_snapshot_sequence_number
Get the last snapshot sequence number from the checkpoint
influxdb3_write/src/lib.rs:488
↓ 1 callersMethodlast_snapshot_sequence_number
(&self)
influxdb3_wal/src/object_store.rs:653
↓ 1 callersMethodlast_success_at
Return the timestamp of the most recent recorded success, or `None` if no success has ever been recorded.
object_store_utils/src/object_store_health.rs:145
↓ 1 callersMethodlatest_log_sequence
The highest log sequence present, if any.
influxdb3_commands/src/debug/catalog/mod.rs:272
↓ 1 callersMethodlatest_snapshot_sequence_number
(&self)
influxdb3_write/src/table_index.rs:572
↓ 1 callersMethodlayer
(&self, service: S)
core/client_util/src/tower.rs:25
↓ 1 callersFunctionlegacy_index_entry
Encode one legacy group-index entry: group_type, group_key, record_count, and byte_length as u32 LE, then byte_offset as u64 LE.
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1353
↓ 1 callersMethodlen
(&self)
core/table_batch/src/builder/column_writer/dictionary.rs:53
↓ 1 callersMethodlevel_reached
Notify when then given level is reached or overshot. This will trigger every time a new entry is [fetched](Hook::fetched) while the condition is met.
core/object_store_mem_cache/src/cache_system/hook/level_trigger.rs:34
↓ 1 callersFunctionlimit_exec
(input: &Arc<dyn ExecutionPlan>, fetch: usize)
core/iox_query/src/test.rs:1498
↓ 1 callersMethodlist
(&self, prefix: Option<&Path>)
core/object_store_metrics/src/lib.rs:423
↓ 1 callersMethodlist
(&self, config: TableListConfig)
influxdb3/src/commands/show/system.rs:129
↓ 1 callersMethodlist_distinct_caches
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2401
↓ 1 callersMethodlist_generation_durations
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:1182
↓ 1 callersFunctionlist_installed_packages
()
influxdb3_processing_engine/src/environment.rs:133
↓ 1 callersMethodlist_last_caches
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2410
↓ 1 callersMethodlist_namespaces
( &self, _span: Option<Span>, )
core/iox_query/src/test.rs:119
↓ 1 callersMethodlist_nodes
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:723
↓ 1 callersMethodlist_plugin_files
(&self)
influxdb3_processing_engine/src/lib.rs:864
↓ 1 callersFunctionlist_wal_files
(object_store_root: &str, node_id: &str)
influxdb3/tests/server/gen1_lookback_guard.rs:65
↓ 1 callersMethodlist_with_default_retries
( &self, prefix: Option<&Path>, offset: Option<&Path>, context_message: String
object_store_utils/src/retryable_object_store.rs:427
↓ 1 callersMethodlist_with_delimiter
(&self, prefix: Option<&Path>)
core/object_store_metrics/src/lib.rs:468
↓ 1 callersMethodlist_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
core/object_store_metrics/src/lib.rs:443
↓ 1 callersMethodlit
(self)
core/influxdb_influxql_parser/src/expression/arithmetic.rs:655
↓ 1 callersFunctionliteral
Parse any InfluxQL literal.
core/influxdb_influxql_parser/src/literal.rs:352
↓ 1 callersFunctionliteral_regex
Parse an InfluxQL literal regular expression.
core/influxdb_influxql_parser/src/literal.rs:357
↓ 1 callersFunctionload_catalog_from_paths
( checkpoint_path: &ObjPath, log_paths: &[ObjPath], store: &ObjectStoreCatalog, )
influxdb3_catalog/src/serialize/versions/v2.rs:83
↓ 1 callersMethodload_catalog_sequenced_log
( &self, sequence_number: CatalogSequenceNumber, )
influxdb3_catalog/src/object_store/versions/v2.rs:102
↓ 1 callersFunctionload_dotenv
Source the .env file before initialising the Config struct - this sets any envs in the file, which the Config struct then uses. Precedence is given t
influxdb3_load_generator/src/main.rs:163
↓ 1 callersFunctionload_dotenv
Source the .env file before initialising the Config struct - this sets any envs in the file, which the Config struct then uses. Precedence is given t
influxdb3/src/lib.rs:666
↓ 1 callersMethodload_existing_wal_file_paths
( &self, last_wal_sequence_number: Option<WalFileSequenceNumber>, all_wal_file_paths:
influxdb3_wal/src/object_store.rs:453
↓ 1 callersFunctionload_files_from_obj_store
(object_store: &Arc<dyn ObjectStore>, path: &Path)
influxdb3_write/src/write_buffer/tests.rs:2922
↓ 1 callersFunctionload_function_from_module
Loads a Python function from a multi-file plugin module. This function temporarily adds the plugin's parent directory to Python's sys.path, imports t
influxdb3_py_api/src/system_py.rs:393
↓ 1 callersMethodload_metadata
(&mut self)
core/iox_query/src/physical_optimizer/cached_parquet_data.rs:199
↓ 1 callersMethodload_parquet_file
(&self, path: ParquetFilePath)
influxdb3_write/src/persister.rs:300
↓ 1 callersFunctionload_restore_state
Load the backup state referenced by a `RestoreCatalog` record. Preserves the live cluster's committed feature level if it is ahead of the backup's —
influxdb3_catalog/src/format/apply.rs:257
↓ 1 callersMethodload_snapshots_after
Loads snapshots newer than a given sequence number. Used after loading checkpoints to get any snapshots created since the checkpoint.
influxdb3_write/src/persister.rs:892
↓ 1 callersFunctionlocf
(arg: Expr)
core/iox_query/src/analyzer/handle_gapfill.rs:729
↓ 1 callersMethodlog_path
(&self, sequence: u64)
influxdb3_commands/src/debug/catalog/mod.rs:134
↓ 1 callersFunctionlog_storage_mode
Convert the schema-level [`StorageMode`] to the log-level one used by [`CatalogError::LegacyColumnIdsExhausted`]. TODO(tjh): when the v2 catalog is sw
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:47
↓ 1 callersMethodlogs_dir
(&self)
influxdb3_commands/src/debug/catalog/mod.rs:138
↓ 1 callersFunctionlower_bound_to_df_expr
Assumes the provided nanosecond i64 value is in UTC. Returns a datafusion expression in UTC, relying upon the datafusion engine to perform any castin
core/iox_query_influxql/src/plan/planner_time_range_expression.rs:14
↓ 1 callersFunctionlp_to_table_batch
(lp: &str)
core/mutable_batch_pb/benches/write_table_batch.rs:10
↓ 1 callersMethodmake_batch
(&mut self, spans: Vec<Span>)
core/trace_exporters/src/jaeger.rs:145
↓ 1 callersFunctionmake_exec
(object_store: Arc<dyn ObjectStore>)
influxdb3_query_executor/src/tests.rs:36
↓ 1 callersFunctionmake_flight_data_stream
Convert query result stream (= [`RecordBatch`]es) into a [`FlightData`] stream. This stream will -- as in prod -- send the [`Schema`] data even when
core/service_grpc_flight/src/keep_alive.rs:486
↓ 1 callersFunctionmake_flight_server
( server: Arc<dyn QueryExecutor>, authz: Option<Arc<dyn Authorizer>>, )
influxdb3_server/src/grpc.rs:9
↓ 1 callersFunctionmake_long_str
Make long string data
core/parquet_file/src/lib.rs:637
↓ 1 callersFunctionmake_lp
Generate line protocol for a single partition.
core/mutable_batch_lp/benches/parse_lp.rs:36
↓ 1 callersFunctionmake_multi_row_batch
( t1: Vec<Option<&str>>, t2: Vec<Option<&str>>, f1: Vec<Option<f64>>, )
core/iox_query/src/provider/deduplicate.rs:866
↓ 1 callersFunctionmake_query_result_stream
Creates a stream like the query processing would do.
core/service_grpc_flight/src/keep_alive.rs:465
↓ 1 callersFunctionmake_rng
()
core/partition/src/lib.rs:481
↓ 1 callersFunctionmake_server
( server: Arc<dyn QueryDatabase>, authz: Option<Arc<dyn Authorizer>>, )
core/service_grpc_flight/src/lib.rs:668
↓ 1 callersFunctionmake_server_with_observer
( server: Arc<dyn QueryDatabase>, authz: Option<Arc<dyn Authorizer>>, observer: Option<Arc<dyn Fli
core/service_grpc_flight/src/lib.rs:675
↓ 1 callersFunctionmake_stream_split
Create a StreamSplit node which takes an input stream of record batches and produces multiple output streams based on a list of `N` predicates. The o
core/iox_query/src/exec.rs:396
↓ 1 callersFunctionmake_struct_datatype
Create output struct [`DataType`]. This will be a struct with the following fields: - `value` - `time` - `other_{1..}` (depending on the other input
core/query_functions/src/selectors/type_handling.rs:51
↓ 1 callersFunctionmake_struct_scalar
Create output struct [`ScalarValue`]. This will be a struct with the following fields: - `value` - `time` - `other_{1..}` (depending on the other in
core/query_functions/src/selectors/type_handling.rs:71
↓ 1 callersFunctionmake_tag_key_column_meta
( fields: &[Field], tag_set: &[&str], is_projected: &[bool], )
core/iox_query_influxql/src/plan/planner/select.rs:16
↓ 1 callersMethodmake_timestamp_predicate_expr
Creates a DataFusion predicate for appliying a timestamp range: `range.start <= time and time < range.end`
core/predicate/src/lib.rs:104
↓ 1 callersMethodmake_wal_table_filter
Get the table filter for WAL flush triggers. Returns `Ok(None)` for all-tables triggers, `Ok(Some(table_id))` for single-table triggers, or an error
influxdb3_processing_engine/src/plugins.rs:388
↓ 1 callersFunctionmany0_
Repeats the embedded parser until it fails, discarding the results. This parser is used as a non-allocating version of [`nom::multi::many0`].
core/influxdb_influxql_parser/src/common.rs:178
↓ 1 callersFunctionmany1_
Runs the embedded parser until it fails, discarding the results. Fails if the embedded parser does not produce at least one result. This parser is us
core/influxdb_influxql_parser/src/common.rs:196
↓ 1 callersFunctionmap_error
Applies a function returning a [`ParseResult`] over the result of the `parser`. If the parser returns an error, the result will be mapped to a recover
core/influxdb_influxql_parser/src/internal.rs:62
↓ 1 callersFunctionmap_type
( s: &dyn SchemaProvider, measurement_name: &str, field: &str, )
core/iox_query_influxql/src/plan/field_mapper.rs:33
↓ 1 callersMethodmapped_partition_indices
Mapping of indices. `mapped_partition_indices[out] = in`
core/iox_query/src/provider/reorder_partitions.rs:81
↓ 1 callersMethodmark_used
(&mut self, idx: usize)
core/schema/src/lib.rs:406
↓ 1 callersMethodmatches_node_spec
Test whether the current node satisfies `node_spec`. `All` always matches; `Nodes(_)` requires the current node to be configured and its catalog id to
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1174
↓ 1 callersMethodmax_age
Specify the maximum age for entries in the cache
influxdb3_client/src/lib.rs:1691
↓ 1 callersMethodmax_cardinality
Specify the maximum cardinality for the cache as a non-zero unsigned integer
influxdb3_client/src/lib.rs:1685
↓ 1 callersMethodmax_cardinality
Get the max cardinality accross all tags in the spec
influxdb3_load_generator/src/specification.rs:55
↓ 1 callersMethodmay_contain_pk_duplicates
(&self)
core/iox_query/src/test.rs:1210
↓ 1 callersMethodmay_contain_value
returns true if `tag_value` maps to this bucket id. Note that there are many tag values that map to the same bucket id. returns false if `tag_value`
core/iox_query/src/pruning_oracle.rs:195
↓ 1 callersMethodmaybe_computed_timestamp
If this is `Computed`, return `Some` with the value as a [`Timestamp`]. If this file was not created via compaction of other files and thus the `max_l
core/data_types/src/lib.rs:1336
↓ 1 callersMethodmaybe_expiry_millis
(&self)
influxdb3_authz/src/lib.rs:312
↓ 1 callersFunctionmaybe_print_help
Print the help for the cli if asked for and then exit the program
influxdb3/src/lib.rs:496
↓ 1 callersMethodmemory_size
Current amount of memory used by all entries. This does NOT include the memory consumption of the underlying [`IndexSet`] or the tombstones. They are
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/ordered_set.rs:54
↓ 1 callersMethodmerge
(&mut self, other: Self)
influxdb3_write/src/table_index.rs:259
← previousnext →3,901–4,000 of 11,906, ranked by callers