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
↓ 5 callersMethodwith_upper
(self, end: Bound<Expr>)
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:170
↓ 5 callersMethodwrite
Write a `Stream` of `DataPoint`s to the specified organization and bucket.
core/influxdb2_client/src/api/write.rs:41
↓ 5 callersMethodwrite_f64
Write the f64 typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding index in t
core/mutable_batch/src/writer.rs:262
↓ 5 callersMethodwrite_lp
Write the [LineProtocol] formatted string in `lp_data` to namespace `database`. Returns the number of bytes which were written to the namespace. [Li
core/influxdb_iox_client/src/client/write.rs:163
↓ 5 callersMethodwrite_lp
Write some line protocol data. If a field / tag name appears more than once in a single line, the following semantics apply: duplicate fields, same
core/mutable_batch_lp/src/lib.rs:104
↓ 5 callersMethodwrite_tag_dict
Write the tag typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding index in t
core/mutable_batch/src/writer.rs:597
↓ 5 callersMethodwrite_to_batch
(&self, batch: &mut MutableBatch)
core/partition/src/lib.rs:429
↓ 5 callersFunctionwrite_v1_catalog_to_store
Helper to write a v1 catalog to object store
influxdb3_catalog/src/catalog/migrations/tests.rs:40
↓ 5 callersFunctionyear_month_from_timestamp_ms
Extract year-month from a unix timestamp in milliseconds
influxdb3_write/src/write_buffer/checkpoint.rs:75
↓ 4 callersFunctionTIME_DATA_TYPE
()
core/schema/src/lib.rs:78
↓ 4 callersMethodaccept
(&self, visitor: V)
core/influxdb_influxql_parser/src/visit.rs:609
↓ 4 callersMethodaccepted
(self)
core/object_store_mem_cache/src/buffer_channel.rs:88
↓ 4 callersFunctionack_args
(node_id: &str, final_snapshot_sequence: Option<u64>)
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:304
↓ 4 callersMethodadd_columns
Add the columns to this [`TableDefinition`] This ensures that the resulting schema has its columns ordered
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:239
↓ 4 callersMethodadd_file
Add a file to the checkpoint and update metrics.
influxdb3_write/src/lib.rs:568
↓ 4 callersMethodadd_input_argument
(mut self, arg: impl Into<String>)
influxdb3/tests/cli/api.rs:921
↓ 4 callersMethodadd_tag
(&mut self, tag: impl AsRef<str>)
influxdb3_catalog/src/catalog/versions/v2/update.rs:1627
↓ 4 callersFunctionadjust_sort_key_columns
Given a sort key from the catalog and the primary key (tags + time) from the data, return the sort key that should be used for this parquet file and,
core/schema/src/sort.rs:421
↓ 4 callersMethodapi_v3_query_influxql
Compose a request to the `/api/v3/query_influxql` API # Example ```no_run # use influxdb3_client::Client; # #[tokio::main] # async fn main() -> Resul
influxdb3_client/src/lib.rs:316
↓ 4 callersMethodapi_v3_query_sql
Compose a request to the `/api/v3/query_sql` API # Example ```no_run # use influxdb3_client::Client; # #[tokio::main] # async fn main() -> Result<(),
influxdb3_client/src/lib.rs:283
↓ 4 callersFunctionappend_create_if_v2_write_action
(v2_permissions: &mut Vec<v2::enterprise::PermissionDetails>)
influxdb3_catalog/src/log/versions/v2/conversion.rs:61
↓ 4 callersMethodappend_null
(&mut self)
core/table_batch/src/builder/null_mask.rs:94
↓ 4 callersFunctionarr
Construct a boolean ColumnarValue::Array
core/iox_query/src/exec/split.rs:1070
↓ 4 callersMethodas_any
(&self)
influxdb3_wal/src/object_store/tests.rs:903
↓ 4 callersMethodas_boolean_opt
Return the value as a boolean, if it is one.
core/iox_v1_query_api/src/value.rs:67
↓ 4 callersMethodas_database
(&self)
influxdb3_catalog/src/log/versions/v2.rs:75
↓ 4 callersMethodas_duration
(&self)
influxdb3_wal/src/lib.rs:199
↓ 4 callersMethodas_float_opt
Return the value as a float, if it is one.
core/iox_v1_query_api/src/value.rs:81
↓ 4 callersMethodas_integer_opt
Return the value as an integer, if it is one.
core/iox_v1_query_api/src/value.rs:76
↓ 4 callersMethodas_ref
(&self)
influxdb3_types/src/database_name.rs:186
↓ 4 callersMethodas_secs
(&self)
influxdb3_catalog/src/log/versions/v4.rs:943
↓ 4 callersMethodas_str
(&self)
core/generated_types/src/google.rs:240
↓ 4 callersMethodas_string_opt
Return the value as a string, if it is one.
core/iox_v1_query_api/src/value.rs:94
↓ 4 callersMethodas_unsigned_opt
Return the value as an unsigned integer, if it is one.
core/iox_v1_query_api/src/value.rs:114
↓ 4 callersFunctionassert_both_ids_live_and_distinct
(repo: &Repository<I, R>, first: I, second: I)
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:101
↓ 4 callersFunctionassert_case_ok
( vals: [ColumnarValue; N], dt: &DataType, expected: [&'static str; M], )
core/query_functions/src/coalesce_struct.rs:412
↓ 4 callersFunctionassert_count
(metrics: &metric::Registry, t: &'static str, count: u64)
core/panic_logging/src/lib.rs:208
↓ 4 callersFunctionassert_dbs_not_empty_in_snapshot_file
(obj_store: &Arc<dyn ObjectStore>, host: &str)
influxdb3_write/src/write_buffer/tests.rs:2901
↓ 4 callersFunctionassert_err
(s: &'static str, expected: &'static str)
influxdb3_clap_blocks/src/memory_size/tests.rs:70
↓ 4 callersFunctionassert_float_field
Assert that the field named `field_name` has a float value within 0.0001% of `expected_value`, panic'ing if not
core/influxdb_line_protocol/src/lib.rs:2752
↓ 4 callersFunctionassert_fut_pending
Assert that given future is pending.
core/trace_exporters/src/rate_limiter.rs:130
↓ 4 callersFunctionassert_ok
(s: &'static str, expected: usize)
influxdb3_clap_blocks/src/memory_size/tests.rs:58
↓ 4 callersFunctionassert_roundtrip
(size: u64)
core/object_store_size_hinting/src/lib.rs:82
↓ 4 callersFunctionassert_runtime_thread_property
(builder: tokio::runtime::Builder, f: F)
influxdb3_clap_blocks/src/tokio/tests.rs:70
↓ 4 callersMethodassert_size
(&self, size_bytes_expected: u64, size_n_files_expected: u64)
influxdb3_cache/src/parquet_cache/tests.rs:475
↓ 4 callersFunctionassert_tablib_not_in_system_python
()
influxdb3/tests/server/packages.rs:247
↓ 4 callersFunctionassert_unknown_partitioning
(partitioning: Partitioning, n: usize)
core/iox_query/src/physical_optimizer/test_util.rs:78
↓ 4 callersMethodauthorize
( &self, token: Option<Vec<u8>>, perms: &[Permission], )
core/service_grpc_flight/src/lib.rs:1894
↓ 4 callersMethodbatch
(&self)
influxdb3_catalog/src/log/versions/v2.rs:135
↓ 4 callersFunctionbatches
(meta: InfluxQlMetadata)
core/influxdb_iox_client/src/format/influxql.rs:228
↓ 4 callersFunctionboolean
Parse the input for an InfluxQL boolean, which must be the value `true` or `false`.
core/influxdb_influxql_parser/src/literal.rs:232
↓ 4 callersMethodbroadcast
(&self, events: Vec<CatalogEvent>, context: &str)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2954
↓ 4 callersMethodbuild
(self)
influxdb3_write/src/table_index/test_table_index_operations.rs:71
↓ 4 callersMethodbuild_aggr_fill_interpolate
Create an Arrow array with gaps filled in between values using linear interpolation.
core/iox_query/src/exec/gapfill/algo/interpolate.rs:25
↓ 4 callersMethodbuild_aggr_fill_prev
Builds an array using the [`take`](take::take) kernel to produce an aggregate output column, filling gaps with the previous values in the column.
core/iox_query/src/exec/gapfill/algo.rs:602
↓ 4 callersFunctionbuild_raw_file
Build a raw catalog file from header fields plus a payload. The caller owns validity — this helper exists so corruption tests can construct malformed
influxdb3_catalog/src/format/reader/tests.rs:182
↓ 4 callersFunctioncapture
()
core/object_store_metrics/src/cache_metrics.rs:1073
↓ 4 callersMethodcatalog_id
(mut self, catalog_id: impl Into<Arc<str>>)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:226
↓ 4 callersMethodcatch_up_from
(&self, from_seq: CatalogSequenceNumber)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2826
↓ 4 callersMethodcheck_name
Check if the column name is available and not a reserved name.
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:210
↓ 4 callersMethodchild_span
Returns a new child span of the current context
core/iox_query/src/exec/context.rs:729
↓ 4 callersMethodchunks
Chunks that make up this node.
core/iox_query/src/provider/record_batch_exec.rs:100
↓ 4 callersMethodclient
Return a client suitable for communicating with this server
core/influxdb2_client/tests/common/server_fixture.rs:116
↓ 4 callersMethodcolumn_definition
(&self, name: impl AsRef<str>)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:46
↓ 4 callersMethodcolumn_definition
TODO(trevor): remove thid API in favour of the Repository APIs
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:411
↓ 4 callersFunctioncolumns
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2936
↓ 4 callersFunctioncommand
(mut config: Config)
influxdb3_load_generator/src/commands/full.rs:25
↓ 4 callersFunctioncomment_inline
Parse a SQL-style inline comment, which can span multiple lines
core/influxdb_influxql_parser/src/common.rs:163
↓ 4 callersFunctioncomment_single_line
Parse a SQL-style single-line comment
core/influxdb_influxql_parser/src/common.rs:158
↓ 4 callersMethodcompact_plan
Creates an execution plan for the COMPACT operations which does the following: 1. Merges chunks together into a single stream 2. Deduplicates via PK
core/iox_query/src/frontend/reorg.rs:68
↓ 4 callersMethodcontains_id
(&self, id: &ColumnIdentifier)
influxdb3_catalog/src/catalog/versions/v2.rs:3001
↓ 4 callersMethodcore_count
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:100
↓ 4 callersMethodcreate_distinct_cache
( &self, db_name: impl Into<String>, table_name: impl Into<String>, cache_name
influxdb3/tests/cli/api.rs:517
↓ 4 callersFunctioncreate_fx_serde_map
Helper to create FxHash-based SerdeVecMap (our optimized version)
influxdb3_id/benches/serde_vec_map_comparison.rs:10
↓ 4 callersFunctioncreate_snapshot_with_files
Create a snapshot with file data for testing aggregation
influxdb3_write/src/persister/tests.rs:710
↓ 4 callersMethodcreate_table
(&self, req: Request)
influxdb3_server/src/http.rs:1951
↓ 4 callersFunctioncreate_test_source
Helper function to create a simple test input.
core/iox_query/src/plan.rs:197
↓ 4 callersFunctioncreate_test_v1_catalog
Helper to create a test v1 catalog with sample data
influxdb3_catalog/src/catalog/migrations/tests.rs:14
↓ 4 callersMethoddatabase_deletion_status
Deletion status of a database by ID, or `None` if it exists and is not deleted.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1437
↓ 4 callersFunctiondate_bin_wallclock
Get a reference to the date_bin_wallclock ScalarUDF instance.
core/query_functions/src/date_bin_wallclock.rs:27
↓ 4 callersMethoddefault_hard_delete_duration
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:565
↓ 4 callersMethoddelete_auto_distinct_cache
Delete the auto-generated distinct cache for a table. This is used when expanding an auto cache - the old one is deleted and a new one with more colu
influxdb3_catalog/src/catalog/versions/v2/update.rs:778
↓ 4 callersFunctiondelete_from_clause
Parse a `FROM` clause for a `DELETE` statement.
core/influxdb_influxql_parser/src/simple_from_clause.rs:106
↓ 4 callersFunctiondelete_statement
Parse a `DELETE` statement.
core/influxdb_influxql_parser/src/delete.rs:51
↓ 4 callersMethoddelete_token
(&mut self, token_name: &str)
influxdb3_catalog/src/catalog/versions/v3/schema/tokens.rs:69
↓ 4 callersMethoddelete_with_default_retries
( &self, path: &Path, context_message: String, )
object_store_utils/src/retryable_object_store.rs:351
↓ 4 callersFunctiondisjunction
Parse disjunction operator, such as `OR`.
core/influxdb_influxql_parser/src/expression/conditional.rs:246
↓ 4 callersFunctiondistinct_values
Takes a `RecordBatch` and the column names that make up the primary key of the schema. Returns a map of column names to the set of the distinct string
core/schema/src/sort.rs:362
↓ 4 callersMethoddo_writes
( &self, db: &'static str, writes: impl IntoIterator<Item = TestWrite<LP>>, )
influxdb3_server/tests/lib.rs:318
↓ 4 callersMethoddone
Called when a terminal/final state ([fail](QueryPhase::Fail), [success](QueryPhase::Success), [cancel](QueryPhase::Cancel)) occurred. The query will N
core/iox_query/src/query_log.rs:1117
↓ 4 callersMethoddrain
Drain all elements from the queue, consuming the underlying VecDeque and returning a iterator over the items. This preserves the ordering of elements
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/fifo.rs:56
↓ 4 callersFunctionduration
Parse the input for an InfluxQL duration.
core/influxdb_influxql_parser/src/literal.rs:328
↓ 4 callersFunctionencode_status
(code: tonic::Code, message: String, details: Any)
core/generated_types/src/google.rs:98
↓ 4 callersMethodenter
(&self, _span: &Id)
core/test_helpers/src/tracing.rs:221
↓ 4 callersFunctionescaped_value
While not all of these escape characters are required to be escaped, we support the client escaping them proactively to provide a common experience.
core/influxdb_line_protocol/src/lib.rs:957
↓ 4 callersMethodeval_var_ref
Returns the type for the specified [`VarRef`]. This function assumes that the expression has already been reduced.
core/iox_query_influxql/src/plan/expr_type_evaluator.rs:110
↓ 4 callersMethodevict_if_full
Evict the oldest entries down to the configured maximum number of entries.
influxdb3_write/src/table_index_cache.rs:1033
↓ 4 callersFunctionexpected_false_positive_rate
Uses the formula in <https://hur.st/bloomfilter>.
core/object_store_metrics/src/cache_metrics.rs:280
↓ 4 callersMethodexponential_builder
(&self)
object_store_utils/src/retryable_object_store.rs:57
↓ 4 callersMethodexport
Exports this `Span` to its registered collector if any
core/trace/src/span.rs:117
← previousnext →1,501–1,600 of 11,906, ranked by callers