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

Methodupdated_at_ns

(&self)

influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:171

Functionupdated_at_ns_picks_latest_timestamp

()

influxdb3_catalog/src/catalog/versions/v3/schema/node/node_state_tests.rs:60

Methodupgrade_safe

Create flags with UPGRADE_SAFE set.

influxdb3_catalog/src/format/mod.rs:157

Methodupsert_schema

Upsert the schema for a namespace and table. Returns the schema for the specified table after applying the upsert.

core/influxdb_iox_client/src/client/schema.rs:51

Functionurlencode

Common Collection of helper functions Serialize to application/x-www-form-urlencoded syntax

core/influxdb2_client/src/common.rs:6

Methoduse_legacy_tokens

Whether to use new or old token format true - use name-only token format (legacy) false - use name-and-id token format

core/test_helpers_authz/src/authz.rs:66

Functionuser_describe_grant_confers_database_visibility_but_not_read

()

influxdb3_authz/src/authorizer/tests.rs:834

Functionuser_permission_covers_matching_action

()

influxdb3_authz/src/role/tests.rs:80

Functionuser_permission_does_not_cover_different_action

()

influxdb3_authz/src/role/tests.rs:87

Functionuser_provided_value_source_only_matches_cli_and_env

()

influxdb3/src/lib_tests.rs:5

Methoduses_window_frame

(&self)

core/iox_query_influxql/src/window/percent_row_number.rs:98

Methoduses_window_frame

(&self)

core/iox_query_influxql/src/window/integral.rs:244

Methoduses_window_frame

(&self)

core/iox_query_influxql/src/window/cumulative_sum.rs:84

Methoduses_window_frame

(&self)

core/iox_query_influxql/src/window/moving_average.rs:118

Methoduses_window_frame

(&self)

core/query_functions/src/non_negative.rs:147

Methoduses_window_frame

(&self)

core/query_functions/src/derivative.rs:228

Methoduses_window_frame

(&self)

core/query_functions/src/difference.rs:91

Functionutc

()

core/query_functions/src/tz.rs:235

Functionutc_origin_conversion

()

core/query_functions/src/date_bin_wallclock.rs:848

Methoduuid_from_path

extract file uuid from file path: "database_id/table_id/parition_hash_id/file_uuid.parquet"

core/parquet_file/src/lib.rs:130

Functionv1_password_parameter

()

influxdb3/tests/server/auth.rs:287

Functionv1_query_influxql_with_format

()

influxdb3_client/src/tests.rs:312

Functionv1_query_influxql_with_params

()

influxdb3_client/src/tests.rs:344

Methodv1_ref

(&self)

influxdb3_write/src/lib.rs:155

Functionvalid_azure_config

()

influxdb3_clap_blocks/src/object_store/tests.rs:288

Functionvalid_file_config

()

influxdb3_clap_blocks/src/object_store/tests.rs:327

Functionvalid_google_config

()

influxdb3_clap_blocks/src/object_store/tests.rs:212

Functionvalid_s3_config

()

influxdb3_clap_blocks/src/object_store/tests.rs:68

Functionvalid_s3_endpoint_url

()

influxdb3_clap_blocks/src/object_store/tests.rs:125

Functionvalid_s3_url_signer

()

influxdb3_clap_blocks/src/object_store/tests.rs:170

Functionvalidate

(#[case] tc: TestCase)

influxdb3_write/src/table_index/test_persisted_snapshot_conversion.rs:574

Functionvalidate_auth_header

(header: HeaderValue)

influxdb3_server/src/http.rs:2229

Functionvalidate_auth_header

(header: &HeaderValue)

core/iox_v1_query_api/src/handler.rs:652

Functionvalidate_aws_credential_reloader

()

influxdb3_clap_blocks/src/object_store/tests.rs:425

Methodvalidate_db_id

(&self, db_id: &str)

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

Methodvalidate_db_id

(&self, db_id: &str)

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

Methodvalidate_insertion

( &self, col_name: &str, col_type: InfluxColumnType, )

core/schema/src/builder.rs:256

Functionvalidate_reauthing_object_store

()

influxdb3_clap_blocks/src/object_store/tests.rs:584

Functionvalidate_table_index_snapshot_path_regex

()

influxdb3_write/src/paths/test.rs:5

Functionvalidate_table_index_snapshot_sequence_number_extraction

()

influxdb3_write/src/paths/test.rs:35

Functionvalue_buf_rejects_heterogeneous_types

()

core/table_batch/src/builder/column_writer/mod.rs:268

Functionvalue_buf_rejects_same_underlying_type_but_different_semantic_type

()

core/table_batch/src/builder/column_writer/mod.rs:277

Functionvar_ref_data_type_to_data_type

Map a field-like data type to an equivalent Arrow data type.

core/iox_query_influxql/src/plan/var_ref.rs:6

Methodvariant

Variant as string. This can be used for logging and metrics.

core/catalog_cache/src/lib.rs:78

Functionverbose_count

()

core/trogging/src/lib.rs:462

Functionverbose_v_not_expanded

()

influxdb3/src/lib_tests.rs:169

Functionverbose_vv_expands

()

influxdb3/src/lib_tests.rs:139

Functionverbose_vv_expansion_disabled

()

influxdb3/src/lib_tests.rs:177

Functionverbose_vvv_expands

()

influxdb3/src/lib_tests.rs:149

Functionverbose_vvvv_expands

()

influxdb3/src/lib_tests.rs:158

Methodverification

Create new Error::Verification.

core/authz/src/iox_authorizer.rs:123

Functionverification_error_returns_503

()

core/iox_http/src/write/single_tenant/mod.rs:684

Functionverify_checkpoint_exists

Helper to verify checkpoint count in object store

influxdb3_write/src/write_buffer/tests.rs:3035

Functionverify_column_transformations

(lines: Vec<ParsedLine<'static>>)

core/partition/src/traits.rs:242

Functionverify_duplicate_tag_or_field_returns_error

()

influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:477

Functionverify_error_from_tonic_status

()

core/authz/src/lib.rs:47

Functionverify_snapshot

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:1487

Functionverify_tags_fields_are_valid

()

influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:172

Functionverify_tags_fields_cannot_be_named_reserved_columns

()

influxdb3_catalog/src/catalog/versions/v2/update/tests.rs:404

Functionverify_upgraded_log_exists

Helper to verify UpgradedLog exists in v1 catalog

influxdb3_catalog/src/catalog/migrations/tests.rs:81

Functionverify_v2_checkpoint_exists

Helper to verify v2 checkpoint exists

influxdb3_catalog/src/catalog/migrations/tests.rs:75

Functionvirtual_col_also_in_input

()

core/iox_query/src/provider/adapter.rs:475

Functionvirtual_col_has_wrong_type

()

core/iox_query/src/provider/adapter.rs:451

Methodvisit_seq

(self, mut seq: A)

influxdb3_id/src/serialize.rs:205

Functionwaiters_tracking

()

object_store_limit/src/tests.rs:52

Functionwal_flush_success_variant_holds_its_fields

()

influxdb3_internal_api/src/sll/tests.rs:4

Functionwal_replay_concurrency_limit_default

()

influxdb3/src/commands/serve.rs:189

Methodwarm

Warm the local cache by performing quorum reads from the other two replicas. From the first replica we will only fetch the version. From the second o

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

Methodwarn

(&self, py: Python<'_>, args: &Bound<'_, PyTuple>)

influxdb3_py_api/src/system_py.rs:88

Functionwarn_not_expanded

()

influxdb3/src/lib_tests.rs:123

Methodwas_not_pruned

Called when a chunk was not pruned.

core/iox_query/src/pruning.rs:62

Methodwas_pruned

Called when the specified chunk was pruned

core/iox_query/src/pruning.rs:59

Functionwhitespace

(input: &str)

core/influxdb_line_protocol/src/lib.rs:941

Methodwildcard

()

influxdb3_authz/src/permissions.rs:129

Functionwindow_bounds_udf

Implement the window bounds function as a DataFusion UDF where each of the two `WindowDuration` argument has been encoded as three distinct arguments,

core/query_functions/src/window.rs:83

Methodwith_alignment

(len: usize, alignment: NonZeroUsize)

core/linear_buffer/src/linear_buffer.rs:92

Functionwith_all_column_types

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:358

Functionwith_all_non_key_columns

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:592

Functionwith_bool

(mut column: PbColumn, values: Vec<bool>, nulls: Vec<u8>)

core/mutable_batch_pb/src/decode.rs:508

Methodwith_capacity

(size: usize)

influxdb3_id/src/serialize.rs:47

Methodwith_capacity

Construct an empty [`BitSet`] with a pre-allocated capacity for `n` bits.

core/arrow_util/src/bitset.rs:27

Methodwith_capacity

(keys: usize, values: usize)

core/arrow_util/src/string.rs:42

Methodwith_capacity

(keys: usize, values: usize)

core/arrow_util/src/dictionary.rs:64

Methodwith_capacity

Initialise a [`SequenceNumberSet`] that is pre-allocated to contain up to `n` elements without reallocating.

core/data_types/src/sequence_number_set.rs:68

Methodwith_capacity

(capacity: usize)

core/schema/src/sort.rs:26

Methodwith_capacity

(n: usize)

core/schema/src/builder.rs:42

Methodwith_chunk

Add a test chunk to the database

core/iox_query/src/test.rs:195

Functionwith_complex_column_mapping

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:1044

Methodwith_descending

set SortOptions::descending flag

core/iox_query/src/physical_optimizer/sort/extract_ranges.rs:626

Methodwith_error

specify that any call should result in an error with the message specified

core/iox_query/src/test.rs:591

Functionwith_explicit_columns

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:521

Methodwith_exprs_and_inputs

( &self, exprs: Vec<Expr>, inputs: Vec<LogicalPlan>, )

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

Methodwith_exprs_and_inputs

(&self, exprs: Vec<Expr>, inputs: Vec<LogicalPlan>)

core/iox_query/src/exec/split.rs:140

Methodwith_exprs_and_inputs

( &self, mut series_expr: Vec<Expr>, inputs: Vec<LogicalPlan>, )

core/iox_query/src/exec/gapfill/mod.rs:258

Functionwith_f64

(mut column: PbColumn, values: Vec<f64>, nulls: Vec<u8>)

core/mutable_batch_pb/src/decode.rs:500

Functionwith_field_families

()

influxdb3_catalog/src/catalog/migrations/v2/tests.rs:277

Methodwith_file_id_start

(mut self, start: u64)

influxdb3_write/src/table_index/test_table_index_operations.rs:61

Methodwith_format

Specify the [`QueryFormat`] of the returned `Bytes`

influxdb3_client/src/lib.rs:1569

Functionwith_group

()

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

Functionwith_i64

(mut column: PbColumn, values: Vec<i64>, nulls: Vec<u8>)

core/mutable_batch_pb/src/decode.rs:484

← previous next →11,701–11,800 of 11,906, ranked by callers