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

Functionwith_interpolate

()

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

Methodwith_jaeger_debug

Enable generation of jaeger debug headers with the given header name.

core/influxdb2_client/src/lib.rs:162

Methodwith_latency

Configure fixed latency for get and put style operations.

object_store_utils/src/test_object_store.rs:111

Methodwith_latency_ms

Configure fixed latency for get and put style operations using milliseconds.

object_store_utils/src/test_object_store.rs:122

Methodwith_limit

Set limit for table entries

influxdb3/tests/cli/api.rs:1322

Functionwith_limit_or_offset

()

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

Functionwith_limit_or_offset2

()

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

Functionwith_limit_or_offset3

()

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

Functionwith_limit_or_offset_errors

()

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

Functionwith_locf

()

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

Functionwith_locf_aliased

()

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

Methodwith_log_entry

( namespace_id: NamespaceId, namespace_name: Arc<str>, query_type: &'stati

core/iox_query/src/query_log.rs:7540

Methodwith_max_concurrent_uploads

The client makes this many concurrent uploads at a time. Defaults to 1.

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

Methodwith_max_path_segments

Restrict metric paths to `segments`

core/trace_http/src/metrics.rs:61

Methodwith_new_children

( self: Arc<Self>, _children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_query_influxql/src/frontend/planner.rs:146

Methodwith_new_children

( self: Arc<Self>, _children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_query/src/query_log.rs:7669

Methodwith_new_children

( self: Arc<Self>, _children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_query/src/exec.rs:623

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, _children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_query/src/exec/query_tracing.rs:680

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_query/src/provider/record_batch_exec.rs:170

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

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

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

core/iox_system_tables/src/system_tables.rs:168

Methodwith_new_children

( self: Arc<Self>, _children: Vec<Arc<dyn ExecutionPlan>>, )

influxdb3_query_executor/src/query_planner.rs:144

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

influxdb3_cache/src/distinct_cache/table_function.rs:393

Methodwith_new_children

( self: Arc<Self>, children: Vec<Arc<dyn ExecutionPlan>>, )

influxdb3_cache/src/last_cache/table_function.rs:447

Functionwith_node_specifications

()

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

Methodwith_nulls_before_single_valid

(preceding_nulls: usize)

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

Methodwith_nulls_first

set SortOptions::nulls_first flag

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

Methodwith_object_store_id

Set new object store ID.

core/parquet_file/src/lib.rs:122

Methodwith_object_store_tls_allow_insecure

Allow insecure TLS connections for object store

influxdb3/tests/server/mod.rs:260

Methodwith_object_store_tls_ca_path

Set custom CA certificate path for object store TLS

influxdb3/tests/server/mod.rs:266

Methodwith_one_row_of_data

Prepares this chunk to return a specific record batch with one row of non null data. tag: MA

core/iox_query/src/test.rs:809

Methodwith_order_by

Set order by clause

influxdb3/tests/cli/api.rs:1328

Functionwith_origin

()

core/query_functions/src/date_bin_wallclock.rs:640

Functionwith_origin_in_future

()

core/query_functions/src/date_bin_wallclock.rs:683

Methodwith_output_file

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

influxdb3/tests/cli/api.rs:389

Methodwith_package_manager

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

influxdb3/tests/cli/api.rs:1084

Methodwith_packages

(mut self, packages: impl IntoIterator<Item = impl Into<String>>)

influxdb3/tests/cli/api.rs:1064

Methodwith_param

Supply a new named parameter to use with this query. Parameters referenced using `$placeholder` syntax in the query will be substituted with the value

core/influxdb_iox_client/src/client/flight/query.rs:63

Methodwith_params

IMPORTANT NOTE: Named parameters currently do not work with this client until an upgrade to DataFusion 34.0 is performed. See <https://github.com/apac

core/influxdb_iox_client/src/client/flight/query.rs:76

Methodwith_partition_id

(mut self, id: PartitionHashId)

core/iox_query/src/test.rs:584

Methodwith_path

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

influxdb3/tests/cli/api.rs:707

Methodwith_permission_tokens_file

Set the permission tokens file path for this [`TestServer`]

influxdb3/tests/server/mod.rs:254

Methodwith_permissions_return

( self, ret: impl Into<VecDeque<Result<Vec<Permission>, Error>>>, )

core/authz/src/instrumentation.rs:100

Functionwith_projection

()

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

Methodwith_quiet

Returns the receiver configured to suppress any output to STDOUT.

core/iox_query/src/test.rs:563

Methodwith_ret

(self, ret: T)

core/iox_http/src/write.rs:52

Functionwith_retention

()

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

Methodwith_retention

Add an exprestion "time > retention_time"

core/predicate/src/lib.rs:265

Methodwith_retention_time_ns

Set retention time.

core/iox_query/src/test.rs:222

Methodwith_return

Return the values specified in `ret` in sequence for calls to `shard`, starting from the front.

core/sharder/src/mock.rs:56

Methodwith_select

Set select fields

influxdb3/tests/cli/api.rs:1334

Methodwith_sequence

(mut self, seq: SnapshotSequenceNumber)

influxdb3_write/src/table_index/test_table_index_operations.rs:51

Methodwith_size

Creates a new BitSet with `count` unset bits.

core/arrow_util/src/bitset.rs:35

Methodwith_sort_expr

Add a sort expression to the ordering (created with the current SortOptions)

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

Methodwith_specific_file_ids

(mut self, ids: Vec<ParquetFileId>)

influxdb3_write/src/table_index/test_table_index_operations.rs:66

Functionwith_strings

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

core/mutable_batch_pb/src/decode.rs:452

Methodwith_target

Control whether target and location attributes are displayed (on by default). Note: this API mimics that of other fmt layers in tracing-subscriber cr

core/logfmt/src/lib.rs:76

Methodwith_ten_rows_of_data_some_duplicates

Prepares this chunk to return a specific record batch with ten rows of non null data that look like, duplicates within "+------+------+-----------+---

core/iox_query/src/test.rs:1097

Methodwith_test_mode

( common_state: CommonServerState, time_provider: Arc<dyn TimeProvider>, write_buffer:

influxdb3_server/src/http.rs:1039

Methodwith_testing

Constructor for testing. This is identical to [`Default::default`] but we do NOT implement [`Default`] to make the creation of untracked contexts mor

core/iox_query/src/exec/context.rs:468

Methodwith_three_rows_of_data

Prepares this chunk to return a specific record batch with three rows of non null data that look like, no duplicates within "+------+------+----------

core/iox_query/src/test.rs:896

Methodwith_trigger_arguments

( mut self, args: impl IntoIterator<Item = impl Into<String>>, )

influxdb3/tests/cli/api.rs:674

Functionwith_u64

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

core/mutable_batch_pb/src/decode.rs:492

Methodwith_variant

(mut self, variant: SnapshotVariant)

influxdb3_write/src/table_index/test_table_index_operations.rs:56

Methodwith_virtual_env_location

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

influxdb3/tests/cli/api.rs:1079

Methodwoken

How often the callers [`Waker::wake`](std::task::Waker::wake) was called.

core/futures_test_utils/src/lib.rs:83

Methodwrite

(&mut self, bytes: &[u8])

core/data_types/src/partition.rs:706

Methodwrite

(&mut self, buf: &[u8])

influxdb3_load_generator/src/line_protocol_generator.rs:563

Functionwrite_and_query

()

influxdb3_server/src/tests.rs:46

Functionwrite_and_query

()

influxdb3/tests/server/client.rs:11

Functionwrite_and_query_via_file

()

influxdb3/tests/cli/mod.rs:3911

Functionwrite_and_query_via_stdin

()

influxdb3/tests/cli/mod.rs:3850

Functionwrite_and_query_via_stdin_gzip

()

influxdb3/tests/cli/mod.rs:3881

Functionwrite_and_query_via_string

()

influxdb3/tests/cli/mod.rs:3943

Functionwrite_flush_delete_and_load

()

influxdb3_wal/src/object_store/tests.rs:26

Functionwrite_lp_precision_tests

()

influxdb3_server/src/tests.rs:299

Functionwrite_lp_tests

()

influxdb3_server/src/tests.rs:153

Functionwrite_lp_to_db

Write to the server with the line protocol

influxdb3/tests/server/mod.rs:1163

Functionwrite_metrics

()

influxdb3_write/src/write_buffer/tests.rs:1691

Methodwrite_source

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

core/influxdb_iox_client/src/client/reloadable_token.rs:117

Methodwrite_source

( &self, _org_id: String, _bucket_id: String, body: String,

core/influxdb_iox_client/src/client/batched_write.rs:293

Methodwrite_sync

Write line protocol to the database this trigger is attached to. Writes synchronously via the write buffer. Use `write_sync_to_db` to write to a diff

influxdb3_py_api/src/system_py.rs:131

Methodwrite_trailer_count

(md: &mut HeaderMap, key: &'static str, count: Option<N>)

core/service_grpc_flight/src/lib.rs:1588

Methodwrite_trailer_duration

(md: &mut HeaderMap, key: &'static str, d: Option<Duration>)

core/service_grpc_flight/src/lib.rs:1593

Functionwrite_validator_v1

()

influxdb3_write/src/write_buffer/validator/tests.rs:14

Functionwrite_with_no_sync

()

influxdb3/tests/server/client.rs:104

Functionwrite_with_precision_arg

()

influxdb3/tests/cli/mod.rs:3975

Functionwriter_delegates_to_column_validator

()

core/mutable_batch/src/writer.rs:1014

Functionwrites_data_to_wal_and_is_queryable

()

influxdb3_write/src/write_buffer/tests.rs:163

Functionwrites_not_dropped_on_larger_snapshot_size

()

influxdb3_write/src/write_buffer/tests.rs:1088

Functionwrites_not_dropped_on_snapshot

()

influxdb3_write/src/write_buffer/tests.rs:1001

Functionwrites_not_dropped_with_future_writes

()

influxdb3_write/src/write_buffer/tests.rs:1178

Functionwrites_with_different_schema_should_fail

()

influxdb3/tests/server/write.rs:367

Functionwriting_points

()

core/influxdb2_client/src/api/write.rs:70

Methodwritten_bytes

Number of written bytes since last snapshot.

core/tracker/src/disk_metric.rs:63

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