MCPcopy Index your code

hub / github.com/influxdata/influxdb / functions

Functions11,906 in github.com/influxdata/influxdb

⨍ Functions 11,906◇ Types & classes 2,644↳ Endpoints 4
↓ 781 callersMethodcollect
Executes the logical plan using DataFusion on a separate thread pool and produces RecordBatches
core/iox_query/src/exec/context.rs:610
↓ 702 callersMethodclone
(&self)
influxdb3_query_executor/src/lib.rs:76
↓ 657 callersMethodclone
(&self)
core/influxdb_line_protocol/src/lib.rs:285
↓ 457 callersMethodclone
(&self)
core/tracker/src/task.rs:366
↓ 447 callersMethoditer
An iterator visiting all name-value pairs. Currently this will iterate in an arbitrary order, but specific ordering is subject to change and shouldn't
core/iox_query_params/src/params.rs:120
↓ 385 callersMethodrun
(&self, commands: Vec<&str>, args: &[&str])
influxdb3/tests/cli/api.rs:41
↓ 368 callersMethodas_ref
(&self)
core/parquet_file/src/storage.rs:90
↓ 362 callersFunctionlit
Convert `v` to a literal expression.
core/influxdb_influxql_parser/src/expression/arithmetic.rs:650
↓ 276 callersMethodas_ref
(&self)
influxdb3_catalog/src/object_store/versions/v2.rs:373
↓ 261 callersMethodread
Read the current disk space statistics.
core/tracker/src/disk_metric.rs:110
↓ 234 callersMethodpush
Push writes.
influxdb3_py_api/src/write.rs:19
↓ 230 callersMethodget
Look up a registered record by raw ID.
influxdb3_catalog/src/format/registry.rs:172
↓ 223 callersMethodinto_iter
(self)
core/data_types/src/columns.rs:146
↓ 209 callersMethodlock
(&self)
core/tracker/src/lock.rs:327
↓ 196 callersMethodbody
Set the body of the request to the `/api/v3/write_lp` API The body is materialized as [`Bytes`] so it can be transformed (e.g. gzip-compressed via [`
influxdb3_client/src/lib.rs:1242
↓ 196 callersFunctionparse_select
Returns the InfluxQL [`SelectStatement`] for the specified SQL, `s`.
core/iox_query_influxql/src/plan/test_utils.rs:21
↓ 194 callersMethodjoin
Waits for registered tasks to complete before signaling shutdown to frontend The future returned will complete when all registered tasks have signale
influxdb3_shutdown/src/lib.rs:121
↓ 193 callersMethoditer
( &self, )
influxdb3_authz/src/permissions.rs:706
↓ 186 callersMethodclone
(&self)
core/object_store_mock/src/lib.rs:75
↓ 182 callersMethodnow
(&self)
core/iox_time/src/lib.rs:222
↓ 179 callersMethodpush
(&mut self, record: &R)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:103
↓ 178 callersMethodfilter
Returns a [`PartitionWrite`] containing just the rows of `Self` that pass the provided time predicate, or None if no rows
core/partition/src/lib.rs:401
↓ 178 callersMethodinto_iter
(self)
core/iox_query_params/src/params.rs:353
↓ 175 callersMethodpush
( &self, namespace_id: NamespaceId, namespace_name: Arc<str>, query_type: &'st
core/iox_query/src/query_log.rs:856
↓ 171 callersMethodget
(&self)
influxdb3_process/src/lib.rs:61
↓ 164 callersMethodas_ref
(&self)
influxdb3_write/src/lib.rs:369
↓ 162 callersMethodsend
Send the request to the server
influxdb3_client/src/lib.rs:1254
↓ 162 callersMethodstatus
Set status of `Span`
core/trace/src/span.rs:110
↓ 161 callersMethoditer
(&self)
core/metric/src/lib.rs:432
↓ 158 callersMethodinsert
Insert a new resource to the repository
influxdb3_catalog/src/catalog/versions/v2.rs:3059
↓ 158 callersMethodto_str
(&self)
influxdb3_server/src/http.rs:523
↓ 156 callersMethodok
Record success on this `Span` setting the status if it isn't already set
core/trace/src/span.rs:98
↓ 154 callersMethodinto_iter
(&self)
influxdb3_catalog/src/catalog/versions/v2/enterprise.rs:1022
↓ 154 callersMethodpath
(&self)
core/parquet_file/src/storage.rs:180
↓ 152 callersMethodinsert
Insert a new resource to the repository
influxdb3_catalog/src/repository.rs:225
↓ 150 callersMethodas_str
Return the logical representation for the `EscapedStr` as a single slice. The slice might not point into the original buffer.
core/influxdb_line_protocol/src/lib.rs:494
↓ 149 callersMethodspawn
Spawn a new [`TestServer`] This will run the `influxdb3 serve` command, and bind its HTTP address to a random port on localhost.
influxdb3/tests/server/mod.rs:462
↓ 146 callersMethodboxed
(self)
core/object_store_mem_cache/src/cache_system/reactor/reaction.rs:50
↓ 146 callersMethodcreate_database
(&self, name: &str)
influxdb3_catalog/src/catalog/versions/v2/update.rs:394
↓ 140 callersMethodget_by_id
(&self, id: &ColumnIdentifier)
influxdb3_catalog/src/catalog/versions/v2.rs:2967
↓ 139 callersMethodlen
(&self)
core/iox_query/src/exec/gapfill/exec_tests.rs:1404
↓ 138 callersMethodentry
Underlying entry.
core/iox_query/src/query_log.rs:1078
↓ 138 callersMethodparse
Parse a measurement name, which may be an identifier or a regular expression.
core/influxdb_influxql_parser/src/common.rs:55
↓ 134 callersMethodappend
Append a value Returns the index of the appended data
core/arrow_util/src/string.rs:55
↓ 115 callersMethodas_str
(&self)
influxdb3_telemetry/src/lib.rs:65
↓ 111 callersFunctionmaybe_start_logging
Enables debug logging if the RUST_LOG environment variable is set. Does nothing if RUST_LOG is not set. If enable_logging has been set previously, doe
core/test_helpers/src/lib.rs:112
↓ 107 callersMethodas_slice
(&self)
influxdb3_catalog/src/format/record.rs:199
↓ 105 callersMethodbuild
(self)
core/schema/src/sort.rs:57
↓ 105 callersMethodsort
Sort the output of this plan with the specified expressions
core/iox_query/src/physical_optimizer/sort/order_union_sorted_inputs.rs:2374
↓ 102 callersMethodcreate_database
(&self, name: impl Into<String>)
influxdb3/tests/cli/api.rs:17
↓ 100 callersMethodas_bytes
Returns the bytes of the inner string.
core/data_types/src/partition.rs:157
↓ 100 callersMethodwrite
Push a `RecordBatch` into the underlying writer, updating the tracked allocation
influxdb3_write/src/persister.rs:1024
↓ 93 callersMethodapply
(&self, catalog: &mut InnerCatalog)
influxdb3_catalog/src/format/records/role.rs:47
↓ 93 callersMethoditer
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:3081
↓ 92 callersMethodfield
Return the InfluxDB data model type, if any, and underlying arrow schema field for the column at index `idx`. Panics if `idx` is greater than or equal
core/schema/src/lib.rs:702
↓ 91 callersFunctiondecode
decodes the encoded value as a `WindowDuration`, panic'ing on failure
core/query_functions/src/window.rs:387
↓ 91 callersMethodinc
Increments the value of this U64Gauge by the specified amount.
core/metric/src/gauge.rs:22
↓ 91 callersMethodok_or
(self)
core/trace_exporters/src/thrift/jaeger.rs:1209
↓ 90 callersMethodinflux_field
Add a new field column with the specified InfluxDB data model type
core/schema/src/builder.rs:94
↓ 90 callersMethodtag
Add a new tag column to this schema. By default tags are potentially nullable as they are not guaranteed to be present for all rows
core/schema/src/builder.rs:86
↓ 89 callersMethodlen
Returns the number of columns defined in this schema
core/schema/src/lib.rs:741
↓ 89 callersMethodtimestamp_nanos
Returns the number of non-leap-nanoseconds since January 1, 1970 UTC
core/iox_time/src/lib.rs:98
↓ 89 callersMethodwait
wait for the first output to be produced
core/iox_query/src/exec.rs:567
↓ 88 callersMethodinsert
Sets the given key, overriding it if already set
core/metric/src/lib.rs:437
↓ 88 callersFunctionnone
()
influxdb3_catalog/src/catalog/versions/v2/update.rs:1834
↓ 88 callersMethodquery
(&self)
influxdb3_load_generator/src/query_generator.rs:75
↓ 88 callersMethodwrite_lp_to_db
Write some line protocol to the server
influxdb3/tests/server/mod.rs:892
↓ 87 callersMethodrecorder
Retrieves a type that can be used to report observations for a given set of attributes If this is the first time this method has been called with thi
core/metric/src/metric.rs:66
↓ 86 callersMethodlen
(&self)
influxdb3_sys_events/src/lib.rs:139
↓ 86 callersFunctionno
The expression was not rewritten
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:225
↓ 85 callersFunctionapply_batch
(batch: &RecordBatch, catalog: &mut InnerCatalog)
influxdb3_catalog/src/catalog/versions/v3/ops/test_util.rs:21
↓ 85 callersMethoddb_schema
(&self)
influxdb3_catalog/src/catalog/versions/v2/update.rs:2026
↓ 84 callersMethodheader
Sets a header to be included on all requests
core/client_util/src/connection.rs:208
↓ 84 callersMethodis_none
Returns true if both the min and max values are None (aka not known)
core/data_types/src/lib.rs:1850
↓ 83 callersMethodcreate_table
( &self, db_name: &str, table_name: &str, tags: &[impl AsRef<str> + Send + Syn
influxdb3_catalog/src/catalog/versions/v2/update.rs:486
↓ 80 callersMethodload
Load data for given key. The future generator (`F`) will only be called if there a new future is required, i.e. if there is NO running future for the
core/object_store_mem_cache/src/cache_system/loader.rs:84
↓ 78 callersFunctionsql_keyword
Matches any InfluxQL reserved keyword.
core/influxdb_influxql_parser/src/keywords.rs:145
↓ 77 callersMethoditer
(&self)
influxdb3_catalog/src/repository.rs:273
↓ 77 callersMethodlen
get the current number of cached entries
influxdb3_write/src/table_index_cache.rs:534
↓ 75 callersMethodbuild
Create the Provider
core/iox_query/src/provider.rs:120
↓ 74 callersFunctionbytes_to_response_body
Responding with one chunk of bytes. For streaming, see [`stream_bytes_to_response_body`].
core/iox_http_util/src/lib.rs:84
↓ 74 callersFunctionkeyword
Recognizes a case-insensitive `keyword`, ensuring it is followed by a valid separator.
core/influxdb_influxql_parser/src/keywords.rs:154
↓ 74 callersFunctiontest_catalog_with_store
(store: ObjectStoreCatalog)
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:51
↓ 73 callersMethodget_by_id
(&self, id: &RoleId)
influxdb3_catalog/src/catalog/versions/v3/schema/role.rs:46
↓ 73 callersMethodwith_dummy_parquet_file
(self)
core/iox_query/src/test.rs:522
↓ 72 callersMethodeq
Return `self == other`
core/influxdb_influxql_parser/src/expression/conditional.rs:110
↓ 72 callersFunctionparse
(s: &str)
core/influxdb_line_protocol/src/lib.rs:1530
↓ 72 callersFunctiontest_store_with_prefix
(prefix: &str)
influxdb3_catalog/src/catalog/versions/v3/catalog/tests.rs:31
↓ 71 callersMethodas_arrow
Return a valid Arrow `SchemaRef` representing this `Schema`
core/schema/src/lib.rs:576
↓ 71 callersFunctioninternal
An unexpected error whilst planning that represents a bug in IOx.
core/iox_query_influxql/src/error.rs:13
↓ 71 callersMethodupdate
(&self)
influxdb3_catalog/src/catalog/versions/v3/events.rs:263
↓ 71 callersMethoduri
Return a reference to the base uri of the IOx http API endpoint
core/client_util/src/connection.rs:63
↓ 70 callersMethodcall
(&mut self, mut request: Request<ReqBody>)
core/trace_http/src/tower.rs:142
↓ 69 callersMethodfind
Find the first initialised slot that causes `F` to evaluate to true, returning the slot contents. This is a O(n) linear search operation, which for s
core/partition/src/template/strftime.rs:71
↓ 69 callersMethodget
(self)
core/trace/src/ctx.rs:17
↓ 68 callersMethodget_mut
Retrieves a mutable reference to the value corresponding to the given name.
core/iox_query_params/src/params.rs:161
↓ 68 callersFunctionquery
An error that was the result of an invalid InfluxQL query.
core/iox_query_influxql/src/error.rs:4
↓ 68 callersMethodtag
Add a tag (key + value). Tag keys and tag values will be escaped according to the rules defined in [the special characters documentation]. [special
core/influxdb_line_protocol/src/builder.rs:155
↓ 68 callersMethodvalue
Returns the value data if present
core/catalog_cache/src/api/list/mod.rs:83
↓ 68 callersFunctionyes
The expression was rewritten
core/iox_query_influxql/src/plan/planner_rewrite_expression.rs:220
next →1–100 of 11,906, ranked by callers