Functions — github.com/influxdata/influxdb

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4

↓ 67 callersFunctiondatabase

(id: u32, name: &str, retention: Option<RetentionPeriodSnapshot>)

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:100

↓ 67 callersFunctiontest_catalog

()

influxdb3_catalog/src/catalog/versions/v3/ops/test_util.rs:17

↓ 66 callersMethodfail

Record that this query failed during planning.

core/iox_query/src/query_log.rs:1161

↓ 66 callersMethodfield

(&self, field_args: WindowUDFFieldArgs<'_>)

core/iox_query_influxql/src/window/elapsed.rs:39

↓ 66 callersMethodhttp_client

(&self)

influxdb3/tests/server/mod.rs:747

↓ 66 callersFunctionrewrite_select_statement

Test implementation that converts `Select` to `SelectStatement` so that it can be converted back to a string.

core/iox_query_influxql/src/plan/rewriter.rs:2152

↓ 65 callersMethodpush

Push an item into the queue with a specific time.

influxdb3_write/src/async_collections.rs:37

↓ 64 callersMethodand

Return `self AND other`

core/influxdb_influxql_parser/src/expression/conditional.rs:140

↓ 64 callersMethodas_str

Convert the enum to its string representation

core/flightsql/src/lib.rs:29

↓ 63 callersFunctionassert_histogram_hit

( metrics: &metric::Registry, name: &'static str, attr: [(&'static str, &'static str); N], )

core/object_store_metrics/src/test_utils.rs:7

↓ 63 callersMethodcontains

(&self, perm: u16)

influxdb3_authz/src/permissions.rs:306

↓ 63 callersMethodget_by_name

(&self, name: &str)

influxdb3_catalog/src/catalog/versions/v2.rs:2961

↓ 63 callersMethodsend

Record a send action. This may async-block if the rate limit was hit until the it is OK to send a message again. It is safe to cancel this method.

core/trace_exporters/src/rate_limiter.rs:28

↓ 63 callersMethodwith_id

(mut self, id: u128)

core/iox_query/src/test.rs:568

↓ 63 callersMethodwith_plugin_dir

Set the plugin dir for this [`TestServer`]

influxdb3/tests/server/mod.rs:160

↓ 62 callersMethodrepo

(&self)

influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:34

↓ 61 callersMethodfinish

Note: may be able to use something simpler than StructArray here, this is just based directly on the arrow docs: https://docs.rs/arrow/latest/arrow/ar

influxdb3_query_executor/src/lib.rs:425

↓ 61 callersMethodnext

(&self)

influxdb3_catalog/src/catalog.rs:109

↓ 60 callersMethodcolumn_or_create

( &mut self, table_name: &str, column_name: &str, column_type: InfluxColumnTyp

influxdb3_catalog/src/catalog/versions/v2/update.rs:1924

↓ 60 callersMethodis_empty

(&self)

influxdb3_wal/src/lib.rs:477

↓ 60 callersMethodjoin

Blocks until all futures associated with the tracker have been dropped and no more can be created

core/tracker/src/task.rs:453

↓ 60 callersMethodmock_next

(self: Arc<Self>, call: MockCall)

core/object_store_mock/src/lib.rs:373

↓ 58 callersFunctionexpect

Transforms a [`nom::Err::Error`] to a [`nom::Err::Failure`] using `message` for additional context.

core/influxdb_influxql_parser/src/internal.rs:82

↓ 58 callersMethodlen

Return the number of parameters in this collection.

core/iox_query_params/src/params.rs:132

↓ 57 callersMethodas_expr

(&self)

core/datafusion_util/src/lib.rs:67

↓ 57 callersMethodcreate_trigger

( &self, db_name: impl Into<String>, trigger_name: impl Into<String>, plugin_f

influxdb3/tests/cli/api.rs:650

↓ 57 callersFunctionempty_snapshot

(sequence: u64)

influxdb3_catalog/src/catalog/migrations/v3/tests.rs:54

↓ 57 callersMethodfirst

(call: &'a Call)

core/iox_query_influxql/src/plan/planner/select.rs:291

↓ 57 callersFunctionselect_statement_info

Gather information about the semantics of a [`SelectStatement`] and verify the `SELECT` projection clause is semantically correct. Upon success the f

core/iox_query_influxql/src/plan/rewriter.rs:1706

↓ 57 callersFunctionsynthesize_records

Synthesize the v3 records that reconstruct `snapshot`'s state. Returns a [`RecordBatch`] stamped with the snapshot's sequence number. Applying the ba

influxdb3_catalog/src/catalog/migrations/v3.rs:154

↓ 57 callersMethodtake

Transfer ownership of the buffered record batches to the caller for processing. Resets the memory reservation since we no longer hold these batches.

core/iox_query/src/exec/gapfill/buffered_input.rs:86

↓ 56 callersMethodmax

()

core/generated_types/src/lib.rs:55

↓ 55 callersMethodbuild

(self)

core/iox_query/src/physical_optimizer/sort/lexical_range.rs:102

↓ 54 callersMethodas_any

(&self)

core/iox_query/src/physical_optimizer/projection_pushdown.rs:1965

↓ 53 callersMethodoutput

(&self, catalog: &InnerCatalog)

influxdb3_catalog/src/catalog/versions/v3/ops/role.rs:67

↓ 52 callersMethodcatalog

(&self)

influxdb3_write/src/lib.rs:961

↓ 52 callersMethodid

Return the identifier of the column.

influxdb3_catalog/src/catalog/versions/v3/schema/column.rs:60

↓ 52 callersFunctionto_string

--- Test infrastructure --

core/iox_query/src/provider/overlap.rs:378

↓ 51 callersMethodas_ref

(&self)

core/data_types/src/namespace_name.rs:185

↓ 51 callersMethodlen

Return a count of items in the queue.

core/object_store_mem_cache/src/cache_system/s3_fifo_cache/fifo.rs:29

↓ 51 callersMethodproject

adds a ProjectionExec node to the plan with the specified columns

core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2419

↓ 51 callersFunctionrun_case

Runs the expr using `run_plan` and compares the result to `expected`

core/query_functions/src/selectors.rs:1272

↓ 51 callersMethodtake

Take the contents of this recorder returning a new recorder From this point on `self` will behave as if it were created with no span

core/trace/src/span.rs:339

↓ 50 callersFunctionmake_statement

( database: &Arc<dyn QueryDatabase>, ctx: &Arc<IOxSessionContext>, log: &Arc<QueryLog>

core/iox_v1_query_api/src/response.rs:505

↓ 49 callersMethodinsert

Insert a new resource to the repository

influxdb3_catalog/src/catalog/versions/v2/update.rs:2126

↓ 49 callersMethodwith_tag_column

core/iox_query/src/test.rs:612

↓ 48 callersFunctionassert_u64histogram_hits

( metrics: &metric::Registry, name: &'static str, attr: [(&'static str, &'static str); N], exp

core/object_store_metrics/src/test_utils.rs:80

↓ 48 callersFunctionchannel

Create channel that can be used ONCE to send a [`Slice`]. The sender may choose not to accept the transfer (by not calling [`accept`](BufferSender::a

core/object_store_mem_cache/src/buffer_channel.rs:24

↓ 48 callersMethodcontains

Return true if this column appears anywhere in the sort key.

core/schema/src/sort.rs:114

↓ 48 callersMethodname

return a human readable name for this result

core/tracker/src/task.rs:191

↓ 48 callersMethodnext

(&self)

influxdb3_wal/src/lib.rs:492

↓ 48 callersMethodpush

(&mut self, row_status: RowStatus)

core/iox_query/src/exec/gapfill/algo.rs:457

↓ 48 callersMethodrequire_by_id

Get a resource by id, or return `NotFound` if it does not exist.

influxdb3_catalog/src/repository.rs:117

↓ 48 callersMethodsoft_delete_database

( &self, db_name: &str, hard_delete_time: HardDeletionTime, hard_delete_scope:

influxdb3_catalog/src/catalog/versions/v2/update.rs:419

↓ 47 callersMethodas_any

(&self)

core/iox_query/src/exec/sleep.rs:216

↓ 47 callersMethodtimestamp_millis

Returns the number of non-leap-milliseconds since January 1, 1970 UTC

core/iox_time/src/lib.rs:129

↓ 46 callersMethodassert

(&self)

core/iox_query_influxql_rewrite/src/lib.rs:236

↓ 46 callersFunctionevaluate_type

( s: &dyn SchemaProvider, expr: &str, from: &[&str], )

core/iox_query_influxql/src/plan/expr_type_evaluator.rs:513

↓ 46 callersMethodschema

(&self, s: &dyn SchemaProvider)

core/iox_query_influxql/src/plan/ir.rs:168

↓ 45 callersMethodas_nanos

(&self)

influxdb3_wal/src/lib.rs:203

↓ 45 callersMethodget_by_name

(&self, name: &str)

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:161

↓ 45 callersMethodlen

(&self)

influxdb3_catalog/src/format/record.rs:203

↓ 45 callersMethodpush

Append this [`Value`] to the null mask. This call is amortised `O(1)` for [`Value::Null`] and always `O(1)` and allocation free for [`Value::NonNull`

core/table_batch/src/builder/null_mask.rs:83

↓ 45 callersMethodurl

URL to given key.

core/catalog_cache/src/api/client.rs:197

↓ 45 callersMethodwith_time_column

core/iox_query/src/test.rs:693

↓ 44 callersMethodas_array

Produce an arrow [`ArrayRef`] from this column for the sake of producing [`RecordBatch`]es Accepts `n_non_expired` to indicate how many of the first

influxdb3_cache/src/last_cache/cache.rs:1051

↓ 44 callersFunctionchunk

(id: u128)

core/iox_query/src/physical_optimizer/dedup/test_util.rs:54

↓ 44 callersMethodinsert

Inserts a parameter name-value pair into the map. If the map did not have this parameter name present, `None` is returned. If the map did have the p

core/iox_query_params/src/params.rs:171

↓ 44 callersMethodlen

Returns the number of rows in this column

core/mutable_batch/src/column.rs:189

↓ 44 callersFunctionread_body_bytes_for_tests

FOR TESTS ONLY: Read the full response as bytes. # Panics Panics if reading any frame fails! Non-test code should be processing the stream and propa

core/iox_http_util/src/lib.rs:128

↓ 44 callersMethodset

Sets the value of this U64Gauge

core/metric/src/gauge.rs:17

↓ 44 callersMethodtake

(&mut self)

influxdb3_catalog/src/format/apply.rs:195

↓ 43 callersMethodget

Retrieve the value of a parameter with the given name.

core/iox_query_params/src/params.rs:147

↓ 43 callersFunctionparse

Parse the body of a Prometheus metric endpoint. # Panics Panics if a duplicate value is observed for the same `(name, labels)` tuple.

core/test_helpers/src/prometheus.rs:249

↓ 43 callersMethodreplace

Replaces the actual value in the receiver by the value given in parameter, returning the old value if present.

core/influxdb_influxql_parser/src/common.rs:546

↓ 42 callersFunctionassert_counter_value

( metrics: &metric::Registry, name: &'static str, attr: [(&'static str, &'static str); N], val

core/object_store_metrics/src/test_utils.rs:63

↓ 42 callersMethodget

Retrieve the given value from the remote cache Returns `None` if value is not present in a quorum of replicas Returns [`Error::Quorum`] if cannot est

core/catalog_cache/src/api/quorum.rs:115

↓ 42 callersMethodget_or_fetch

Get an existing key or start a new fetch process. Returns a [`CacheState`] that contains either the cached value or a future that resolves to the val

core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:338

↓ 42 callersMethodis_empty

Return `true` if the map is empty.

core/iox_query/src/pruning_oracle.rs:105

↓ 42 callersMethoditer

Iterate over the names and columns.

core/data_types/src/columns.rs:79

↓ 42 callersMethodlen

Return the logical length of this [`NullMaskBuilder`] (total number of null and non-null [`Value`] encoded). This call is always `O(1)`. Note: the p

core/table_batch/src/builder/null_mask.rs:155

↓ 42 callersFunctionlit_timestamptz_nano

Create a timestamp literal for the given UTC nanosecond offset in the timezone specified by [TIME_DATA_TIMEZONE]. N.B. If [TIME_DATA_TIMEZONE] specif

core/datafusion_util/src/lib.rs:479

↓ 42 callersFunctionpath

()

core/object_store_mock/src/lib.rs:605

↓ 42 callersMethodquery_sql

(&self, database: impl Into<String>)

influxdb3/tests/cli/api.rs:376

↓ 42 callersMethodvalues

(&self)

influxdb3_cache/src/last_cache/cache.rs:520

↓ 41 callersMethoddb_name_to_id

(&self, db_name: &str)

influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:696

↓ 41 callersMethoditer

(&self)

influxdb3_catalog/src/catalog/versions/v2/legacy.rs:116

↓ 41 callersMethodslice

Update this cursor to reflect that `offset` older rows are being sliced off from the buffered input.

core/iox_query/src/exec/gapfill/algo.rs:437

↓ 41 callersMethodwith_sql

(mut self, query: impl Into<String>)

influxdb3/tests/cli/api.rs:394

↓ 40 callersMethodas_str

(&self)

influxdb3_catalog/src/log/versions/v2.rs:246

↓ 40 callersMethodbytes

Number of bytes.

influxdb3_clap_blocks/src/memory_size.rs:32

↓ 40 callersMethodelapsed

(&self)

influxdb3_catalog/src/catalog/versions/v3/catalog.rs:371

↓ 40 callersMethodextend

Pads with empty strings to reach length

core/arrow_util/src/string.rs:111

↓ 40 callersMethodlen

Returns the number of elements in this list

core/data_types/src/snapshot/list.rs:131

↓ 40 callersFunctionstring

( delimiter: char, unterminated_message: &'static str, literal: T, escaped: U, )

core/influxdb_influxql_parser/src/string.rs:102

↓ 40 callersMethodtimestamp

Returns the number of seconds since January 1, 1970 UTC

core/iox_time/src/lib.rs:104

↓ 40 callersMethodwith_timestamp_min_max

(mut self, min: i64, max: i64)

core/iox_query/src/test.rs:730

↓ 39 callersMethodas_store

(self: Arc<Self>)

core/object_store_mock/src/lib.rs:391

↓ 39 callersMethodcreate_database

Create a new database with default options.

influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1648

↓ 39 callersMethodnext

Return next level, if there is one. This is used for iterating a range, not determining the target level.

core/data_types/src/lib.rs:101

← previous next →101–200 of 11,906, ranked by callers