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
↓ 2 callersFunctionwrap_multipart_upload_res
( res: Result<Box<dyn MultipartUpload>>, mut recorder: MetricsWithBytesRecorder, )
core/object_store_metrics/src/lib.rs:551
↓ 2 callersMethodwrite_batch
Write the provided MutableBatch
core/mutable_batch/src/writer.rs:708
↓ 2 callersMethodwrite_batch_ranges
Write the rows identified by `ranges` to the provided MutableBatch
core/mutable_batch/src/writer.rs:761
↓ 2 callersMethodwrite_checkpoint
Overwrite the snapshot file to shorten the log replay chain. Old log files are left in place; `load_catalog` ignores logs at sequences ≤ the snapshot
influxdb3_catalog/src/object_store/versions/v3.rs:364
↓ 2 callersMethodwrite_f64s_from_slice
ALMOST Functionally equivalent to calling [`Self::write_f64`] with an all-valid valid mask, but more performant when your values already exist in a sl
core/mutable_batch/src/writer.rs:292
↓ 2 callersFunctionwrite_file_atomically
Write a file atomically by writing to a temporary file and moving it into place This ensures the file either exists with correct permissions or doesn'
influxdb3/src/commands/create/token.rs:373
↓ 2 callersMethodwrite_from_slice_with_col_ty
( &mut self, name: &str, values: &[V], col_ty: InfluxColumnType, )
core/mutable_batch/src/writer.rs:216
↓ 2 callersMethodwrite_lp_stream
Write the stream of [LineProtocol] formatted strings in `sources` to database `database`. It is assumed that individual lines (points) do not cross th
core/influxdb_iox_client/src/client/write.rs:181
↓ 2 callersMethodwrite_lp_to_write_batch
( &self, lp: impl AsRef<str>, time_ns: i64, )
influxdb3_write/src/lib.rs:936
↓ 2 callersFunctionwrite_plugin_to_temp_dir
(temp_dir: &TempDir, name: &str, code: &str)
influxdb3/tests/cli/mod.rs:52
↓ 2 callersMethodwrite_reporter
Get the [`QueryReporter`] along with the path of the file it is generating as a `String`
influxdb3_load_generator/src/commands/common.rs:261
↓ 2 callersMethodwrite_sample_to
( &mut self, sample_time: DateTime<Local>, mut w: W, rng: &mut impl RngCore,
influxdb3_load_generator/src/line_protocol_generator.rs:273
↓ 2 callersMethodwrite_span_id
(&mut self, id: &Id)
core/logfmt/src/lib.rs:181
↓ 2 callersMethodwrite_spec
(&mut self)
influxdb3_load_generator/src/commands/common.rs:233
↓ 2 callersMethodwrite_timestamp
(&mut self)
core/logfmt/src/lib.rs:185
↓ 2 callersMethodwrite_to
( &mut self, writer_id: WriterId, w: &mut ByteCounter<W>, )
influxdb3_load_generator/src/line_protocol_generator.rs:374
↓ 2 callersMethodwrite_to_out_protocol
(&self, o_prot: &mut dyn TOutputProtocol)
core/trace_exporters/src/thrift/jaeger.rs:39
↓ 2 callersMethodwrite_to_out_protocol
(&self, o_prot: &mut dyn TOutputProtocol)
core/trace_exporters/src/thrift/agent.rs:243
↓ 2 callersMethodwrite_to_out_protocol
(&self, o_prot: &mut dyn TOutputProtocol)
core/trace_exporters/src/thrift/zipkincore.rs:41
↓ 2 callersMethodwrite_u64s_from_slice
ALMOST Functionally equivalent to calling [`Self::write_u64`] with an all-valid valid mask, but more performant when your values already exist in a sl
core/mutable_batch/src/writer.rs:406
↓ 2 callersMethodwrite_wal_contents_to_caches
Update the caches managed by the database
influxdb3_write/src/write_buffer/queryable_buffer.rs:147
↓ 2 callersFunctionwriter_props
Helper to construct [`WriterProperties`] for a list of given [`KeyValue`] metadata values. The configuration used here should be the same as in [`par
core/parquet_file/src/serialize.rs:373
↓ 2 callersFunctionws1
Must consume either whitespace, single-line or inline comments
core/influxdb_influxql_parser/src/common.rs:206
↓ 1 callersMethod_escape_field_key
Escape characters in field keys according to line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:62
↓ 1 callersMethod_escape_measurement
Escape characters in measurement names according to line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:49
↓ 1 callersMethod_escape_tag_value
Escape characters in tag values according to line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:53
↓ 1 callersMethodaccept
(&mut self, visitor: &mut V)
core/influxdb_influxql_parser/src/visit_mut.rs:639
↓ 1 callersFunctionaccount_admin_role_definition
()
influxdb3_authz/src/role/role_defaults.rs:13
↓ 1 callersMethodacquire_execution_semaphore
( &self, span: Option<Span>, )
influxdb3_query_executor/src/lib.rs:509
↓ 1 callersFunctionacquire_semaphore
( semaphore: Arc<InstrumentedAsyncSemaphore>, span: Option<Span>, )
influxdb3_query_executor/src/lib.rs:521
↓ 1 callersMethodacquire_snapshot_permit
(&self)
influxdb3_wal/src/object_store.rs:757
↓ 1 callersMethodactive_triggers
Get active (non-disabled) triggers by (database id, trigger id).
influxdb3_catalog/src/catalog/versions/v2.rs:917
↓ 1 callersMethodadd_action
(&mut self, new_allowed_actions: &ActionsBitmap)
influxdb3_authz/src/permissions.rs:250
↓ 1 callersMethodadd_callback
Register callback that is called when the trailers are sent.
core/tower_trailer/src/lib.rs:160
↓ 1 callersMethodadd_column
Add `col` to this table schema. # Panics This method panics if a column of the same name already exists in `self`, or if `col` references a differen
core/data_types/src/lib.rs:851
↓ 1 callersMethodadd_column
( &mut self, column_name: Arc<str>, column_type: InfluxColumnType, )
influxdb3_catalog/src/catalog/versions/v1.rs:1651
↓ 1 callersMethodadd_column_schema
Add the name and column schema to this table's schema. # Panics This method panics if a column of the same name already exists in `self`.
core/data_types/src/lib.rs:871
↓ 1 callersFunctionadd_columns_op
( database_id: impl Into<DbId>, db_name: impl Into<Arc<str>>, table_id: impl Into<TableId>, ta
influxdb3_catalog/src/catalog/versions/v2/create.rs:23
↓ 1 callersMethodadd_cpu_utilization
(&mut self, cpu_used: f32)
influxdb3_telemetry/src/store.rs:390
↓ 1 callersMethodadd_debug_header
Merges result of the gRPC debug header into the is_debug field of this request using boolean or logic
core/service_grpc_flight/src/request.rs:202
↓ 1 callersFunctionadd_encoded_arrow_schema_to_metadata
When encoding to parquet, the ArrowWriter persists the arrow schema, keyed to [`ARROW_SCHEMA_META_KEY`] in the parquet metadata. This occurs as the d
core/arrow_util/src/parquet_meta.rs:44
↓ 1 callersMethodadd_field
(&mut self, name: &str, field_type: InfluxFieldType)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:576
↓ 1 callersMethodadd_fill_strategy
(&mut self, e: Expr, fs: FillStrategy, name: String)
core/iox_query/src/analyzer/handle_gapfill.rs:567
↓ 1 callersMethodadd_login_identity_oauth
( &mut self, user_id: UserId, identity: LoginIdentityOAuth, )
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:354
↓ 1 callersMethodadd_login_identity_username_password
Add a username/password login identity to an existing user
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:248
↓ 1 callersMethodadd_memory
(&mut self, value: u64)
influxdb3_telemetry/src/store.rs:384
↓ 1 callersMethodadd_no_op
(&mut self)
influxdb3_wal/src/object_store.rs:810
↓ 1 callersMethodadd_one_value
(&mut self)
core/data_types/src/lib.rs:1904
↓ 1 callersMethodadd_parquet_file
Add the parquet file the list of files to be scanned, updating the sort key as necessary.
core/iox_query/src/provider/physical.rs:71
↓ 1 callersMethodadd_persisted_file
Add a single parquet file to the tracked files for a specific table. Called from `QueryableBuffer` after persistence and from `Replica` during backgr
influxdb3_write/src/write_buffer/persisted_files.rs:152
↓ 1 callersMethodadd_response_body_size
Register additional response body size.
core/trace_http/src/metrics.rs:261
↓ 1 callersMethodadd_role
(&mut self, role: Role)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:54
↓ 1 callersMethodadd_rows
(&mut self, rows: &[Row])
influxdb3_write/src/write_buffer/table_buffer.rs:308
↓ 1 callersFunctionadd_sort_preserving_merge
Add SortPreservingMerge to the plan with many partitions to ensure the order is preserved
core/iox_query/src/physical_optimizer/sort/util.rs:11
↓ 1 callersMethodadd_tag
(&mut self, name: &str)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:552
↓ 1 callersMethodadd_time
(&mut self)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:535
↓ 1 callersMethodadd_user
(&mut self, user: UserInfo)
influxdb3_catalog/src/catalog/versions/v3/schema/user.rs:148
↓ 1 callersMethodadd_write_batch
(&mut self, write_batch: &WriteBatch)
influxdb3_write/src/write_buffer/queryable_buffer.rs:519
↓ 1 callersMethodadd_write_batch
( &mut self, new_table_chunks: SerdeVecMap<TableId, TableChunks>, min_time_ns: i64,
influxdb3_wal/src/lib.rs:325
↓ 1 callersMethodadjust_for_discontinuity
(&mut self, next_utc_offset_ns: i64)
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:680
↓ 1 callersMethodaggregate_child
(&mut self, child: &Self)
core/iox_query/src/exec/query_tracing.rs:238
↓ 1 callersFunctionaggregate_system_data
(file_path)
influxdb3_load_generator/analysis/app.py:96
↓ 1 callersMethodall
()
core/panic_logging/src/lib.rs:140
↓ 1 callersMethodall_iter
Returns an iterator of `(Option<InfluxColumnType>, &Field)` for all the columns of this schema, in order
core/schema/src/lib.rs:758
↓ 1 callersMethodall_roles
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:72
↓ 1 callersMethodallocation_size
Size of the underlying allocation in bytes.
core/linear_buffer/src/linear_buffer.rs:261
↓ 1 callersMethodallows
Whether `record_id` is compatible with this feature level.
influxdb3_catalog/src/format/feature_level.rs:34
↓ 1 callersMethodalready_loading
Returns `true` if the loader already had a running task when [`Loader::load`] was called.
core/object_store_mem_cache/src/cache_system/loader.rs:257
↓ 1 callersFunctionany_options_set
Returns `true` if ANY options are set.
core/object_store_mem_cache/src/object_store_helpers.rs:7
↓ 1 callersMethodapi_v3_configure_create_admin_token
Create an admin token
influxdb3_client/src/lib.rs:946
↓ 1 callersMethodapi_v3_configure_create_named_admin_token
Create "named" admin tokens
influxdb3_client/src/lib.rs:961
↓ 1 callersMethodapi_v3_configure_db_delete
Make a request to the `DELETE /api/v3/configure/database?db=foo` API
influxdb3_client/src/lib.rs:527
↓ 1 callersMethodapi_v3_configure_db_delete_with_hard_delete
Make a request to the `DELETE /api/v3/configure/database` API with hard delete option
influxdb3_client/src/lib.rs:544
↓ 1 callersMethodapi_v3_configure_db_show
Compose a request to the `GET /api/v3/configure/database` API
influxdb3_client/src/lib.rs:474
↓ 1 callersMethodapi_v3_configure_db_update
Make a request to the `PUT /api/v3/configure/database` API
influxdb3_client/src/lib.rs:506
↓ 1 callersMethodapi_v3_configure_distinct_cache_create
( &self, request: &serde_json::Value, )
influxdb3/tests/server/mod.rs:1040
↓ 1 callersMethodapi_v3_configure_distinct_cache_delete
( &self, request: &serde_json::Value, )
influxdb3/tests/server/mod.rs:1055
↓ 1 callersMethodapi_v3_configure_last_cache_delete
Make a request to the `DELETE /api/v3/configure/last_cache` API
influxdb3_client/src/lib.rs:398
↓ 1 callersMethodapi_v3_configure_plugin_environment_install_packages
Make a request to `POST /api/v3/configure/plugin_environment/install_packages`
influxdb3_client/src/lib.rs:763
↓ 1 callersMethodapi_v3_configure_processing_engine_trigger_create
( &self, db: impl Into<String> + Send, trigger_name: impl Into<String> + Send,
influxdb3_client/src/lib.rs:688
↓ 1 callersMethodapi_v3_configure_processing_engine_trigger_delete
Make a request to `DELETE /api/v3/configure/processing_engine_trigger`
influxdb3_client/src/lib.rs:719
↓ 1 callersMethodapi_v3_configure_processing_engine_trigger_disable
Make a request to `POST /api/v3/configure/processing_engine_trigger/disable`
influxdb3_client/src/lib.rs:799
↓ 1 callersMethodapi_v3_configure_processing_engine_trigger_enable
Make a request to `POST /api/v3/configure/processing_engine_trigger/enable`
influxdb3_client/src/lib.rs:742
↓ 1 callersMethodapi_v3_configure_processing_engine_trigger_install_requirements
Make a request to `POST /api/v3/configure/plugin_environment/install_requirements`
influxdb3_client/src/lib.rs:780
↓ 1 callersMethodapi_v3_configure_regenerate_admin_token
regenerate admin token
influxdb3_client/src/lib.rs:981
↓ 1 callersMethodapi_v3_configure_table_delete
Make a request to the `DELETE /api/v3/configure/table?db=foo&table=bar` API
influxdb3_client/src/lib.rs:565
↓ 1 callersMethodapi_v3_configure_table_delete_with_hard_delete
Make a request to the `DELETE /api/v3/configure/table` API with hard delete option
influxdb3_client/src/lib.rs:587
↓ 1 callersMethodapi_v3_configure_token_delete
Delete token `DELETE /api/v3/configure/token?token_name=foo` API
influxdb3_client/src/lib.rs:996
↓ 1 callersMethodapi_v3_create_table
( &self, database: &str, table: &str, tags: Vec<String>, fields: Vec<(
influxdb3/tests/server/mod.rs:918
↓ 1 callersMethodapi_v3_query_sql_with_header
( &self, params: &[(&str, &str)], headers: HeaderMap<HeaderValue>, )
influxdb3/tests/server/mod.rs:932
↓ 1 callersMethodapi_v3_replace_plugin_directory
Replace an entire plugin directory atomically
influxdb3_client/src/lib.rs:863
↓ 1 callersMethodapi_v3_update_plugin_file
Update a plugin file
influxdb3_client/src/lib.rs:852
↓ 1 callersMethodappend_series_items
Helper method that generates output for one series by invoking [VecBuilder::push] for each output value in the column to be generated.
core/iox_query/src/exec/gapfill/algo.rs:743
↓ 1 callersMethodapply_catalog_batch
Verifies _and_ applies the `CatalogBatch` to the catalog.
influxdb3_catalog/src/catalog/versions/v1.rs:572
↓ 1 callersMethodapply_database_batch
(&mut self, database_batch: &DatabaseBatch)
influxdb3_catalog/src/catalog/versions/v1.rs:706
↓ 1 callersMethodapply_delete_batch
(&mut self, delete_batch: &DeleteBatch)
influxdb3_catalog/src/catalog/versions/v1.rs:775
↓ 1 callersMethodapply_expressions
( &self, mut f: F, )
core/iox_query/src/exec/series_limit/logical.rs:492
↓ 1 callersFunctionapply_filter
Calculates [`Statistics`] by applying selectivity (either default, or estimated) to input statistics. This is a (slightly) modified from a private fu
core/iox_query/src/statistics/partition_statistics/filter.rs:14
↓ 1 callersMethodapply_generation_batch
(&mut self, generation_batch: &GenerationBatch)
influxdb3_catalog/src/catalog/versions/v2.rs:2034
↓ 1 callersMethodapply_generation_batch
(&mut self, generation_batch: &GenerationBatch)
influxdb3_catalog/src/catalog/versions/v1.rs:846
← previousnext →3,101–3,200 of 11,906, ranked by callers