MCPcopy Create free account

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

Methodif_not_deleted
(self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:461
Methodif_not_deleted
(self)
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:282
Functionillegal_attribute_name
()
core/metric/src/lib.rs:558
Functionillegal_metric_name
()
core/metric/src/lib.rs:551
Methodin_mem
Create data based on batches and schema.
core/iox_query/src/lib.rs:226
Methodin_use
(&mut self)
core/object_store_mem_cache/src/store.rs:128
Methodin_use
For arc'ed references (e.g. `Arc<V>` or nested arc'ed values within V), check the strong count and the inner usage, since an inner Arc may still be he
core/object_store_mem_cache/src/cache_system/mod.rs:117
Methodin_use
(&mut self)
core/object_store_mem_cache/src/cache_system/test_utils.rs:709
Methodin_use
(&mut self)
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:667
Methodinclude_rank
(&self)
core/iox_query_influxql/src/window/percent_row_number.rs:102
Methodinclude_rank
(&self)
core/iox_query_influxql/src/window/integral.rs:248
Methodinclude_rank
(&self)
core/iox_query_influxql/src/window/cumulative_sum.rs:88
Methodinclude_rank
(&self)
core/iox_query_influxql/src/window/moving_average.rs:122
Methodinclude_rank
(&self)
core/query_functions/src/non_negative.rs:151
Methodinclude_rank
(&self)
core/query_functions/src/derivative.rs:232
Methodinclude_rank
(&self)
core/query_functions/src/difference.rs:95
Functionindex
()
influxdb3_load_generator/analysis/app.py:14
Methodindex
(&self, index: usize)
influxdb3_catalog/src/catalog/versions/v2/legacy.rs:143
Methodindex
(&self, index: usize)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:132
Methodindex_column_ids
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3491
Methodindex_column_ids
(&self)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:52
Methodindex_column_ids
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/table.rs:350
Functioninfluxdb3_py_api
(_m: &Bound<'_, PyModule>)
influxdb3_py_api/src/system_py.rs:832
Methodinfluxql
Query the given database with the given InfluxQL query, returning a struct that can stream Arrow [`RecordBatch`] results.
core/influxdb_iox_client/src/client/flight/mod.rs:284
Methodinfluxql
Builds an InfluxQL query from the given string.
core/influxdb_iox_client/src/client/flight/query.rs:114
Functioninfluxql_logs
(c: &mut Criterion)
core/mutable_batch_pb/benches/write_table_batch.rs:90
Functioninfluxql_returns_raw_query
()
core/service_grpc_flight/src/request.rs:1063
Functioninfo
Print an info message formatted like the logging system output.
influxdb3_startup/src/early_logging.rs:26
Methodinfo
(&self, py: Python<'_>, args: &Bound<'_, PyTuple>)
influxdb3_py_api/src/system_py.rs:77
Functioninfo_not_expanded
()
influxdb3/src/lib_tests.rs:118
Functioninitial_construction_is_correct
()
core/table_batch/src/builder/null_mask.rs:302
Methodinitialize
Initialize the [`WriteValidator`] by starting a catalog transaction on the given database with name `db_name`. This initializes the database if it doe
influxdb3_write/src/write_buffer/validator.rs:101
Methodinitialize
(spec: &ParamSpec, querier_id: QuerierId, querier_count: usize)
influxdb3_load_generator/src/query_generator.rs:99
Functioninitialize_and_load_snapshot_round_trip
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:58
Functioninitialize_snapshot_twice_returns_already_exists
()
influxdb3_catalog/src/object_store/versions/v3/tests.rs:106
Methodinitialized_bytes
Number of initialized bytes.
core/linear_buffer/src/linear_buffer.rs:114
Methodinner
(&self)
core/object_store_mem_cache/src/store.rs:434
Methodinner
(&self)
core/arrow_util/src/string.rs:150
Methodinner
Return a reference to the underlying [`FlightClient`]
core/influxdb_iox_client/src/client/flightsql.rs:77
Methodinner
Return a reference to the inner stream
core/influxdb_iox_client/src/client/flight/mod.rs:358
Methodinner
Reference the inner error value
core/error_reporting/src/lib.rs:89
Methodinner
Returns underlying string.
core/data_types/src/partition.rs:152
Methodinner
(&self)
influxdb3_catalog/src/catalog/versions/v3/legacy.rs:38
Methodinner_mut
Return a mutable reference to the underlying [`FlightClient`]
core/influxdb_iox_client/src/client/flightsql.rs:82
Methodinner_mut
Return the underlying [`BTreeMap`].
core/data_types/src/columns.rs:74
Functioninput_different_order_than_output
()
core/iox_query/src/provider/adapter.rs:318
Functioninput_has_different_type
()
core/iox_query/src/provider/adapter.rs:427
Functioninput_subset_of_output
()
core/iox_query/src/provider/adapter.rs:352
Functioninput_superset_of_columns
()
core/iox_query/src/provider/adapter.rs:394
Methodinputs
(&self)
core/iox_query/src/exec/split.rs:123
Methodinputs
(&self)
core/iox_query/src/exec/gapfill/mod.rs:206
Methodinsert
Called before a value is potentially inserted.
core/object_store_mem_cache/src/cache_system/hook/mod.rs:29
Functioninsert_race_condition
()
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:1652
Methodinsert_table_from_log
Insert a [`TableDefinition`] to the `tables` map and also update the `table_map` and increment the database next id. # Implementation Note This meth
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:88
Methodinstall_global
Build a tracing subscriber and install it as a global default subscriber for all threads. It returns a RAII guard that will ensure all events are flu
core/trogging/src/lib.rs:241
Methodinstalled_packages
(&self)
influxdb3/src/commands/serve.rs:1490
Methodinstance_id
(&self)
influxdb3_catalog/src/catalog/versions/v1.rs:920
Methodinstance_id
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:59
Methodint64_field
Add an integer field to the line protocol.
influxdb3_py_api/src/line_builder/line_builder.py:85
Functioninteger_literal
Parse an InfluxQL integer to a [`Literal::Integer`] or [`Literal::Unsigned`] if the string overflows. This behavior is consistent with [InfluxQL]. In
core/influxdb_influxql_parser/src/literal.rs:145
Methodintegral_unit
(args: &[Expr])
core/iox_query_influxql/src/plan/planner.rs:2204
Methodinternal
Return a `Error::Internal` variant with the specified message
core/influxdb_iox_client/src/client/error.rs:155
Functioninternal_gaps
()
core/iox_query/src/exec/gapfill/date_bin_gap_expander.rs:344
Functioninternal_gaps
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:397
Functioninterpolate
(arg: Expr)
core/query_functions/src/gapfill.rs:466
Methodinterpolate
(segment: &Segment<Self>, ts: i64)
core/iox_query/src/exec/gapfill/algo/interpolate.rs:317
Functioninterpolate_errs
()
core/query_functions/src/gapfill.rs:474
Methodinto_batch
(self)
influxdb3_catalog/src/log/versions/v3.rs:223
Methodinto_batch
(self)
influxdb3_catalog/src/log/versions/v4.rs:358
Methodinto_create_last_cache
(self)
influxdb3_catalog/src/log/versions/v2.rs:189
Methodinto_database
(self)
influxdb3_catalog/src/log/versions/v2.rs:83
Functioninto_decimal_with_precision
(maybe_f: Option<f64>, precision: u32)
core/object_store_metrics/src/cache_metrics.rs:872
Functioninto_dst
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:733
Functioninto_dst_avoid_discontinuity
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:801
Functioninto_dst_short_strides
()
core/iox_query/src/exec/gapfill/date_bin_wallclock_gap_expander.rs:767
Methodinto_inner
(self)
core/arrow_util/src/dictionary.rs:124
Methodinto_inner
Return the inner arrow flight client
core/influxdb_iox_client/src/client/flight/mod.rs:221
Methodinto_inner
Take the inner error value
core/error_reporting/src/lib.rs:84
Methodinto_iter
(&self)
influxdb3_catalog/src/catalog/versions/v1/enterprise.rs:448
Methodinto_names
Creates a consuming iterator visiting all parameter names. Currently this will iterate in an arbitrary order, but specific ordering is subject to chan
core/iox_query_params/src/params.rs:92
Methodinto_tables
Consumes `self`, returning an iterator of the table ID and data contained within it.
core/dml/src/lib.rs:182
Methodinvalid_argument
Return `Error::InvalidArgument` specifing an error in `field_name`
core/influxdb_iox_client/src/client/error.rs:168
Methodinvalid_configuration
(message: impl AsRef<str>)
influxdb3_catalog/src/error.rs:311
Functioninvalid_magic
()
influxdb3_catalog/src/format/reader/tests.rs:134
Functioninvalid_magic_rejected
()
influxdb3_catalog/src/format/header/tests.rs:97
Functioninvalid_s3_endpoint_url_fails_clap_parsing
()
influxdb3_clap_blocks/src/object_store/tests.rs:138
Functioninvalid_strftime_format_is_invalid
()
core/data_types/src/partition_template.rs:1813
Functioninvalid_token_error_returns_403
()
core/iox_http/src/write/single_tenant/mod.rs:703
Methodinvoke_with_args
(&self, _args: ScalarFunctionArgs)
core/query_functions/src/sleep.rs:38
Methodinvoke_with_args
(&self, _args: ScalarFunctionArgs)
core/query_functions/src/gapfill.rs:149
Methodinvoke_with_args
(&self, args: ScalarFunctionArgs)
core/query_functions/src/to_timestamp.rs:71
Methodinvoke_with_args
(&self, args: ScalarFunctionArgs)
core/query_functions/src/coalesce_struct.rs:135
Functioniox_expr_rewrite_inner
(expr: Expr)
core/predicate/src/rpc_predicate/rewrite.rs:40
Functioniox_metadata_protobuf_round_trip
()
core/parquet_file/src/metadata.rs:1065
Methodis_admin
Returns true if this token carries unrestricted admin privileges (the `*:*:*` permission) rather than being scoped to specific resources. Admin tokens
influxdb3_authz/src/lib.rs:334
Functionis_aggregate_field
A utility function that checks whether `f` is an aggregate field or not. An aggregate field is one that contains at least one call to an aggregate fun
core/iox_query_influxql/src/plan/planner.rs:4347
Methodis_all
(&self)
influxdb3_catalog/src/catalog/versions/v3/schema/node.rs:259
Methodis_any_set
Returns true if any bit is set (short circuiting).
core/arrow_util/src/bitset.rs:257
Methodis_authenticated
Whether this client has an auth token set.
influxdb3_client/src/lib.rs:210
Methodis_auto_generated
Check if this is an auto-generated cache
influxdb3_catalog/src/log/versions/v4.rs:1069
← previousnext →7,001–7,100 of 11,906, ranked by callers