Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/influxdata/influxdb
/ functions
Functions
11,906 in github.com/influxdata/influxdb
⨍
Functions
11,906
◇
Types & classes
2,644
↳
Endpoints
4
Method
last_wal_sequence_number
(&self)
influxdb3_wal/src/object_store.rs:645
Method
last_wal_sequence_number
Returns the last [`WalFileSequenceNumber`] that was added to the tracker.
influxdb3_wal/src/snapshot_tracker.rs:175
Method
latest
Returns the latest version.
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/s3_fifo.rs:669
Method
latest_snapshot_sequence_number
(&self)
influxdb3_write/src/table_index_cache.rs:193
Method
layer
(&self, inner: S)
influxdb3_server/src/unified_service/remote_addr_layer.rs:24
Method
layer
(&self, service: S)
core/trace_http/src/tower.rs:86
Method
layer
(&self, service: S)
core/tower_trailer/src/lib.rs:24
Function
leave_dst
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:835
Function
leave_dst_avoid_discontinuity
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:905
Function
leave_dst_short_strides
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:869
Function
legacy_column_id_available_when_space_remains
()
influxdb3_catalog/src/catalog/versions/v3/transaction/tests.rs:31
Function
legacy_column_id_exhausted_pachatree_yields_none
()
influxdb3_catalog/src/catalog/versions/v3/transaction/tests.rs:39
Function
legacy_column_id_exhausted_parquet_errors
()
influxdb3_catalog/src/catalog/versions/v3/transaction/tests.rs:45
Function
legacy_grouped_snapshot_rewritten_at_startup
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1485
Function
legacy_grouped_snapshot_skips_index_and_reads_records
()
influxdb3_catalog/src/format/reader/tests.rs:224
Function
legacy_snapshot_group_count_accepted
()
influxdb3_catalog/src/format/header/tests.rs:51
Method
legacy_table_definition
(&self, table_name: impl AsRef<str>)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:232
Method
legacy_table_definition_by_id
(&self, table_id: &TableId)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:236
Method
len
(&self)
core/table_batch/src/values.rs:25
Method
len
Returns the number of [`SequenceNumber`] in this set.
core/data_types/src/sequence_number_set.rs:52
Method
len
Number of registered records.
influxdb3_catalog/src/format/registry.rs:182
Function
len_of_default_template_is_1
()
core/data_types/src/partition_template.rs:2470
Function
length_mismatch
()
core/iox_query/src/exec/split.rs:1318
Function
level
()
core/logfmt/tests/logging.rs:41
Function
lex_ordering
()
core/iox_query/src/physical_optimizer/limits.rs:369
Function
license_paths_derive_from_catalog_id
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2096
Function
limit_output_rows
()
core/iox_query/src/exec/gapfill/date_bin_gap_expander.rs:478
Function
limit_output_rows
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:531
Function
limited_writer
()
core/trogging/src/lib.rs:635
Function
limits
()
influxdb3/tests/server/limits.rs:7
Method
limits_check
Resource-limit hook for the configured [`CatalogLimiter`]. Override for ops that introduce databases, tables, or columns; default is a no-op.
influxdb3_catalog/src/catalog/versions/v3/ops/mod.rs:33
Method
limits_check
( _args: &Self::Input, _catalog: &InnerCatalog, usage: &CurrentCatalogUsage, l
influxdb3_catalog/src/catalog/versions/v3/ops/database.rs:38
Function
line_buffering
()
core/trogging/src/lib.rs:611
Method
lines_as_maps
Logged lines as map for easier assertion.
core/test_helpers/src/tracing.rs:157
Method
link
Link this span to another context.
core/trace/src/span.rs:134
Method
list
(&self, _prefix: Option<&Path>)
core/object_store_mem_cache/src/store.rs:361
Method
list
(&self, prefix: Option<&Path>)
core/object_store_metrics/src/cache_metrics.rs:378
Method
list
Collect results from inner object store into a vec, sort them, then return a new boxed stream that iterates over the new vec.
influxdb3_clap_blocks/src/object_store.rs:234
Method
list
(&self, _prefix: Option<&Path>)
influxdb3_clap_blocks/src/object_store/tests.rs:542
Method
list
(&self, prefix: Option<&Path>)
influxdb3_test_helpers/src/object_store/mod.rs:153
Method
list
(&self, prefix: Option<&Path>)
influxdb3_test_helpers/src/object_store/mock.rs:478
Method
list
(&self, prefix: Option<&Path>)
object_store_utils/src/observed_object_store.rs:152
Method
list_actions
( &self, _request: Request<Empty>, )
core/service_grpc_flight/src/lib.rs:1312
Function
list_default_excludes_pre_snapshot_logs
()
influxdb3_commands/src/debug/catalog/tests.rs:78
Method
list_distinct_caches
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:135
Function
list_empty_does_not_update_health
()
object_store_utils/src/observed_object_store/tests.rs:126
Method
list_flights
( &self, _request: Request<Criteria>, )
core/service_grpc_flight/src/lib.rs:1073
Method
list_hard_deleted_dbs_tables
List IDs of databases and tables that are marked for hard deletion. Returns a vector of tuples where: - `(DbId, None)` indicates the database itself
influxdb3_catalog/src/catalog/versions/v2.rs:820
Function
list_installed_packages_from_python
(py: Python<'_>)
influxdb3_processing_engine/src/environment.rs:113
Method
list_last_caches
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:144
Method
list_namespaces
List all namespaces
core/iox_query/src/lib.rs:181
Method
list_namespaces
( &self, _span: Option<Span>, )
influxdb3_query_executor/src/lib.rs:502
Method
list_namespaces
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:1200
Method
list_namespaces
(&self)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1128
Function
list_namespaces_is_empty_without_databases
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2140
Method
list_parquet_files_by_path_filter
List the parquet files located with the path prefix. Search is recursive (e.g. searching `prefix/` includes `prefix/<other/paths>/uuid.parquet`. Retu
core/influxdb_iox_client/src/client/store.rs:68
Function
list_render_json_contains_log
()
influxdb3_commands/src/debug/catalog/tests.rs:45
Function
list_reports_one_log
()
influxdb3_commands/src/debug/catalog/tests.rs:36
Method
list_request_timeout
Set timeout for `LIST` requests. The timeout is applied from when the request starts connecting until the response body has finished. Given the non-
core/catalog_cache/src/api/client.rs:159
Method
list_with_delimiter
(&self, _prefix: Option<&Path>)
core/object_store_mem_cache/src/store.rs:373
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
core/object_store_metrics/src/cache_metrics.rs:390
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
core/object_store_mock/src/lib.rs:578
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
influxdb3_cache/src/parquet_cache/mod.rs:841
Method
list_with_delimiter
Collect results from inner object store into a vec, sort them, then return a new boxed stream that iterates over the new vec.
influxdb3_clap_blocks/src/object_store.rs:298
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
influxdb3_clap_blocks/src/object_store/tests.rs:546
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
influxdb3_test_helpers/src/object_store/mod.rs:165
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
influxdb3_test_helpers/src/object_store/mock.rs:502
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
object_store_utils/src/observed_object_store.rs:174
Method
list_with_delimiter
(&self, prefix: Option<&Path>)
object_store_limit/src/lib.rs:203
Function
list_with_delimiter_records_success_on_empty
()
object_store_utils/src/observed_object_store/tests.rs:83
Method
list_with_delimiter_with_default_retries
( &self, prefix: Option<&Path>, context_message: String, )
object_store_utils/src/retryable_object_store.rs:375
Function
list_with_delimiter_with_retries_retries_transient_errors
()
object_store_utils/src/retryable_object_store/tests.rs:308
Method
list_with_offset
( &self, _prefix: Option<&Path>, _offset: &Path, )
core/object_store_mem_cache/src/store.rs:365
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
core/object_store_metrics/src/cache_metrics.rs:382
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
core/object_store_mock/src/lib.rs:564
Method
list_with_offset
Collect results from inner object store into a vec, sort them, then return a new boxed stream that iterates over the new vec.
influxdb3_clap_blocks/src/object_store.rs:264
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
influxdb3_test_helpers/src/object_store/mod.rs:157
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
influxdb3_test_helpers/src/object_store/mock.rs:488
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
object_store_utils/src/observed_object_store.rs:161
Method
list_with_offset
( &self, prefix: Option<&Path>, offset: &Path, )
object_store_limit/src/lib.rs:184
Function
list_with_offset_yielding_items_records_success
()
object_store_utils/src/observed_object_store/tests.rs:144
Function
list_with_retries
()
object_store_utils/src/retryable_object_store/tests.rs:257
Method
list_with_retries
( &self, prefix: Option<&Path>, offset: Option<&Path>, context_message: String
object_store_utils/src/retryable_object_store.rs:439
Function
list_with_retries_every_nth_fails
()
object_store_utils/src/retryable_object_store/tests.rs:395
Function
list_with_retries_exhaustion
()
object_store_utils/src/retryable_object_store/tests.rs:350
Function
list_yielding_items_records_success
()
object_store_utils/src/observed_object_store/tests.rs:107
Function
lit_interval_milliseconds
(v: i64)
core/query_functions/src/gapfill.rs:417
Function
lit_timestamptz_nano_with_tz
(t: i64, tz: impl Into<Arc<str>>)
core/iox_query/src/analyzer/handle_gapfill/range_predicate.rs:299
Method
literal_int
(expr: &'a IQLExpr)
core/iox_query_influxql/src/plan/planner/select.rs:387
Method
literal_num
(expr: &'a IQLExpr)
core/iox_query_influxql/src/plan/planner/select.rs:394
Function
load_catalog
( prefix: Arc<str>, store: Arc<dyn ObjectStore>, )
influxdb3_catalog/src/serialize/versions/v1.rs:23
Method
load_catalog_from_paths
Reconstruct an [`InnerCatalog`] from an explicitly selected snapshot (checkpoint) file plus a set of log files, rather than the live well-known paths.
influxdb3_catalog/src/object_store/versions/v3.rs:449
Function
load_catalog_replays_snapshot_and_logs
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:195
Function
load_catalog_returns_none_for_empty_store
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:134
Function
load_from_object_store
(#[case] tc: LoadFromObjectStoreTestCase)
influxdb3_write/src/table_index/test_table_index_operations.rs:502
Function
load_from_object_store_malformed_index
()
influxdb3_write/src/table_index/test_table_index_operations.rs:533
Function
load_from_object_store_malformed_snapshot
()
influxdb3_write/src/table_index/test_table_index_operations.rs:559
Function
load_log_returns_none_when_missing
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:76
Method
load_or_create
Bootstrap a `Catalog` from an object store: load the existing v3 catalog at `catalog_id`, or initialize a fresh one with `storage_mode` if none exists
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:635
Method
load_or_create_catalog
Try loading the catalog, if there is no catalog generate new instance id and create a new catalog and persist it immediately
influxdb3_catalog/src/object_store/versions/v1.rs:37
← previous
next →
7,201–7,300 of 11,906, ranked by callers