MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
Functionno_tags_or_timestamp
()
core/influxdb2_client/src/models/data_point.rs:375
Functionno_timestamp
()
core/influxdb2_client/src/models/data_point.rs:389
Functionno_token_error_returns_401
()
core/iox_http/src/write/single_tenant/mod.rs:709
Methodnode
( time_ns: i64, node_catalog_id: NodeId, node_id: impl Into<Arc<str>>, ops: Ve
influxdb3_catalog/src/log/versions/v3.rs:54
Methodnode
( time_ns: i64, node_catalog_id: NodeId, node_id: impl Into<Arc<str>>, ops: Ve
influxdb3_catalog/src/log/versions/v4.rs:118
Methodnode_by_id
(&self, node_id: &NodeId)
influxdb3_catalog/src/catalog/versions/v2.rs:719
Methodnode_by_id
(&self, node_id: &NodeId)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1141
Methodnode_id
(&self)
influxdb3_processing_engine/src/lib.rs:381
Methodnode_id
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:2185
Methodnode_id
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:924
Methodnode_id
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:63
Methodnode_label
Return a short label identifying the node this client targets. Uses URL authority (`host:port`) when available, falling back to the full URL string.
influxdb3_client/src/lib.rs:224
Functionnode_mode_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:6
Functionnode_spec_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:16
Functionnon_default_cache_size
()
influxdb3_cache/src/last_cache/tests.rs:333
Methodnon_empty
(self, field: impl Into<Self>)
core/generated_types/src/google.rs:707
Methodnone
Limits high enough to be effectively unenforced. Intended for tests, and for internal paths (e.g. migrating an existing catalog) that must not reject
influxdb3_catalog/src/catalog/versions/v3/usage.rs:80
Methodnone
Create flags with no bits set (feature-gated).
influxdb3_catalog/src/format/mod.rs:152
Functionnonscalar_origin
()
core/iox_query/src/analyzer/handle_gapfill.rs:880
Functionnonscalar_stride
()
core/iox_query/src/analyzer/handle_gapfill.rs:904
Functionnonzero_group_count_on_log_rejected
()
influxdb3_catalog/src/format/header/tests.rs:72
Functionnoop_rewrites
()
core/iox_query_influxql_rewrite/src/lib.rs:533
Functionnoop_sink_accepts_any_event
()
influxdb3_internal_api/src/sll/tests.rs:46
Functionnormalize_batches
Return a new set of `RecordBatch`es where the function `norm` has applied to all `StringArray` rows.
core/arrow_util/src/test_util.rs:142
Functionnormalize_plugin_name_handles_supported_plugin_reference_forms
()
influxdb3_processing_engine/src/plugin_telemetry/tests.rs:5
Methodnormalize_results
Take the output of running the query and apply the specified normalizations to them
core/arrow_util/src/test_util.rs:337
Functionnot_accepted
()
core/object_store_mem_cache/src/buffer_channel.rs:170
Functionnot_quote_unicode_unnecessarily
()
core/logfmt/src/lib.rs:502
Functionnothing_to_migrate_on_empty_store
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1668
Functionnotifies_watchers_of_snapshot
()
influxdb3_write/src/write_buffer/tests.rs:1257
Methodnotify_and_snapshot
( &self, write: Arc<WalContents>, snapshot_details: SnapshotDetails, )
influxdb3_processing_engine/src/lib.rs:1180
Methodnow_call
Parse the `now()` function call
core/influxdb_influxql_parser/src/select.rs:334
Methodnull_counts
(&self, column: &Column)
core/iox_query/src/pruning.rs:215
Functionnull_masks_from_valid_masks
()
core/mutable_batch_pb/src/encode.rs:167
Functionnull_non_nullable_column
()
core/iox_query/src/provider/adapter.rs:502
Functionnull_values
()
influxdb3_cache/src/last_cache/tests.rs:847
Functionnullable_schema
Returns a new schema where all the fields are nullable
core/datafusion_util/src/lib.rs:427
Methodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:1735
Methodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v2/legacy.rs:50
Methodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:42
Methodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:415
Methodnum_columns
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:358
Methodnum_columns_per_table_limit
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:166
Methodnum_containers
(&self)
core/iox_query/src/pruning.rs:211
Methodnum_dupes
return the number of duplicates this deduplicator detected
core/iox_query/src/provider/deduplicate.rs:1647
Methodnum_field_columns
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3507
Methodnum_field_families
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3511
Methodnum_field_families
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:370
Methodnum_rows
(&self)
core/partition/src/traits/mutable_batch.rs:43
Methodnum_rows
(&self)
core/partition/src/traits/record_batch.rs:55
Methodnum_tables_limit
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:162
Methodnum_tag_columns
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3503
Methodnum_tag_columns
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:1739
Methodnum_triggers
(&self)
influxdb3_telemetry/src/sampler/tests.rs:15
Methodnum_triggers
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:1493
Methodnum_triggers
(&self)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3453
Methodnum_triggers
Counts of triggers by spec variant: (single-table-wal, all-tables-wal, schedule, request). Mirrors v2's `num_triggers` shape used by `ProcessingEngine
influxdb3_catalog/src/catalog/versions/v3/inner.rs:169
Methodnum_values
Get how many values are currently being stored here
core/table_batch/src/builder/column_writer/mod.rs:215
Methodnum_wal_periods
(&self)
influxdb3_wal/src/snapshot_tracker.rs:190
Methodobject_store
(&self)
influxdb3_catalog/src/object_store/versions/v2.rs:52
Methodobject_store
(&self)
influxdb3_catalog/src/object_store/versions/v3.rs:87
Functionobject_store_file_stem
(n: u64)
influxdb3_write/src/paths.rs:37
Methodobject_store_id
Get object store ID.
core/parquet_file/src/lib.rs:117
Methodobject_store_id
Return object store id
core/parquet_file/src/chunk.rs:47
Methodobject_store_prefix
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:569
Functionobject_store_returns_underlying_handle
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2084
Functionobserve
(_plan: &LogicalPlan, _rule: &dyn AnalyzerRule)
core/iox_query/src/analyzer/handle_gapfill.rs:741
Methodobserve
( self, cache: &'static str, trigger: &'static str, metrics: &metric::Registry
core/object_store_mem_cache/src/cache_system/reactor/trigger.rs:110
Methodobserve
( self, cache: &'static str, metrics: &metric::Registry, time_provider: Arc<dy
core/object_store_mem_cache/src/cache_system/reactor/reaction.rs:54
Methodobserve
(&self)
core/metric/src/duration.rs:45
Methodobserve
(&self)
core/metric/src/histogram.rs:135
Methodobserve
(&self)
core/metric/src/cumulative.rs:43
Methodobserve
(&self)
core/metric/src/counter.rs:35
Functionoffset
()
core/query_functions/src/tz.rs:350
Functionon_clause
Parse an `ON` clause for statements such as `SHOW TAG KEYS` and `SHOW FIELD KEYS`.
core/influxdb_influxql_parser/src/show.rs:92
Methodon_event
(&self, event: &tracing::Event<'_>, ctx: Context<'_, S>)
core/logfmt/src/lib.rs:110
Methodon_new_span
(&self, attrs: &tracing::span::Attributes<'_>, id: &Id, ctx: Context<'_, S>)
core/logfmt/src/lib.rs:96
Functiononboarding
()
core/influxdb2_client/src/api/setup.rs:138
Functiononboarding
()
core/influxdb2_client/tests/setup.rs:48
Functiononboarding_opt
()
core/influxdb2_client/src/api/setup.rs:209
Functionone_catalog_down_with_503s_causes_new_snapshot
()
core/catalog_cache/src/api/quorum.rs:954
Functionone_catalog_unreachable_causes_new_snapshot
()
core/catalog_cache/src/api/quorum.rs:999
Functionone_time_column_overlap_1_chunk
()
core/iox_query/src/provider/overlap.rs:276
Functionone_time_column_overlap_2_groups
()
core/iox_query/src/provider/overlap.rs:214
Functionone_time_column_overlap_3_groups
()
core/iox_query/src/provider/overlap.rs:243
Functionone_time_column_overlap_bad_case
()
core/iox_query/src/provider/overlap.rs:156
Functionone_time_column_overlap_contiguous
()
core/iox_query/src/provider/overlap.rs:185
Functionone_time_column_overlap_same_min_max
()
core/iox_query/src/provider/overlap.rs:137
Methodop
Operator.
core/data_types/src/lib.rs:1578
Functionop_flags_bits
()
influxdb3_catalog/src/format/tests.rs:4
Functionop_flags_from_u16
()
influxdb3_catalog/src/format/tests.rs:18
Methodoperand
(i: &str)
core/influxdb_influxql_parser/src/select.rs:290
Methodoperand
(i: &str)
core/influxdb_influxql_parser/src/expression/conditional.rs:360
Methodoperand
(i: &str)
core/influxdb_influxql_parser/src/expression/arithmetic.rs:706
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/predicate_pushdown.rs:27
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/cached_parquet_data.rs:33
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/projection_pushdown.rs:38
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/dedup/split.rs:26
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/dedup/dedup_null_columns.rs:33
Methodoptimize
( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, )
core/iox_query/src/physical_optimizer/dedup/dedup_sort_order.rs:52
← previousnext →8,101–8,200 of 11,906, ranked by callers