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

Methodreporter

Gets the CumulativeGauge this CumulativeRecorder is associated with

core/metric/src/cumulative.rs:64

Functionreproduce_schema_bug_in_data_source_exec

()

core/iox_query/src/provider/physical.rs:596

Methodrequest_send

(method: Method, url: impl Into<String>, source: reqwest::Error)

influxdb3_client/src/lib.rs:112

Functionrequest_stop_idempotent_when_already_stopping

()

influxdb3_catalog/src/format/records/node/tests.rs:359

Functionrequest_stop_no_op_when_stopped

()

influxdb3_catalog/src/format/records/node/tests.rs:382

Methodrequest_stop_node

Request a graceful stop for a node, driving its state from `Running` to `Stopping`. The target node finishes its in-flight work and then writes an `Ac

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

Functionrequest_stop_node_round_trip

()

influxdb3_catalog/src/format/records/node/tests.rs:257

Functionrequest_stop_rejected_when_not_running

()

influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:372

Functionrequest_stop_transitions_running_to_stopping

()

influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:355

Functionrequest_stop_transitions_running_to_stopping

()

influxdb3_catalog/src/format/records/node/tests.rs:321

Methodrequests

get a copy of the requests that were made using this mock

core/influxdb_iox_client/src/client/write.rs:506

Methodrequire_by_name

Get a resource by name, or return `NotFoundByName` if it does not exist.

influxdb3_catalog/src/repository.rs:125

Methodrequired

(field: impl Into<String>)

core/ingester_query_grpc/src/lib.rs:47

Methodrequired

(field: impl Into<String>)

core/generated_types/src/google.rs:131

Methodrequired_input_distribution

Always require a single input (eventually we might imagine running this on multiple partitions concurrently to compute the splits in parallel, but not

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

Methodrequired_input_distribution

(&self)

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

Methodrequired_input_distribution

(&self)

core/iox_query/src/provider/progressive_eval.rs:164

Methodrequired_input_distribution

(&self)

core/iox_query/src/provider/deduplicate.rs:306

Methodrequired_input_distribution

(&self)

core/iox_query/src/provider/reorder_partitions.rs:125

Methodrequired_input_ordering

(&self)

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

Methodrequired_input_ordering

(&self)

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

Methodrequired_input_ordering

(&self)

core/iox_query/src/provider/progressive_eval.rs:172

Methodrequired_input_ordering

(&self)

core/iox_query/src/provider/reorder_partitions.rs:129

Methodrequires_quotes

Returns true if the identifier requires quotes.

core/influxdb_influxql_parser/src/identifier.rs:56

Functionreqwest_description

(e: &reqwest::Error)

influxdb3_client/src/lib.rs:96

Functionrerun_after_success_returns_already_migrated

()

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

Methodreservation

(&self)

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

Methodreserve

Unconditionally reserve sz bytes of memory. This marks the additional memory as being reserved, but cannot fail. This is used to tell the monitor abou

core/jemalloc_stats/src/monitor.rs:97

Methodreset

(&mut self)

influxdb3_telemetry/src/bucket.rs:33

Methodreset

(&mut self)

influxdb3_telemetry/src/metrics.rs:31

Methodreset_plugin_trigger_invocations

(&self)

influxdb3/src/commands/serve.rs:1525

Methodresolve

(&self, name: Name)

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

Functionresolves_registered_node

()

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

Methodresource_id_to_name

( &self, identifier: &ResourceIdentifier, )

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

Methodresource_id_to_name

( &self, identifier: &ResourceIdentifier, )

influxdb3_catalog/src/catalog/versions/v3/inner/enterprise.rs:85

Methodresource_id_to_name

( &self, identifier: &ResourceIdentifier, )

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

Functionresource_identifier_all_covers_everything

()

influxdb3_authz/src/role/tests.rs:9

Functionresource_identifier_covers_exact_match

()

influxdb3_authz/src/role/tests.rs:16

Functionresource_identifier_does_not_cover_different_id

()

influxdb3_authz/src/role/tests.rs:22

Functionresource_identifier_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:187

Methodresource_iter

(&self)

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

Methodresource_name_to_id

( &self, resource_type: ResourceType, names: &[String], )

influxdb3_catalog/src/catalog/versions/v3/inner/enterprise.rs:12

Methodresource_name_to_id

( &self, resource_type: ResourceType, names: &[String], )

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

Functionresource_scoped_token_emits_create_resource_scoped_token

()

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

Functionresource_scoped_token_expiry_i64_max_becomes_none

()

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

Functionresource_scoped_token_is_not_admin

()

influxdb3_authz/src/tests.rs:79

Functionresource_scoped_token_preserves_resource_names

()

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

Functionresource_try_from_proto

()

core/authz/src/permission.rs:250

Functionresource_try_into_proto

()

core/authz/src/permission.rs:291

Functionresource_type_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:179

Functionrestore_checkpoint_stays_consistent_under_concurrent_write

()

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

Functionrestore_errors_on_missing_replayed_sequence

()

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

Functionrestore_from_object_store_errors_on_missing_replayed_sequence

()

influxdb3_catalog/src/catalog/versions/v2/tests.rs:304

Functionrestore_from_object_store_uses_selected_backup_paths

()

influxdb3_catalog/src/catalog/versions/v2/tests.rs:178

Functionrestore_keeps_live_identity_when_backup_uuid_differs

()

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

Functionrestore_propagates_via_catch_up_to_peer

()

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

Methodrestore_staging_dir

Object-store directory under which a restore stages the backup's catalog checkpoint and log files. Deliberately a sibling of the versioned catalog di

influxdb3_catalog/src/object_store/versions/v3.rs:581

Methodrestore_user

( &mut self, user_id: UserId, display_name: Option<Arc<str>>, restored_at: i64

influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:172

Functionrestore_user_roundtrip

()

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

Functionrestore_uses_selected_backup_paths

()

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

Methodretention_delete_predicate

Return the delete predicate for data outside retention We need to only retain time >= retention_time. Thus we only need to set the range to MIN < time

core/data_types/src/lib.rs:1539

Methodretention_period

Returns the retention period if any

core/data_types/src/snapshot/namespace.rs:224

Functionretention_period_cutoff_map

()

influxdb3_catalog/src/catalog/versions/v2/tests.rs:1550

Functionretention_period_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:154

Functionretention_period_set_and_clear

()

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

Functionretention_period_set_and_clear_after_soft_delete

()

influxdb3_catalog/src/catalog/versions/v2/tests.rs:1674

Methodretention_time_ns

(&self)

core/iox_query/src/test.rs:229

Methodretention_time_ns

(&self)

influxdb3_query_executor/src/lib.rs:600

Methodretry_all_errors

Retry all errors.

core/backoff/src/lib.rs:192

Functionretry_exhaustion

()

object_store_utils/src/retryable_object_store/tests.rs:453

Methodreturn_field_from_args

(&self, args: ReturnFieldArgs<'_>)

core/query_functions/src/tz.rs:106

Methodreturn_type

(&self, _arg_types: &[DataType])

core/iox_query_influxql/src/plan/udf.rs:81

Methodreturn_type

Calculate the return type given the function signature. Spread always returns the same type as the input column.

core/iox_query_influxql/src/aggregate/spread.rs:47

Methodreturn_type

Calculate the return type given the function signature. Percentile always returns the same type as the input column.

core/iox_query_influxql/src/aggregate/percentile.rs:52

Methodreturn_type

(&self, arg_types: &[DataType])

core/iox_query_influxql/src/aggregate/mode.rs:55

Methodreturn_type

(&self, _arg_types: &[DataType])

core/query_functions/src/sleep.rs:34

Methodreturn_type

(&self, _arg_types: &[DataType])

core/query_functions/src/tz.rs:102

Methodreturn_type

(&self, arg_types: &[DataType])

core/query_functions/src/gapfill.rs:145

Methodreturn_type

(&self, args: &[DataType])

core/query_functions/src/date_bin_wallclock.rs:182

Methodreturn_type

(&self, _arg_types: &[DataType])

core/query_functions/src/to_timestamp.rs:53

Methodreturn_type

(&self, arg_types: &[DataType])

core/query_functions/src/coalesce_struct.rs:115

Methodreturn_type

(&self, arg_types: &[DataType])

core/query_functions/src/selectors.rs:380

Methodreturn_type

Return type of the aggregator. See [`make_struct_datatype`].

core/query_functions/src/selectors/type_handling.rs:115

Functionreturns_chunks_across_parquet_and_buffered_data

()

influxdb3_write/src/write_buffer/tests.rs:480

Methodrevoke_all_refresh_tokens_for_user

(&self, user_id: UserId)

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

Functionrevoke_all_refresh_tokens_for_user_roundtrip

()

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

Methodrevoke_refresh_token

(&self, token_hash: Arc<str>)

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

Functionrevoke_refresh_token_roundtrip

()

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

Functionrewrite

(expr: Expr)

core/predicate/src/rpc_predicate/column_rewrite.rs:84

Functionrole_admin_token_action_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:271

Functionrole_database_action_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:236

Functionrole_database_resource_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:277

Functionrole_name_empty_rejected

()

influxdb3_authz/src/role/tests.rs:144

Functionrole_name_invalid_chars_rejected

()

influxdb3_authz/src/role/tests.rs:155

Functionrole_name_max_length_accepted

()

influxdb3_authz/src/role/tests.rs:161

Functionrole_name_too_long_rejected

()

influxdb3_authz/src/role/tests.rs:149

Functionrole_name_valid

()

influxdb3_authz/src/role/tests.rs:137

Functionrole_permission_grant_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:283

Functionrole_role_action_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:263

Functionrole_token_action_encodings

()

influxdb3_catalog/src/format/records/types/tests.rs:246

← previous next →8,801–8,900 of 11,906, ranked by callers