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
try_new
( predicates: Option<IndexMap<ColumnId, Predicate>>, table_def: Arc<TableDefinition>,
influxdb3_cache/src/distinct_cache/table_function.rs:312
Method
try_new
( predicates: Option<IndexMap<ColumnId, Predicate>>, table_def: Arc<TableDefinition>,
influxdb3_cache/src/last_cache/table_function.rs:385
Method
try_new
( value: Py<PyAny>, ttl: Option<f64>, time_provider: Arc<dyn TimeProvider>, )
influxdb3_py_api/src/cache.rs:26
Method
try_new
( trigger_spec: &TriggerSpecificationDefinition, time_provider: Arc<dyn TimeProvider>, )
influxdb3_processing_engine/src/plugins.rs:854
Method
try_new_from_lexical_ranges
( sort_options: &[SortOptions], lexical_ranges: Vec<LexicalRange>, )
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:291
Method
try_update_catalog
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:348
Function
two_group_exprs
()
core/iox_query/src/analyzer/handle_gapfill.rs:1039
Method
type_description
(&self)
core/partition/src/traits/mutable_batch.rs:35
Method
type_description
(&self)
core/partition/src/traits/record_batch.rs:47
Function
type_errors
()
core/iox_query/src/exec/split.rs:1267
Method
type_info
()
core/data_types/src/partition.rs:183
Method
type_info
()
core/data_types/src/columns.rs:364
Method
type_info
()
core/data_types/src/partition_template.rs:1015
Method
type_name
Return a human interpretable description of this type
core/data_types/src/lib.rs:2125
Function
u64_max_msgs_per_second
()
core/trace_exporters/src/rate_limiter.rs:63
Function
udf_http_allow_list_rejects_invalid_method
()
core/iox_query/src/config.rs:336
Function
udf_http_allow_list_rejects_invalid_port
()
core/iox_query/src/config.rs:330
Function
udf_http_allow_list_requires_three_parts
()
core/iox_query/src/config.rs:324
Method
udf_to_expr
Transform a UDF to a window expression.
core/iox_query_influxql/src/plan/planner.rs:1996
Method
uint64_field
Add an unsigned integer field to the line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:77
Function
unary
Parse a unary expression.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:395
Method
undelete_namespace
Restore a soft-deleted namespace
core/influxdb_iox_client/src/client/namespace.rs:139
Method
unexpected
(message: impl Into<String>)
influxdb3_catalog/src/object_store.rs:22
Method
unexpected
(message: impl Into<String>)
influxdb3_catalog/src/error.rs:317
Method
union_plan
Build a test physical plan like the following, and extract disjoint ranges from it: ```text UNION DataSourceExec (key_ranges[0]) (rang
core/iox_query/src/physical_optimizer/sort/extract_ranges.rs:709
Method
union_sort_union_plan
Build a test physical plan like the following, and extract disjoint ranges from it: ```text UNION DataSourceExec (key_ranges[0]) (range_a)
core/iox_query/src/physical_optimizer/sort/extract_ranges.rs:655
Method
unknown
Return a `Error::Unknown` variant with the specified message
core/influxdb_iox_client/src/client/error.rs:147
Function
unknown_non_upgrade_safe_returns_error
()
influxdb3_catalog/src/format/registry/tests.rs:58
Function
unknown_record_id_renders_hex_not_panic
()
influxdb3_catalog/src/format/view/tests.rs:40
Function
unknown_upgrade_safe_returns_false
()
influxdb3_catalog/src/format/registry/tests.rs:52
Method
unlock
(&self)
core/tracker/src/lock.rs:355
Method
unlock_exclusive
(&self)
core/tracker/src/lock.rs:227
Method
unlock_shared
(&self)
core/tracker/src/lock.rs:187
Method
unlock_upgradable
(&self)
core/tracker/src/lock.rs:277
Function
unquoted_parameter
Parse an unquoted InfluxQL bind parameter.
core/influxdb_influxql_parser/src/parameter.rs:52
Method
unregister
(&self, _consumer: &MemoryConsumer)
core/iox_query/src/memory_pool.rs:76
Method
unregister_node
Permanently unregister a node from the catalog. Called by the compactor's node_removal driver after object-store cleanup completes.
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1639
Function
unregister_node_idempotent_when_already_gone
()
influxdb3_catalog/src/format/records/node/tests.rs:670
Function
unregister_node_purges_entry
()
influxdb3_catalog/src/format/records/node/tests.rs:625
Function
unregister_node_rejects_unless_removing
()
influxdb3_catalog/src/format/records/node/tests.rs:654
Function
unregister_node_round_trip
()
influxdb3_catalog/src/format/records/node/tests.rs:297
Function
unregister_rejected_unless_removing
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:521
Function
unregister_succeeds_when_removing
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:534
Method
unsequenced
Create a new [`DmlMeta`] for an unsequenced operation
core/dml/src/lib.rs:29
Function
unset_falls_back_to_catalog_id
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2486
Method
unsubscribe
(&mut self, name: &str)
influxdb3_catalog/src/channel/versions/v2.rs:216
Function
unsubscribe_drops_the_named_subscription
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3771
Method
unsubscribe_from_updates
(&self, name: &str)
influxdb3_catalog/src/catalog/versions/v2.rs:581
Method
unsupported_message_type
(description: impl Into<String>)
core/service_grpc_flight/src/lib.rs:418
Method
unsupported_type
(type_name: &'static str)
core/iox_query_params/src/params.rs:583
Method
unwrap_bool
(&self)
core/influxdb_line_protocol/src/lib.rs:1395
Method
unwrap_f64
(&self)
core/influxdb_line_protocol/src/lib.rs:1381
Method
unwrap_i64
(&self)
core/influxdb_line_protocol/src/lib.rs:1367
Method
unwrap_string
(&self)
core/influxdb_line_protocol/src/lib.rs:1388
Method
unwrap_success
Extract the `Success` payload, panicking if this is a `Retry`. Convenience for tests / call sites that have already filtered.
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:76
Method
unwrap_success
(self)
influxdb3_catalog/src/catalog/versions/v1/update.rs:1032
Method
unwrap_u64
(&self)
core/influxdb_line_protocol/src/lib.rs:1374
Method
upcast
(&self)
influxdb3_authz/src/authorizer.rs:172
Method
upcast
(&self)
influxdb3_query_executor/src/lib.rs:280
Method
upcast
(&self)
influxdb3_internal_api/src/query_executor.rs:284
Method
update
Execute an op and return just its output. See [`Self::update_committed`].
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2530
Method
update_admin_token_hash
( &mut self, token_id: TokenId, hash: Vec<u8>, updated_at: i64, )
influxdb3_catalog/src/catalog.rs:249
Method
update_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/spread.rs:136
Method
update_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/percentile.rs:131
Method
update_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/mode.rs:220
Function
update_broadcasts_to_subscribers
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:171
Function
update_catches_up_when_gate_fails_on_stale_view
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1872
Method
update_columns
( mut table: Cow<'a, Self>, columns: &Vec<ColumnDefinitionLog>, )
influxdb3_catalog/src/catalog/versions/v2.rs:3349
Method
update_committed
Execute an op: prepare → persist → apply → broadcast, returning its output along with the sequence number and timestamp it was applied at. On `Persis
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2540
Method
update_field_families
( mut table: Cow<'a, Self>, families: &Vec<FieldFamilyDefinitionLog>, )
influxdb3_catalog/src/catalog/versions/v2.rs:3315
Method
update_from_arg_matches
(&mut self, matches: &clap::ArgMatches)
influxdb3/src/commands/create/token.rs:328
Method
update_from_snapshot
(&self, snapshot: CatalogSnapshot)
influxdb3_catalog/src/catalog/versions/v1.rs:182
Function
update_label
()
core/influxdb2_client/src/api/label.rs:252
Function
update_label_opt
()
core/influxdb2_client/src/api/label.rs:280
Function
update_login_identity_password_hash_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:94
Function
update_login_identity_requires_password_reset_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:106
Method
update_metrics
(&self, metrics: IngesterQueryMetricsState)
core/iox_query/src/ingester.rs:35
Method
update_namespace_name
Rename a namespace
core/influxdb_iox_client/src/client/namespace.rs:153
Method
update_namespace_retention
Update retention for a namespace `retention_period_ns` is the the retention period in nanoseconds, measured from `now()`. `None` represents infinite
core/influxdb_iox_client/src/client/namespace.rs:84
Method
update_namespace_service_protection_limit
Update one of the service protection limits for a namespace `limit_update` is the new service limit protection limit to set on the namespace. Zero-v
core/influxdb_iox_client/src/client/namespace.rs:106
Method
update_node_state_stopped
( &self, node_id: &str, process_uuid_getter: Arc<dyn ProcessUuidGetter>, )
influxdb3_catalog/src/catalog/versions/v1/update.rs:203
Method
update_num_queries
(&mut self)
influxdb3_telemetry/src/bucket.rs:28
Method
update_password_hash
( &self, user_id: UserId, password_hash: Arc<str>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3224
Function
update_persists_applies_and_advances_sequence
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:157
Method
update_requires_password_reset
( &self, user_id: UserId, requires_password_reset: bool, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3238
Function
update_retries_on_already_exists
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:193
Method
update_role
(&mut self, role: Role)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:59
Function
update_role_op
()
influxdb3_catalog/src/catalog/versions/v3/ops/role/tests.rs:30
Method
update_role_permissions
( &self, role_id: RoleId, permissions: Vec<influxdb3_authz::role::Permission>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3324
Function
update_role_permissions_roundtrip
()
influxdb3_catalog/src/format/records/role/tests.rs:72
Function
update_role_roundtrip
()
influxdb3_catalog/src/format/records/role/tests.rs:84
Function
update_snapshot_replaces_existing
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:118
Function
update_string
()
core/data_types/src/lib.rs:2968
Method
update_token
(&mut self, token_id: TokenId, token_info: TokenInfo)
influxdb3_catalog/src/catalog.rs:279
Method
update_user_display_name
( &self, user_id: UserId, display_name: Option<Arc<str>>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3210
Function
update_user_display_name_op
()
influxdb3_catalog/src/catalog/versions/v3/ops/user/tests.rs:29
Function
update_user_display_name_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:45
Method
update_user_roles
(&self, user_id: UserId, role_ids: Vec<RoleId>)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3122
Function
update_user_roles_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:159
Method
updated_at_ns
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:975
← previous
next →
11,601–11,700 of 11,906, ranked by callers