MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

Methodtry_new
( predicates: Option<IndexMap<ColumnId, Predicate>>, table_def: Arc<TableDefinition>,
influxdb3_cache/src/distinct_cache/table_function.rs:312
Methodtry_new
( predicates: Option<IndexMap<ColumnId, Predicate>>, table_def: Arc<TableDefinition>,
influxdb3_cache/src/last_cache/table_function.rs:385
Methodtry_new
( value: Py<PyAny>, ttl: Option<f64>, time_provider: Arc<dyn TimeProvider>, )
influxdb3_py_api/src/cache.rs:26
Methodtry_new
( trigger_spec: &TriggerSpecificationDefinition, time_provider: Arc<dyn TimeProvider>, )
influxdb3_processing_engine/src/plugins.rs:854
Methodtry_new_from_lexical_ranges
( sort_options: &[SortOptions], lexical_ranges: Vec<LexicalRange>, )
core/iox_query/src/physical_optimizer/sort/lexical_range.rs:291
Methodtry_update_catalog
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:348
Functiontwo_group_exprs
()
core/iox_query/src/analyzer/handle_gapfill.rs:1039
Methodtype_description
(&self)
core/partition/src/traits/mutable_batch.rs:35
Methodtype_description
(&self)
core/partition/src/traits/record_batch.rs:47
Functiontype_errors
()
core/iox_query/src/exec/split.rs:1267
Methodtype_info
()
core/data_types/src/partition.rs:183
Methodtype_info
()
core/data_types/src/columns.rs:364
Methodtype_info
()
core/data_types/src/partition_template.rs:1015
Methodtype_name
Return a human interpretable description of this type
core/data_types/src/lib.rs:2125
Functionu64_max_msgs_per_second
()
core/trace_exporters/src/rate_limiter.rs:63
Functionudf_http_allow_list_rejects_invalid_method
()
core/iox_query/src/config.rs:336
Functionudf_http_allow_list_rejects_invalid_port
()
core/iox_query/src/config.rs:330
Functionudf_http_allow_list_requires_three_parts
()
core/iox_query/src/config.rs:324
Methodudf_to_expr
Transform a UDF to a window expression.
core/iox_query_influxql/src/plan/planner.rs:1996
Methoduint64_field
Add an unsigned integer field to the line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:77
Functionunary
Parse a unary expression.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:395
Methodundelete_namespace
Restore a soft-deleted namespace
core/influxdb_iox_client/src/client/namespace.rs:139
Methodunexpected
(message: impl Into<String>)
influxdb3_catalog/src/object_store.rs:22
Methodunexpected
(message: impl Into<String>)
influxdb3_catalog/src/error.rs:317
Methodunion_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
Methodunion_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
Methodunknown
Return a `Error::Unknown` variant with the specified message
core/influxdb_iox_client/src/client/error.rs:147
Functionunknown_non_upgrade_safe_returns_error
()
influxdb3_catalog/src/format/registry/tests.rs:58
Functionunknown_record_id_renders_hex_not_panic
()
influxdb3_catalog/src/format/view/tests.rs:40
Functionunknown_upgrade_safe_returns_false
()
influxdb3_catalog/src/format/registry/tests.rs:52
Methodunlock
(&self)
core/tracker/src/lock.rs:355
Methodunlock_exclusive
(&self)
core/tracker/src/lock.rs:227
Methodunlock_shared
(&self)
core/tracker/src/lock.rs:187
Methodunlock_upgradable
(&self)
core/tracker/src/lock.rs:277
Functionunquoted_parameter
Parse an unquoted InfluxQL bind parameter.
core/influxdb_influxql_parser/src/parameter.rs:52
Methodunregister
(&self, _consumer: &MemoryConsumer)
core/iox_query/src/memory_pool.rs:76
Methodunregister_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
Functionunregister_node_idempotent_when_already_gone
()
influxdb3_catalog/src/format/records/node/tests.rs:670
Functionunregister_node_purges_entry
()
influxdb3_catalog/src/format/records/node/tests.rs:625
Functionunregister_node_rejects_unless_removing
()
influxdb3_catalog/src/format/records/node/tests.rs:654
Functionunregister_node_round_trip
()
influxdb3_catalog/src/format/records/node/tests.rs:297
Functionunregister_rejected_unless_removing
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:521
Functionunregister_succeeds_when_removing
()
influxdb3_catalog/src/catalog/versions/v3/ops/node/tests.rs:534
Methodunsequenced
Create a new [`DmlMeta`] for an unsequenced operation
core/dml/src/lib.rs:29
Functionunset_falls_back_to_catalog_id
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:2486
Methodunsubscribe
(&mut self, name: &str)
influxdb3_catalog/src/channel/versions/v2.rs:216
Functionunsubscribe_drops_the_named_subscription
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:3771
Methodunsubscribe_from_updates
(&self, name: &str)
influxdb3_catalog/src/catalog/versions/v2.rs:581
Methodunsupported_message_type
(description: impl Into<String>)
core/service_grpc_flight/src/lib.rs:418
Methodunsupported_type
(type_name: &'static str)
core/iox_query_params/src/params.rs:583
Methodunwrap_bool
(&self)
core/influxdb_line_protocol/src/lib.rs:1395
Methodunwrap_f64
(&self)
core/influxdb_line_protocol/src/lib.rs:1381
Methodunwrap_i64
(&self)
core/influxdb_line_protocol/src/lib.rs:1367
Methodunwrap_string
(&self)
core/influxdb_line_protocol/src/lib.rs:1388
Methodunwrap_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
Methodunwrap_success
(self)
influxdb3_catalog/src/catalog/versions/v1/update.rs:1032
Methodunwrap_u64
(&self)
core/influxdb_line_protocol/src/lib.rs:1374
Methodupcast
(&self)
influxdb3_authz/src/authorizer.rs:172
Methodupcast
(&self)
influxdb3_query_executor/src/lib.rs:280
Methodupcast
(&self)
influxdb3_internal_api/src/query_executor.rs:284
Methodupdate
Execute an op and return just its output. See [`Self::update_committed`].
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:2530
Methodupdate_admin_token_hash
( &mut self, token_id: TokenId, hash: Vec<u8>, updated_at: i64, )
influxdb3_catalog/src/catalog.rs:249
Methodupdate_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/spread.rs:136
Methodupdate_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/percentile.rs:131
Methodupdate_batch
(&mut self, values: &[ArrayRef])
core/iox_query_influxql/src/aggregate/mode.rs:220
Functionupdate_broadcasts_to_subscribers
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:171
Functionupdate_catches_up_when_gate_fails_on_stale_view
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:1872
Methodupdate_columns
( mut table: Cow<'a, Self>, columns: &Vec<ColumnDefinitionLog>, )
influxdb3_catalog/src/catalog/versions/v2.rs:3349
Methodupdate_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
Methodupdate_field_families
( mut table: Cow<'a, Self>, families: &Vec<FieldFamilyDefinitionLog>, )
influxdb3_catalog/src/catalog/versions/v2.rs:3315
Methodupdate_from_arg_matches
(&mut self, matches: &clap::ArgMatches)
influxdb3/src/commands/create/token.rs:328
Methodupdate_from_snapshot
(&self, snapshot: CatalogSnapshot)
influxdb3_catalog/src/catalog/versions/v1.rs:182
Functionupdate_label
()
core/influxdb2_client/src/api/label.rs:252
Functionupdate_label_opt
()
core/influxdb2_client/src/api/label.rs:280
Functionupdate_login_identity_password_hash_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:94
Functionupdate_login_identity_requires_password_reset_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:106
Methodupdate_metrics
(&self, metrics: IngesterQueryMetricsState)
core/iox_query/src/ingester.rs:35
Methodupdate_namespace_name
Rename a namespace
core/influxdb_iox_client/src/client/namespace.rs:153
Methodupdate_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
Methodupdate_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
Methodupdate_node_state_stopped
( &self, node_id: &str, process_uuid_getter: Arc<dyn ProcessUuidGetter>, )
influxdb3_catalog/src/catalog/versions/v1/update.rs:203
Methodupdate_num_queries
(&mut self)
influxdb3_telemetry/src/bucket.rs:28
Methodupdate_password_hash
( &self, user_id: UserId, password_hash: Arc<str>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3224
Functionupdate_persists_applies_and_advances_sequence
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:157
Methodupdate_requires_password_reset
( &self, user_id: UserId, requires_password_reset: bool, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3238
Functionupdate_retries_on_already_exists
()
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:193
Methodupdate_role
(&mut self, role: Role)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:59
Functionupdate_role_op
()
influxdb3_catalog/src/catalog/versions/v3/ops/role/tests.rs:30
Methodupdate_role_permissions
( &self, role_id: RoleId, permissions: Vec<influxdb3_authz::role::Permission>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3324
Functionupdate_role_permissions_roundtrip
()
influxdb3_catalog/src/format/records/role/tests.rs:72
Functionupdate_role_roundtrip
()
influxdb3_catalog/src/format/records/role/tests.rs:84
Functionupdate_snapshot_replaces_existing
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:118
Functionupdate_string
()
core/data_types/src/lib.rs:2968
Methodupdate_token
(&mut self, token_id: TokenId, token_info: TokenInfo)
influxdb3_catalog/src/catalog.rs:279
Methodupdate_user_display_name
( &self, user_id: UserId, display_name: Option<Arc<str>>, )
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3210
Functionupdate_user_display_name_op
()
influxdb3_catalog/src/catalog/versions/v3/ops/user/tests.rs:29
Functionupdate_user_display_name_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:45
Methodupdate_user_roles
(&self, user_id: UserId, role_ids: Vec<RoleId>)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3122
Functionupdate_user_roles_roundtrip
()
influxdb3_catalog/src/format/records/user/tests.rs:159
Methodupdated_at_ns
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:975
← previousnext →11,601–11,700 of 11,906, ranked by callers