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
total_active_cores_in_use_by_other_nodes
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:485
Method
total_active_cores_in_use_by_other_nodes
Sum of `core_count` across every running node in the cluster except the current one.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1192
Method
total_column_count
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:135
Method
total_db_count
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:127
Method
total_disk_space
The maximum capacity in bytes of the disk.
core/tracker/src/disk_metric.rs:46
Method
total_entries_count
Calculate total number of entries across all databases
influxdb3_write/src/table_index_cache.rs:529
Method
total_table_count
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:131
Method
trace_exporter
(&self)
influxdb3_server/src/lib.rs:118
Method
tracked
(&self)
core/tracker/src/task/registry.rs:111
Method
tracked
(&self)
core/tracker/src/task/history.rs:52
Method
tracked_len
(&self)
core/tracker/src/task/metrics.rs:55
Method
tracked_len
(&self)
core/tracker/src/task/registry.rs:107
Method
tracked_len
(&self)
core/tracker/src/task/history.rs:48
Function
trait_method_delegates_to_impl_with_default_chunk_size
()
object_store_utils/src/adaptive_put.rs:242
Function
transaction_commit_applies_heterogeneous_record_types
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:338
Function
transaction_commit_persists_records_and_advances_sequence
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:246
Function
transaction_concurrent_commits_one_succeeds_other_retries
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:364
Function
transaction_pushes_after_side_channel_advance_still_retry
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:433
Function
transaction_retries_when_another_writer_takes_the_next_sequence
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:307
Function
transaction_retries_when_catalog_advanced_after_begin
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:278
Method
trial_or_home_license_file_path
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:563
Method
trial_or_home_license_file_path
Object store path holding the cluster's trial or home license file, derived from the catalog id.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1124
Function
trigger_arguments_sorted_by_key_for_determinism
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:553
Method
trigger_count_by_type
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:153
Function
trigger_create_disable_enable_delete
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3712
Function
trigger_disabled_flag_carries_through
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:537
Method
trigger_shutdown
Trigger application shutdown due to some unrecoverable state
influxdb3_shutdown/src/lib.rs:207
Function
trigger_spec_encodings
()
influxdb3_catalog/src/format/records/types/tests.rs:118
Function
trigger_with_settings
()
influxdb3_catalog/src/catalog/migrations/v2/tests.rs:1309
Function
triggers_emitted_between_create_database_and_soft_delete
()
influxdb3_catalog/src/catalog/migrations/v3/tests.rs:1603
Method
truncate_to_hour
Returns a new instance truncated to the most recently passed hour. # Example ``` let time = iox_time::Time::from_timestamp_nanos(1723129005000000000
core/iox_time/src/lib.rs:169
Function
truncated_record_header
()
influxdb3_catalog/src/format/reader/tests.rs:147
Function
truncated_string
()
influxdb3_types/src/database_name/tests.rs:113
Function
truth_table
Valid combinations for AND
core/iox_query/src/exec/split.rs:1094
Method
try_decode
(_: &Status)
core/influxdb_iox_client/src/client/error.rs:33
Method
try_decode
try to decode a ReadInfo structure from a Token
core/service_grpc_flight/src/request.rs:208
Method
try_decode
(handle: Bytes)
core/flightsql/src/cmd.rs:84
Function
try_deleting_table_after_db_is_deleted
()
influxdb3/tests/server/configure.rs:1429
Method
try_encode
Encode the command as a flightsql message (bytes)
core/flightsql/src/cmd.rs:415
Method
try_from
(path: ObjPath)
influxdb3_write/src/paths.rs:196
Method
try_from
(proto: proto::IngesterQueryRequest)
core/ingester_query_grpc/src/lib.rs:131
Method
try_from
(statement: Statement)
core/iox_query_influxql_rewrite/src/lib.rs:87
Method
try_from
(iox_metadata: &IoxMetadata)
core/parquet_file/src/metadata.rs:283
Method
try_from
attempt to convert the encoded duration back to a WindowDuration
core/query_functions/src/window.rs:207
Method
try_from
(batch: RecordBatch)
core/iox_query_params/src/params.rs:255
Method
try_from
(storage: PackedStringArray<K>)
core/arrow_util/src/dictionary.rs:182
Method
try_from
(value: &PhysicalLimitExpr)
core/iox_query/src/exec/series_limit/physical.rs:964
Method
try_from
(value: TestRecords)
core/iox_query/src/exec/gapfill/exec_tests.rs:1429
Method
try_from
(mut s: Span)
core/trace_exporters/src/jaeger/span.rs:19
Method
try_from
(i: i32)
core/trace_exporters/src/thrift/jaeger.rs:48
Method
try_from
(i: i32)
core/trace_exporters/src/thrift/zipkincore.rs:50
Method
try_from
(value: proto::resource_action_permission::Action)
core/authz/src/permission.rs:27
Method
try_from
(v: u64)
core/generated_types/src/lib.rs:246
Method
try_from
(value: &AttributeValue)
core/object_store_metrics/src/cache_state.rs:110
Method
try_from
(req: &Request)
core/iox_http/src/write/v2.rs:40
Method
try_from
(req: &Request)
core/iox_http/src/write/v1.rs:77
Method
try_from
(data: &[u8])
core/data_types/src/partition.rs:379
Method
try_from
(value: i32)
core/data_types/src/lib.rs:79
Method
try_from
(value: ColumnsByName)
core/data_types/src/columns.rs:176
Method
try_from
An existing namepsace pulled from the catalog may contain a valid, but since disallowed partition template that would fail the validation checks perfo
core/data_types/src/partition_template.rs:678
Method
try_from
(v: &'a str)
core/data_types/src/namespace_name.rs:155
Method
try_from
(value: generated::HashBuckets)
core/data_types/src/snapshot/hash.rs:54
Method
try_from
(value: ArrowSchemaRef)
core/schema/src/lib.rs:212
Method
try_from
tries to create a new ValueExpr. If `expr` follows the expected pattrn, returns Ok(Self). If not, returns Err(expr)
core/predicate/src/lib.rs:323
Method
try_from
(value: PreparedStatementHandle)
core/flightsql/src/cmd.rs:160
Method
try_from
(v: &'a str)
influxdb3_types/src/database_name.rs:156
Method
try_from
(value: usize)
influxdb3_catalog/src/log/versions/v2.rs:481
Method
try_from
(value: usize)
influxdb3_catalog/src/log/versions/v1.rs:263
Method
try_from
(value: usize)
influxdb3_catalog/src/log/versions/v3.rs:596
Method
try_from
(value: usize)
influxdb3_catalog/src/log/versions/v4.rs:866
Method
try_from
((ans, catalog): (ApiNodeSpec, &Catalog))
influxdb3_catalog/src/catalog/versions/v2.rs:1537
Method
try_from
((ans, catalog): (ApiNodeSpec, &Catalog))
influxdb3_catalog/src/catalog/versions/v1.rs:490
Method
try_from
(value: super::ColumnDefinition)
influxdb3_catalog/src/catalog/versions/v2/legacy.rs:218
Method
try_from
(value: usize)
influxdb3_catalog/src/catalog/versions/v3/schema/cache.rs:157
Method
try_from
(dur: Duration)
influxdb3_wal/src/lib.rs:232
Method
try_from
(path: &'a Path)
influxdb3_wal/src/object_store.rs:953
Method
try_from_arg_types
Try to extract type from argument types that where passed into the aggregator UDF. The `name` is used to generated better error messages.
core/query_functions/src/selectors/type_handling.rs:165
Method
try_from_arrow
Create a new Schema wrapper over the schema All metadata validation is done on creation (todo maybe offer a fallible version where the checks are don
core/schema/src/lib.rs:503
Method
try_from_df_args
(args: &[ColumnarValue])
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:28
Method
try_from_existing
An existing table pulled from the catalog may contain a valid, but since disallowed partition template that would fail the validation checks performed
core/data_types/src/partition_template.rs:743
Method
try_from_headers
(headers: &HeaderMap)
influxdb3_types/src/http.rs:417
Method
try_from_proto
( resource_type: proto::resource_action_permission::ResourceType, resource_target: Option<prot
core/authz/src/permission.rs:128
Method
try_from_return_type
Try to exract types from [`return_type`](Self::return_type).
core/query_functions/src/selectors/type_handling.rs:132
Method
try_from_scalar_udf
Try to return the equivalent [`WindowFunction`] for `fun`.
core/iox_query_influxql/src/plan/udf.rs:36
Method
try_into_arrow
Converts this column to an arrow [`ArrayRef`]
core/mutable_batch/src/column.rs:231
Method
try_merge_key
Returns merge key of the 2 given keys if one covers the other. Returns None otherwise. Key1 is said to cover key2 if key2 is a subset and in the same
core/schema/src/sort.rs:186
Method
try_new
create a new `TrackedMemoryArrowWriter<`
influxdb3_write/src/persister.rs:1010
Method
try_new
create a new `TrackedMemoryArrowWriter<`
core/parquet_file/src/writer.rs:58
Method
try_new
( partition_id: &PartitionHashId, meta: &IoxMetadata, id: &StorageId, object_s
core/parquet_file/src/storage.rs:167
Method
try_new
Attempt to create a new [`NonOverlappingOrderedLexicalRanges`] given the specified [`SortOptions`]. See struct documentation for more details Return
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:172
Method
try_new
( input: Arc<LogicalPlan>, series_expr: Vec<Expr>, order_expr: Vec<SortExpr>,
core/iox_query/src/exec/series_limit/logical.rs:432
Method
try_new
Create a new SeriesLimitExec.
core/iox_query/src/exec/series_limit/physical.rs:313
Method
try_new
Creates a new GapFillStream.
core/iox_query/src/exec/gapfill/stream.rs:62
Method
try_new
Create a new gap-filling operator.
core/iox_query/src/exec/gapfill/mod.rs:124
Method
try_new
Create a new [GapFillParams] by figuring out the actual values (as native i64) for the stride, first and last timestamp for gap filling.
core/iox_query/src/exec/gapfill/params.rs:54
Method
try_new
( stride_ns: i64, ts_ns: i64, tz: &Option<impl AsRef<str>>, )
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:662
Method
try_new
Try to create a new adapter stream that produces batches with the specified output schema. Virtual columns that contain constant values may be added
core/iox_query/src/provider/adapter.rs:126
Method
try_new
Create a new allocation monitor that will return an error if the amount of memory allocated exceeds `max`.
core/jemalloc_stats/src/monitor.rs:50
Method
try_new
(record_batch_stream: S, schema: SchemaRef)
core/iox_v1_query_api/src/response/stream.rs:110
Method
try_new
When a new namespace is created, the request to do so may include a custom partition template. This must be validated before use, with additional cons
core/data_types/src/partition_template.rs:626
← previous
next →
11,501–11,600 of 11,906, ranked by callers