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
↓ 1 callersMethodgenerate
(&mut self)
influxdb3_load_generator/src/query_generator.rs:95
↓ 1 callersFunctiongenerate_data_points
The idea here is to generate data based on throughput required shared across multiple writers. Each line is derived from a template so we can calculat
influxdb3_load_generator/src/commands/write_fixed.rs:90
↓ 1 callersFunctiongenerate_grpc_types
Schema used with IOx specific Ingester-Querier gRPC requests Creates: - `influxdata.iox.ingester.v1.rs`
core/ingester_query_grpc/build.rs:22
↓ 1 callersFunctiongenerate_grpc_types
Schema used with IOx specific gRPC requests Creates: - `influxdata.iox.authz.pusher.v1.rs` - `influxdata.iox.authz.v1.rs` - `influxdata.iox.bulk_ing
core/generated_types/build.rs:39
↓ 1 callersFunctiongenerate_metadata
Generate the default InfluxQL metadata map for producing a `Schema` for the `SHOW RETENTION POLICIES` query.
core/iox_query_influxql/src/show_retention_policies.rs:24
↓ 1 callersMethodget
(&self)
core/catalog_cache/src/local/limit.rs:221
↓ 1 callersMethodget
Get the value at a given index
core/arrow_util/src/string.rs:103
↓ 1 callersMethodget
(&self, location: &Path)
influxdb3_clap_blocks/src/object_store.rs:193
↓ 1 callersMethodget
(&self, location: &Path)
object_store_limit/src/lib.rs:130
↓ 1 callersFunctionget_aggr_fn
we use this function to recurse through the structure of the expr that we're given to try to find an aggregate function nested deep in it which still
core/iox_query/src/analyzer/handle_gapfill.rs:632
↓ 1 callersFunctionget_aggregate
Returns the aggregate statistic corresponding to `aggregate` from `stats`
core/iox_query/src/pruning.rs:282
↓ 1 callersMethodget_byte_ranges
( &mut self, ranges: Vec<Range<u64>>, )
core/iox_query/src/physical_optimizer/cached_parquet_data.rs:222
↓ 1 callersMethodget_cache_schema
Get a particular cache's name and arrow schema This is used for the implementation of DataFusion's `TableFunctionImpl` and `TableProvider` traits as
influxdb3_cache/src/distinct_cache/provider.rs:101
↓ 1 callersMethodget_cache_schema
Get a particular cache's name and arrow schema This is used for the implementation of DataFusion's `TableFunctionImpl` and `TableProvider` traits.
influxdb3_cache/src/last_cache/provider.rs:116
↓ 1 callersFunctionget_cached_lp
Read the cached line protocol for this benchmark run, or generate (and cache) it if it does not exist.
core/mutable_batch_lp/benches/parse_lp.rs:64
↓ 1 callersMethodget_catalogs
List the catalogs on this server using a [`CommandGetCatalogs`] message. This implementation does not support alternate endpoints [`CommandGetCatalo
core/influxdb_iox_client/src/client/flightsql.rs:157
↓ 1 callersMethodget_client
(&self)
influxdb3_commands/src/enable.rs:12
↓ 1 callersMethodget_client
(&self)
influxdb3_commands/src/disable.rs:12
↓ 1 callersMethodget_client
(&self)
influxdb3_commands/src/test.rs:15
↓ 1 callersMethodget_client
(&self)
influxdb3/src/commands/create.rs:33
↓ 1 callersMethodget_client
(&self)
influxdb3/src/commands/delete.rs:18
↓ 1 callersFunctionget_column
(expr: Expr)
core/iox_query/src/analyzer/handle_gapfill.rs:171
↓ 1 callersMethodget_connection_settings
(&self)
influxdb3/src/commands/create/token.rs:285
↓ 1 callersMethodget_cpu_and_mem_used
(&mut self)
influxdb3_telemetry/src/sampler.rs:70
↓ 1 callersFunctionget_date_bin_expr
( batch: &TestRecords, stride_ms: i64, origin_ms: Option<i64>, )
core/iox_query/src/exec/gapfill/exec_tests.rs:1595
↓ 1 callersFunctionget_encoded_schemas_for_prepared_statement
Return the IPC encoded dataset and parameter schema for the specified query
core/flightsql/src/planner.rs:352
↓ 1 callersFunctionget_executing_statement_from_plan
( query_plan: QueryPlan, database: Arc<dyn QueryDatabase>, )
core/iox_v1_query_api/src/handler.rs:588
↓ 1 callersMethodget_flight_info_for_command
Send `cmd`, encoded as protobuf, to the FlightSQL server
core/influxdb_iox_client/src/client/flightsql.rs:110
↓ 1 callersFunctionget_flightsql_base_table_type
Retrieve the base table type for FlightSQL requests. Only `BASE TABLE` or `TABLE` are valid. If the header is not present, default to `BASE TABLE` typ
core/service_grpc_flight/src/lib.rs:1384
↓ 1 callersMethodget_generation_duration
(&self, level: u8)
influxdb3_catalog/src/catalog/versions/v2.rs:1175
↓ 1 callersFunctionget_git_hash
()
influxdb3_process/build.rs:19
↓ 1 callersFunctionget_git_hash_short
()
influxdb3_process/build.rs:42
↓ 1 callersFunctionget_hostname_or_primary
Get the system hostname, falling back to "primary" if unavailable
influxdb3/src/lib.rs:316
↓ 1 callersMethodget_latest_snapshot_sequence
Gets the latest snapshot sequence number from the object store. Returns None if no snapshots exist. This is a lightweight operation that only loads t
influxdb3_write/src/persister.rs:183
↓ 1 callersFunctionget_list_entries_real
(size: usize)
core/catalog_cache/benches/list_encode.rs:55
↓ 1 callersFunctionget_list_entries_short
(size: usize)
core/catalog_cache/benches/list_encode.rs:67
↓ 1 callersMethodget_metrics
(&self)
influxdb3_telemetry/src/store/tests.rs:12
↓ 1 callersMethodget_metrics
(&self)
core/iox_query/src/ingester.rs:40
↓ 1 callersMethodget_opts
(&self, location: &Path, options: GetOptions)
core/object_store_metrics/src/lib.rs:322
↓ 1 callersMethodget_opts
(&self, location: &Path, options: GetOptions)
core/object_store_mock/src/lib.rs:517
↓ 1 callersMethodget_opts
Get an object from the object store. If this object is cached, then it will not make a request to the inner object store.
influxdb3_cache/src/parquet_cache/mod.rs:739
↓ 1 callersMethodget_opts
(&self, location: &Path, options: GetOptions)
object_store_utils/src/test_object_store.rs:309
↓ 1 callersMethodget_opts_request_count
(&self, path: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:55
↓ 1 callersMethodget_or_create_named_field_family
(&mut self, family_name: &str)
influxdb3_catalog/src/catalog/versions/v3/transaction.rs:619
↓ 1 callersMethodget_or_fetch
( &self, location: &Path, size_hint: u64, )
core/object_store_mem_cache/src/store.rs:233
↓ 1 callersMethodget_or_fetch_impl
Get the value (`V`) from the cache. If the entry does not exist, run the future (`F`) that returns a value (`Arc<V>`). The value (`V`) is inserted af
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/mod.rs:182
↓ 1 callersMethodget_org_bucket
Internally, we speak the v2 protocol which has an "org" parameter. Single tenant instances of InfluxDB will tolerate the presence of an "org" paramete
core/influxdb_iox_client/src/client/write.rs:56
↓ 1 callersMethodget_output_format
(&self)
influxdb3/src/commands/create/token.rs:292
↓ 1 callersFunctionget_parameter_schema_for_plan
Return the schema for any bind parameters within the specified logical plan
core/flightsql/src/planner.rs:372
↓ 1 callersMethodget_partitions_from_record_batch
( &self, batch: &RecordBatch, )
core/iox_v1_query_api/src/response/stream.rs:161
↓ 1 callersMethodget_path
(&self)
influxdb3_cache/src/parquet_cache/mod.rs:143
↓ 1 callersMethodget_path_and_notifier_and_timestamp
( self, )
influxdb3_cache/src/parquet_cache/mod.rs:84
↓ 1 callersMethodget_permission
Look up the database-scoped permission a `token_hash` carries for `db_name`. Returns `None` if the hash is unknown, the database is unknown, or the to
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1351
↓ 1 callersMethodget_permission_without_resource_identifier
( &self, resource_type: ResourceType, token_id: &TokenId, )
influxdb3_authz/src/permissions.rs:648
↓ 1 callersMethodget_pid
(&self)
influxdb3_telemetry/src/sampler.rs:46
↓ 1 callersMethodget_process_specific_metrics
(&self, pid: Pid)
influxdb3_telemetry/src/sampler.rs:50
↓ 1 callersFunctionget_python_version
()
influxdb3_processing_engine/src/virtualenv.rs:96
↓ 1 callersMethodget_range
(&self, location: &Path, range: Range<u64>)
influxdb3_cache/src/parquet_cache/mod.rs:773
↓ 1 callersMethodget_range_request_count
(&self, path: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:59
↓ 1 callersMethodget_ranges
(&self, _location: &Path, _ranges: &[Range<u64>])
core/object_store_mem_cache/src/store.rs:340
↓ 1 callersMethodget_ranges
(&self, location: &Path, ranges: &[Range<u64>])
core/object_store_metrics/src/lib.rs:353
↓ 1 callersMethodget_ranges
This request is used by DataFusion when requesting metadata for Parquet files, so we need to use the cache to prevent excess network calls during quer
influxdb3_cache/src/parquet_cache/mod.rs:784
↓ 1 callersMethodget_ranges_request_count
(&self, path: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:63
↓ 1 callersMethodget_record_batches_filtered_unchecked
( &self, database_name: &str, table_name: &str, filters: &[Exp
influxdb3_write/src/lib.rs:868
↓ 1 callersMethodget_request_count
(&self, path: &Path)
influxdb3_test_helpers/src/object_store/mod.rs:51
↓ 1 callersMethodget_retention_cutoff_and_period
Returns both the retention cutoff timestamp and the retention period duration for a table. The compactor needs both to compute `next_expiration` after
influxdb3_catalog/src/catalog/versions/v2.rs:2468
↓ 1 callersMethodget_retention_cutoff_and_period
Return the retention cutoff time and retention period for a given table.
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:200
↓ 1 callersMethodget_retention_period_cutoff_map
(&self)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:1268
↓ 1 callersMethodget_retention_period_cutoff_ts_nanos
Return the oldest allowable timestamp for the given table according to the currently-available set of retention policies.
influxdb3_catalog/src/catalog/versions/v3/schema/database.rs:175
↓ 1 callersMethodget_row_converter
Get a row converter for comparing records. Keep it in [`Self::row_converter`] to avoid creating it multiple times.
core/iox_query/src/exec/gapfill/buffered_input.rs:217
↓ 1 callersFunctionget_runtime
Creates the tokio runtime for executing if nthreads is none, uses the default scheduler otherwise, creates a scheduler with the number of threads
influxdb3_load_generator/src/main.rs:124
↓ 1 callersFunctionget_sorted_test_chunks
()
core/iox_query/src/frontend/reorg.rs:310
↓ 1 callersMethodget_sql_info
Get information about sql compatibility from this server using [`CommandGetSqlInfo`] This implementation does not support alternate endpoints If omi
core/influxdb_iox_client/src/client/flightsql.rs:147
↓ 1 callersMethodget_table_chunks
( &self, db_schema: Arc<DatabaseSchema>, table_def: Arc<TableDefinition>, filt
influxdb3_write/src/write_buffer/mod.rs:516
↓ 1 callersMethodget_table_chunks_from_buffer_only
( &self, database_name: &str, table_name: &str, filter: &ChunkFilter<'_>,
influxdb3_write/src/write_buffer/mod.rs:611
↓ 1 callersMethodget_tables
Fetch the list of tables in the given namespace
core/influxdb_iox_client/src/client/table.rs:33
↓ 1 callersFunctionget_test_chunks
()
core/iox_query/src/frontend.rs:227
↓ 1 callersFunctionget_time_range
(start: Option<i64>, end: i64)
core/iox_query/src/exec/gapfill/exec_tests.rs:1622
↓ 1 callersFunctionget_timestamps
Return the start, and end timestamps of the metrics set, if any
core/iox_query/src/exec/query_tracing.rs:294
↓ 1 callersMethodget_token
(&self, token_hash: Vec<u8>)
influxdb3_authz/src/tests.rs:29
↓ 1 callersMethodget_token_from_request
(&self, req: &mut Request)
core/iox_v1_query_api/src/handler.rs:508
↓ 1 callersMethodget_tokens
(&self)
influxdb3_catalog/src/catalog/versions/v2.rs:937
↓ 1 callersMethodget_user
(&self, user_id: UserId)
influxdb3_catalog/src/catalog/versions/v3/catalog.rs:3067
↓ 1 callersMethodgroup_by_tags
Returns the combined `GROUP BY` tags clause from the root and current statement. The list is sorted and guaranteed to be unique.
core/iox_query_influxql/src/plan/planner.rs:559
↓ 1 callersMethodgroup_columns_changed
Check to see if the group column values have changed between the last row that may be in the output and the last buffered input row. This method uses
core/iox_query/src/exec/gapfill/buffered_input.rs:197
↓ 1 callersFunctiongroup_same_file_sources
Group [`PartitionedFile`] which come from the same file source, into the same [`Vec<PartitionedFile>`] group. If the partitioned files (a.k.a. scanne
core/iox_query/src/physical_optimizer/sort/regroup_files.rs:163
↓ 1 callersFunctiongroup_snapshots_by_month
Group snapshots by year-month based on creation timestamp
influxdb3_write/src/write_buffer/checkpoint.rs:84
↓ 1 callersFunctionhandle_admin_token_creation
( client: Client, config: CreateAdminTokenConfig, )
influxdb3/src/commands/create/token.rs:44
↓ 1 callersFunctionhandle_aggregate
(aggr: Aggregate)
core/iox_query/src/analyzer/handle_gapfill.rs:123
↓ 1 callersMethodhandle_batch
(&self, catalog: &Arc<Catalog>, batch: &CatalogBatch)
influxdb3_catalog/src/catalog/versions/v2.rs:150
↓ 1 callersMethodhandle_data
(mut self: Pin<&mut Self>, body: &B::Data)
core/trace_http/src/tower.rs:377
↓ 1 callersMethodhandle_emit_batch
(&self, batch: jaeger::Batch)
core/trace_exporters/src/jaeger.rs:401
↓ 1 callersMethodhandle_emit_zipkin_batch
( &self, _spans: Vec<crate::thrift::zipkincore::Span>, )
core/trace_exporters/src/jaeger.rs:394
↓ 1 callersMethodhandle_error
(mut self: Pin<&mut Self>)
core/trace_http/src/tower.rs:426
↓ 1 callersFunctionhandle_init_logs
(r: Result<TroggingGuard, trogging::Error>)
influxdb3/src/lib.rs:335
↓ 1 callersMethodhandle_metrics
(&self)
influxdb3_server/src/http.rs:1236
↓ 1 callersFunctionhandle_named_admin_token_creation
( client: Client, config: CreateAdminTokenConfig, )
influxdb3/src/commands/create/token.rs:114
↓ 1 callersMethodhandle_parameterized_query
(&self, req: Request)
core/iox_v1_query_api/src/handler.rs:174
↓ 1 callersMethodhandle_pprof_heap
(&self, _req: Request)
influxdb3_server/src/http.rs:1250
↓ 1 callersFunctionhandle_projection
(mut proj: Projection)
core/iox_query/src/analyzer/handle_gapfill.rs:480
← previousnext →3,701–3,800 of 11,906, ranked by callers