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

↓ 1 callersMethodwrite_source

( &self, org_id: String, bucket_id: String, body: String, )

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

↓ 1 callersMethodwrite_source_info

(&mut self, event: &tracing::Event<'_>)

core/logfmt/src/lib.rs:158

↓ 1 callersMethodwrite_span_name

(&mut self, value: &str)

core/logfmt/src/lib.rs:149

↓ 1 callersMethodwrite_sync_to_db

Write line protocol to a specified database. Writes synchronously via the write buffer. Use `write` to write to the trigger's database. # Panics Us

influxdb3_py_api/src/system_py.rs:147

↓ 1 callersFunctionwrite_syspath_race_plugin

(root: &std::path::Path, i: usize)

influxdb3_processing_engine/src/plugins/tests.rs:406

↓ 1 callersMethodwrite_tag_key_to

(&self, w: W)

core/influxdb2_client/src/models/data_point.rs:237

↓ 1 callersMethodwrite_tag_value_to

(&self, w: W)

core/influxdb2_client/src/models/data_point.rs:252

↓ 1 callersMethodwrite_time_from_slice

Write the time typed column identified by `name`, with no nulls and copying directly from the given slice while filling in the spots not covered by th

core/mutable_batch/src/writer.rs:703

↓ 1 callersMethodwrite_timestamp_to

(&self, mut w: W)

core/influxdb2_client/src/models/data_point.rs:309

↓ 1 callersMethodwrite_to_db

Write line protocol to a specified database. Legacy api that batches writes and writes them at the end of plugin execution.

influxdb3_py_api/src/system_py.rs:119

↓ 1 callersMethodwrite_trailers

(&self, md: &mut HeaderMap)

core/service_grpc_flight/src/lib.rs:1602

↓ 1 callersMethodwrite_u64s_from_slice_with_mask

ALMOST Functionally equivalent to calling [`Self::write_u64`], but more performant when your values already exist in a slice that can be memcpy'd over

core/mutable_batch/src/writer.rs:415

↓ 1 callersFunctionwrite_v2_checkpoint_to_store

Helper to write a v2 checkpoint to object store

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

↓ 1 callersFunctionxdbc_type_info_data

()

core/flightsql/src/xdbc_type_info/mod.rs:63

↓ 1 callersMethodyield_batch

(self)

core/partition/src/lib.rs:318

Method__init__

(self, measurement: str)

influxdb3_py_api/src/line_builder/line_builder.py:30

Methodabort

(&mut self)

core/object_store_metrics/src/multipart_upload.rs:79

Methodabort

(&mut self)

object_store_limit/src/lib.rs:292

Functionaccept_accepted_send_receive

()

core/object_store_mem_cache/src/buffer_channel.rs:136

Methodaccept_compressed

Accept compression. This is a set and the server will pick one option from it (plus the option "no compression").

core/influxdb_iox_client/src/client/flight/mod.rs:246

Functionaccept_send_accepted_receive

()

core/object_store_mem_cache/src/buffer_channel.rs:153

Functionaccount_admin_all_covers_database_permission

()

influxdb3_authz/src/role/tests.rs:113

Functionaccount_admin_all_covers_role_permission

()

influxdb3_authz/src/role/tests.rs:127

Functionaccount_admin_all_covers_user_permission

()

influxdb3_authz/src/role/tests.rs:120

Functionaccount_admin_has_wildcard_permission

()

influxdb3_authz/src/role/tests.rs:169

Methodaccumulator

(&self, arg: AccumulatorArgs<'_>)

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

Methodaccumulator

(&self, arg: AccumulatorArgs<'_>)

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

Methodaccumulator

(&self, arg: AccumulatorArgs<'_>)

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

Methodaccumulator

(&self, arg: AccumulatorArgs<'_>)

core/query_functions/src/selectors.rs:384

Functionack_rejected_when_not_stopping

()

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

Functionack_stop_idempotent_when_already_stopped

()

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

Functionack_stop_ignored_when_running

()

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

Methodack_stop_node

Acknowledge that a stopping node has persisted its final snapshot, transitioning it from `Stopping` to `Stopped`.

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

Functionack_stop_node_round_trip

()

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

Functionack_stop_transitions_stopping_to_stopped

()

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

Functionack_succeeds_after_request_stop

()

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

Methodacquire_execution_semaphore

( &self, _span: Option<Span>, )

influxdb3_internal_api/src/query_executor.rs:230

Functionaction_into_proto

()

core/authz/src/permission.rs:226

Functionaction_try_from_proto

()

core/authz/src/permission.rs:198

Functionactions_encodings

()

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

Methodactive_triggers

(&self)

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

Functionactive_triggers_returns_ids

()

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

Methodactive_user_count

(&self)

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

Methodadapt

Create a new stream which wraps the `inner` channel which produces [`RecordBatch`]es that each have the specified schema Not called `new` because it

core/datafusion_util/src/lib.rs:238

Methodadapt_unbounded

Create a new stream which wraps the `inner` unbounded channel which produces [`RecordBatch`]es that each have the specified schema Not called `new` b

core/datafusion_util/src/lib.rs:258

Methodadd

(self, other: u64)

core/data_types/src/lib.rs:212

Methodadd_assign

(&mut self, rhs: u64)

core/data_types/src/lib.rs:218

Methodadd_assign

(&mut self, other: Self)

influxdb3_commands/src/write.rs:158

Methodadd_column

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

influxdb3/tests/cli/api.rs:541

Functionadd_columns_carries_field_families_and_fields

()

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

Functionadd_columns_orders_tags_by_v2_series_key

()

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

Functionadd_columns_preserves_auto_field_family_name

()

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

Functionadd_columns_round_trip

()

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

Functionadd_columns_updates_schema_and_column_map

()

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

Methodadd_context

(_input: &str, context: &'static str, inner: Self)

core/influxdb_line_protocol/src/lib.rs:266

Methodadd_description

Adds information on what normalizations were applied to the input

core/arrow_util/src/test_util.rs:510

Methodadd_fields

( mut table: Cow<'a, Self>, fields: &Vec<FieldDefinition>, )

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

Methodadd_header

Add the specified header with value to all subsequent requests

core/influxdb_iox_client/src/client/flight/mod.rs:239

Methodadd_parts_and_files_from_iter

( iter: I, files: &mut HashSet<&'plan str>, parts: &mut HashSet<&'plan str>, )

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

Methodadd_sample

(&mut self, events_bucket: &EventsBucket)

influxdb3_telemetry/src/metrics.rs:20

Methodadd_target

(self)

core/test_helpers/src/tracing.rs:87

Methodadd_token

(&mut self, token_id: TokenId, token_info: TokenInfo)

influxdb3_catalog/src/catalog.rs:241

Methodadd_token

(&mut self, token_id: TokenId, token_info: TokenInfo)

influxdb3_catalog/src/catalog/versions/v3/schema/tokens.rs:42

Functionadd_token_does_not_update_hash_lookup_when_repo_insert_fails

()

influxdb3_catalog/src/catalog/tests.rs:13

Functionadd_wal_trigger_is_keyed_by_id

()

influxdb3_processing_engine/src/tests.rs:2016

Methodaddr

Get the address the server is listening at.

core/test_helpers_authz/src/authz.rs:138

Methodaddress

Get the address of the PushGateway server.

core/metric_exporters/src/lib.rs:217

Functionadmin_stop_uses_nil_process_uuid

()

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

Functionadmin_token_create_regenerate_delete

()

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

Functionadmin_token_emits_create_admin_token

()

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

Functionadmin_token_is_admin

()

influxdb3_authz/src/tests.rs:67

Methodadvance_time

(&mut self)

influxdb3_processing_engine/src/plugins.rs:967

Functionaggregate_around_window_aggregate

()

core/iox_query_influxql/src/plan/planner.rs:4891

Functionaggregate_non_existent_field

()

core/iox_query_influxql/src/plan/planner.rs:5646

Functionaggregate_non_existent_field_and_group_by

()

core/iox_query_influxql/src/plan/planner.rs:5654

Functionaggregates

()

core/iox_query_influxql/src/plan/planner.rs:4846

Functionair_and_water

(c: &mut Criterion)

core/mutable_batch_pb/benches/write_table_batch.rs:86

Functionalignment

()

core/linear_buffer/src/linear_buffer.rs:474

Functionall_approximately_equal

(f1: &[f64], f2: &[f64])

core/test_helpers/src/lib.rs:20

Functionall_auto_defined_field_families

()

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

Functionall_columns_defined_no_rewrite

()

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

Functionall_columns_not_defined

()

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

Methodall_db_indices_prefix

(host_prefix: &str)

influxdb3_write/src/paths.rs:252

Functionall_empty

(c: &mut Criterion)

core/arrow_util/benches/iter_set_positions.rs:51

Functionall_full

(c: &mut Criterion)

core/arrow_util/benches/iter_set_positions.rs:46

Methodall_snapshots_prefix

(host_prefix: &str)

influxdb3_write/src/paths.rs:136

Functionall_token_types

()

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

Functionall_user_defined_field_families

()

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

Functionallows_core_enterprise_independently

()

influxdb3_catalog/src/format/feature_level/tests.rs:11

Functionallows_record_within_committed_level

()

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

Functionalready_migrated_when_v3_snapshot_present

()

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

Methodanalyze

(&self, plan: LogicalPlan, _config: &ConfigOptions)

core/iox_query/src/analyzer/extract_sleep.rs:36

Methodanalyze

(&self, plan: LogicalPlan, _config: &ConfigOptions)

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

Functionany_ticket_decoding_error

()

core/service_grpc_flight/src/request.rs:972

Functionany_ticket_decoding_flightsql_too_many_fields

()

core/service_grpc_flight/src/request.rs:956

Functionany_ticket_decoding_influxql

()

core/service_grpc_flight/src/request.rs:891

Functionany_ticket_decoding_influxql_too_many_fields

()

core/service_grpc_flight/src/request.rs:940

Functionany_ticket_decoding_sql

()

core/service_grpc_flight/src/request.rs:875

Functionany_ticket_decoding_sql_too_many_fields

()

core/service_grpc_flight/src/request.rs:924

Functionany_ticket_decoding_too_new

()

core/service_grpc_flight/src/request.rs:907

← previous next →4,901–5,000 of 11,906, ranked by callers