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

Functioncreate_database_rejected_at_db_limit

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1734

Functioncreate_database_round_trip

()

influxdb3_catalog/src/format/records/database/tests.rs:17

Functioncreate_database_tables

Helper function to create a SerdeVecMap with database tables

influxdb3_write/src/table_index/test_persisted_snapshot_conversion.rs:49

Methodcreate_distinct_cache

( &self, db_name: &str, table_name: &str, node_spec: ApiNodeSpec, cach

influxdb3_catalog/src/catalog/versions/v1/update.rs:473

Functioncreate_distinct_cache_round_trip

()

influxdb3_catalog/src/format/records/cache/tests.rs:45

Methodcreate_eventual_mode_cache_request

Create a new [`CacheRequest::Eventual`] for eventually loading the path passed in, by doing a GET request from object store for the path. Since it is

influxdb3_cache/src/parquet_cache/mod.rs:123

Methodcreate_evict_from_cache_request

Create a cache eviction request

influxdb3_cache/src/parquet_cache/mod.rs:139

Methodcreate_for_test

(path: impl Into<String>)

influxdb3_write/src/lib.rs:376

Methodcreate_immediate_mode_cache_request

Create a new [`CacheRequest::Immediate`] for loading the bytes passed in immediately into the cache.

influxdb3_cache/src/parquet_cache/mod.rs:113

Functioncreate_label

()

core/influxdb2_client/src/api/label.rs:203

Functioncreate_label_opt

()

core/influxdb2_client/src/api/label.rs:230

Methodcreate_last_cache

( &self, db_name: &str, table_name: &str, node_spec: ApiNodeSpec, cach

influxdb3_catalog/src/catalog/versions/v1/update.rs:559

Functioncreate_last_cache_round_trip

()

influxdb3_catalog/src/format/records/cache/tests.rs:77

Functioncreate_login_identity_oauth_roundtrip

()

influxdb3_catalog/src/enterprise/format/records/login_identity_oauth/tests.rs:8

Functioncreate_login_identity_username_password_roundtrip

()

influxdb3_catalog/src/format/records/user/tests.rs:80

Methodcreate_named_admin_token

Create a named admin token. NOTE(tjh): this was previously called create_named_admin_token_with_permissions but was renamed here because the method do

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

Methodcreate_named_admin_token_with_permission

( &self, token_name: String, expiry_secs: Option<u64>, )

influxdb3_catalog/src/catalog/versions/v1.rs:351

Methodcreate_namespace

Create a namespace `retention_period_ns` is the the retention period in nanoseconds, measured from `now()`. `None` represents infinite retention (i.e

core/influxdb_iox_client/src/client/namespace.rs:57

Methodcreate_oauth_login_identity

( &self, user_id: UserId, oauth_id: Arc<str>, )

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

Functioncreate_persisted_snapshot

Helper function to create a PersistedSnapshot

influxdb3_write/src/table_index/test_persisted_snapshot_conversion.rs:87

Methodcreate_processing_engine_trigger

( &self, db_name: &str, trigger_name: &str, plugin_filename: ValidPluginFilena

influxdb3_catalog/src/catalog/versions/v1/update.rs:681

Methodcreate_reader

( &self, partition_index: usize, partitioned_file: PartitionedFile, metadata_s

core/iox_query/src/physical_optimizer/cached_parquet_data.rs:131

Methodcreate_refresh_token

( &self, user_id: UserId, token_hash: Arc<str>, expires_at: i64, )

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

Functioncreate_refresh_token_roundtrip

()

influxdb3_catalog/src/format/records/user/tests.rs:123

Functioncreate_resource_scoped_token_round_trip

()

influxdb3_catalog/src/enterprise/format/records/token/tests.rs:34

Methodcreate_role

( &self, name: influxdb3_authz::role::RoleName, description: Option<influxdb3_authz::r

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

Functioncreate_role_database_permission_roundtrip

()

influxdb3_catalog/src/format/records/role/tests.rs:54

Functioncreate_role_no_description_roundtrip

()

influxdb3_catalog/src/format/records/role/tests.rs:39

Functioncreate_role_op

()

influxdb3_catalog/src/catalog/versions/v3/ops/role/tests.rs:8

Functioncreate_role_roundtrip

()

influxdb3_catalog/src/format/records/role/tests.rs:24

Methodcreate_shared

Create a new server fixture and wait for it to be ready. This is called "create" rather than new because it is async and waits. The shared database ca

core/influxdb2_client/tests/common/server_fixture.rs:67

Methodcreate_single_use

Create a new server fixture and wait for it to be ready. This is called "create" rather than new because it is async and waits. The database is left u

core/influxdb2_client/tests/common/server_fixture.rs:104

Functioncreate_snapshot_byte_layout_compat_entry_then_flat_records

()

influxdb3_catalog/src/format/apply/tests.rs:284

Functioncreate_snapshot_with_max_time

Create a test snapshot with a specific max_time for month grouping tests

influxdb3_write/src/persister/tests.rs:692

Methodcreate_stash

Create a 2-element array containing a null value and the value from `input_aggr_array` at `offset` for use with the [`interleave`](arrow::compute::int

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

Methodcreate_table

Create a table

core/influxdb_iox_client/src/client/table.rs:70

Functioncreate_table_auto_create_db_rejected_at_db_limit

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1768

Functioncreate_table_rejected_at_table_limit

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1754

Functioncreate_table_round_trip

()

influxdb3_catalog/src/format/records/table/tests.rs:32

Methodcreate_token_for

Create a new token with the requested permissions. Actions are specified by name, the currently supported actions are: - `"ACTION_READ_SCHEMA"` - `"A

core/test_helpers_authz/src/authz.rs:93

Methodcreate_token_with_permission

( &self, all_permissions: Vec<PermissionDetailsSpec>, token_name: String, expi

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

Methodcreate_token_with_permission

( &self, all_permissions: Vec<PermissionDetailsSpec>, token_name: String, expi

influxdb3_catalog/src/catalog/versions/v1/enterprise.rs:27

Methodcreate_token_with_permission_and_hash

Create a token with permissions using a pre-computed hash

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

Functioncreate_trigger_round_trip

()

influxdb3_catalog/src/format/records/trigger/tests.rs:33

Methodcreate_user

(&self, display_name: Option<Arc<str>>)

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

Functioncreate_user_no_display_name_roundtrip

()

influxdb3_catalog/src/format/records/user/tests.rs:33

Functioncreate_user_op

()

influxdb3_catalog/src/catalog/versions/v3/ops/user/tests.rs:8

Functioncreate_user_roundtrip

()

influxdb3_catalog/src/format/records/user/tests.rs:21

Methodcreate_username_login_identity

( &self, user_id: UserId, username: Arc<str>, password_hash: Arc<str>,

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

Functioncreate_users

()

core/influxdb2_client/tests/setup.rs:97

Functioncreates_cache_with_multiple_tags

()

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

Functioncreates_cache_with_single_tag

()

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

Functioncriterion_benchmark

(c: &mut Criterion)

influxdb3_sys_events/benches/store_benchmark.rs:315

Functioncross_boundary_takes_multipart_branch

()

object_store_utils/src/adaptive_put.rs:188

Functioncurrent_node_errors_when_unregistered

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2509

Functioncurrent_snapshot_not_rewritten_at_startup

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1557

Methodcurrently_loading

Check if given key is currently loading.

core/object_store_mem_cache/src/cache_system/loader.rs:177

Methodcurrently_loading

Check if given key is currently loading.

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

Functioncustom_retry_condition

()

object_store_utils/src/retryable_object_store/tests.rs:590

Functioncustom_table_template_with_time_specified_overrides_namespace_template

()

core/data_types/src/partition_template.rs:2494

Methoddata

(&self)

core/iox_query/src/ingester.rs:245

Methoddata_source_exec_input

Return stream of data read from parquet file Inputs for [`DataSourceExec`]. See [`DataSourceExecInput`] for more information. [`DataSourceExec`]: da

core/parquet_file/src/chunk.rs:68

Methoddata_source_exec_parquet

Create a new builder to scan the parquet file with the specified range

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

Methoddata_source_exec_parquet_non_overlapped_chunks

Create a parquet-based `DataSourceExec` with a given number of chunks

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

Methoddata_source_exec_parquet_overlapped_chunks

Create a parquet-based `DataSourceExec` with a given number of chunks

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

Functiondata_source_exec_parquet_with_ranges

( files: &[(&'static str, (i64, i64))], )

core/iox_query/src/physical_optimizer/limits.rs:334

Methoddata_type_and_nullable

Returns both the data type and nullability of this expression. This is a convenience method that combines `get_type` and `nullable`.

core/iox_query/src/exec/series_limit/logical.rs:156

Methoddatabase

(ids: Vec<DbId>)

influxdb3_authz/src/permissions.rs:125

Methoddatabase

(&self)

core/iox_query_influxql_rewrite/src/lib.rs:45

Methoddatabase

( time_ns: i64, database_id: DbId, database_name: impl Into<Arc<str>>, ops: Ve

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

Methoddatabase

( time_ns: i64, database_id: DbId, database_name: impl Into<Arc<str>>, ops: Ve

influxdb3_catalog/src/log/versions/v3.rs:68

Methoddatabase

( time_ns: i64, database_id: DbId, database_name: impl Into<Arc<str>>, ops: Ve

influxdb3_catalog/src/log/versions/v4.rs:132

Functiondatabase_carries_retention_period_duration

()

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

Methoddatabase_count_limit

(&self, current: &CurrentCatalogUsage)

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

Functiondatabase_emits_create_with_name_and_id

()

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

Functiondatabase_or_deletion_status

( db_schema: Option<Arc<DatabaseSchema>>, time_provider: &Arc<dyn TimeProvider>, )

influxdb3_catalog/src/catalog/versions/v3/deletes.rs:45

Functiondatabase_permission_all_resource_covers_specific_resource

()

influxdb3_authz/src/role/tests.rs:44

Functiondatabase_permission_covers_matching_action_and_resource

()

influxdb3_authz/src/role/tests.rs:31

Functiondatabase_permission_does_not_cover_different_action

()

influxdb3_authz/src/role/tests.rs:70

Functiondatabase_permission_specific_does_not_cover_different_id

()

influxdb3_authz/src/role/tests.rs:57

Functiondatabase_with_triggers_emits_create_trigger_per_trigger

()

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

Functiondatafusion_udtf_predicate_conversion

()

influxdb3_cache/src/last_cache/tests.rs:1249

Functiondate_bin_gapfill

(stride: Expr, source: Expr, origin: Expr)

core/query_functions/src/gapfill.rs:410

Functiondate_bin_gapfill_errs

()

core/query_functions/src/gapfill.rs:422

Functiondate_bin_gapfill_origin

()

core/iox_query/src/analyzer/handle_gapfill.rs:1010

Functiondate_bin_gapfill_simple

()

core/iox_query/src/analyzer/handle_gapfill.rs:982

Functiondb_2

()

influxdb3_write/src/table_index/test_table_index_operations.rs:176

Functiondb_and_node_lookups

()

influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2665

Methoddb_exists

(&self, db_id: DbId)

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

Methoddb_exists

(&self, db_id: DbId)

influxdb3_catalog/src/catalog/versions/v1.rs:860

Methoddb_id_to_name

(&self, db_id: &DbId)

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

Methoddb_name_to_id

(&self, db_name: &str)

influxdb3_catalog/src/catalog/versions/v1.rs:248

Methoddb_or_create

( &self, db_name: &str, retention_period: Option<Duration>, now_time_ns: i64,

influxdb3_catalog/src/catalog/versions/v1.rs:214

Methoddb_prefix

(host_prefix: &str, db_id: DbId)

influxdb3_write/src/paths.rs:248

Methoddb_schema

Snapshot of the database schema captured at begin time. Does not reflect uncommitted `table_or_create` / `column_or_create` mutations; observe new sta

influxdb3_catalog/src/catalog/versions/v3/transaction.rs:165

Methoddb_schema_by_id

(&self, db_id: &DbId)

influxdb3_catalog/src/catalog/versions/v1.rs:256

Methoddb_schema_cloned

(&self)

influxdb3_catalog/src/catalog/versions/v1/update.rs:808

Methoddb_schema_mut

(&mut self)

influxdb3_catalog/src/catalog/versions/v1/update.rs:1009

Functiondebug_filter_expanded_at_startup

()

influxdb3/tests/cli/log_filter.rs:4

Functiondebug_filter_not_expanded_when_disabled

()

influxdb3/tests/cli/log_filter.rs:15

← previous next →5,601–5,700 of 11,906, ranked by callers