Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/influxdata/influxdb
/ functions
Functions
11,906 in github.com/influxdata/influxdb
⨍
Functions
11,906
◇
Types & classes
2,644
↳
Endpoints
4
Method
poll
( mut self: Pin<&mut Self>, ctx: &mut std::task::Context<'_>,
influxdb3_server/src/http.rs:2415
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/catalog_cache/src/api/server.rs:124
Method
poll
( mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/catalog_cache/src/local/limit.rs:124
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/object_store_mem_cache/src/buffer_channel.rs:105
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/object_store_mem_cache/src/cache_system/utils.rs:66
Method
poll
( self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/object_store_mem_cache/src/cache_system/loader.rs:218
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/futures_test_utils/src/lib.rs:128
Method
poll
(self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>)
core/tracker/src/async_semaphore.rs:454
Method
poll
(self: Pin<&mut Self>, cx: &mut Context<'_>)
core/datafusion_util/src/watch.rs:39
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/trace_http/src/tower.rs:223
Method
poll
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/tower_trailer/src/lib.rs:78
Method
poll_flight_info
( &self, _request: Request<FlightDescriptor>, )
core/service_grpc_flight/src/lib.rs:1171
Method
poll_frame
( mut self: Pin<&mut Self>, cx: &mut Context<'_>, )
core/trace_http/src/tower.rs:317
Method
poll_frame
( self: Pin<&mut Self>, cx: &mut Context<'_>, )
core/tower_trailer/src/lib.rs:104
Method
poll_next
(self: Pin<&mut Self>, cx: &mut Context<'_>)
core/catalog_cache/src/api/server.rs:319
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/object_store_mem_cache/src/cache_system/hook/notify/mod.rs:58
Method
poll_next
( mut self: Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/influxdb_iox_client/src/client/flight/mod.rs:376
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, ctx: &mut Context<'_>, )
core/iox_query/src/ingester.rs:144
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/iox_query/src/exec.rs:675
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/iox_query/src/exec/query_tracing.rs:70
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/iox_query/src/exec/cross_rt_stream.rs:133
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
core/iox_query/src/exec/series_limit/physical.rs:904
Method
poll_next
Produces a gap-filled record batch from its input stream. For details on implementation, see [`GapFiller`].
core/iox_query/src/exec/gapfill/stream.rs:133
Method
poll_next
(&mut self, cx: &mut Context<'_>)
core/iox_query/src/provider/progressive_eval.rs:398
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, ctx: &mut Context<'_>, )
core/iox_query/src/provider/adapter.rs:245
Method
poll_next
( mut self: Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/service_grpc_flight/src/observer.rs:106
Method
poll_next
(self: Pin<&mut Self>, cx: &mut Context<'_>)
core/service_grpc_flight/src/keep_alive.rs:230
Method
poll_next
( mut self: Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
core/service_grpc_flight/src/lib.rs:1546
Method
poll_next
(self: Pin<&mut Self>, cx: &mut Context<'_>)
core/object_store_metrics/src/stream.rs:166
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, _: &mut Context<'_>, )
core/datafusion_util/src/lib.rs:199
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut TaskContext<'_>)
influxdb3_catalog/src/channel/versions/v2.rs:86
Method
poll_next
( mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
influxdb3_catalog/src/catalog/versions/v3/events.rs:351
Method
poll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
object_store_limit/src/lib.rs:260
Method
poll_next_chunk
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/csv.rs:50
Method
poll_next_inner
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/stream.rs:178
Method
poll_next_result
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/chunked.rs:44
Method
poll_next_result
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/buffered.rs:44
Method
poll_ready
(&mut self, _cx: &mut Context<'_>)
influxdb3_server/src/unified_service/service.rs:53
Method
poll_ready
(&mut self, cx: &mut Context<'_>)
influxdb3_server/src/unified_service/remote_addr_layer.rs:47
Method
poll_ready
(&mut self, cx: &mut Context<'_>)
core/client_util/src/tower.rs:68
Method
poll_ready
(&mut self, cx: &mut Context<'_>)
core/trace_http/src/tower.rs:138
Method
poll_ready
(&mut self, cx: &mut Context<'_>)
core/tower_trailer/src/lib.rs:43
Method
poll_statement
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/chunked.rs:37
Method
poll_statement
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/buffered.rs:40
Method
poll_statement
(&mut self, cx: &mut Context<'_>)
core/iox_v1_query_api/src/response/csv.rs:46
Method
polled
Number of [polls](Future::poll).
core/futures_test_utils/src/lib.rs:73
Method
pool
Returns the memory pool associated with this `Executor`
core/iox_query/src/exec.rs:339
Method
pop_front
Pop entry from the front of the set. This may be called on and empty set. # Runtime Complexity This amortizes to `O(1)`. If there are only tombston
core/object_store_mem_cache/src/cache_system/s3_fifo_cache/ordered_set.rs:80
Function
post_setup_user
()
core/influxdb2_client/src/api/setup.rs:173
Function
post_setup_user_opt
()
core/influxdb2_client/src/api/setup.rs:235
Method
post_visit
(&mut self, plan: &dyn ExecutionPlan)
core/iox_query/src/statistics/aggregate_per_plan.rs:105
Method
post_visit_measurement_name
( self, mn: &MeasurementName, )
core/iox_query_influxql/src/frontend/planner.rs:301
Method
post_visit_show_field_keys_statement
( self, sfk: &ShowFieldKeysStatement, )
core/iox_query_influxql/src/frontend/planner.rs:338
Method
post_visit_show_measurements_statement
( self, sm: &ShowMeasurementsStatement, )
core/iox_query_influxql/src/frontend/planner.rs:327
Method
post_visit_show_tag_keys_statement
( self, stk: &ShowTagKeysStatement, )
core/iox_query_influxql/src/frontend/planner.rs:360
Method
post_visit_show_tag_values_statement
( self, stv: &ShowTagValuesStatement, )
core/iox_query_influxql/src/frontend/planner.rs:349
Method
post_visit_statement
(&mut self, _n: &mut Statement)
core/influxdb_influxql_parser/src/parameter.rs:134
Function
pprof_heap_response_returns_heap_v2_with_expected_headers
()
core/jemalloc_pprof_http/tests/pprof_heap_response.rs:19
Method
pre_visit
( &mut self, plan: &dyn ExecutionPlan, )
core/iox_query/src/frontend.rs:156
Method
pre_visit
(&mut self, _plan: &dyn ExecutionPlan)
core/iox_query/src/statistics/aggregate_per_plan.rs:101
Method
pre_visit
(&mut self, plan: &dyn ExecutionPlan)
core/iox_query/src/physical_optimizer/chunk_extraction.rs:104
Method
pre_visit_call
(self, n: &Call)
core/iox_query_influxql/src/plan/field.rs:63
Method
pre_visit_expr
(&mut self, expr: &mut Expr)
core/influxdb_influxql_parser/src/parameter.rs:120
Method
pre_visit_expr
(self, n: &Expr)
core/iox_query_influxql/src/plan/rewriter.rs:662
Method
pre_visit_select_dimension
(self, n: &Dimension)
core/iox_query_influxql/src/plan/rewriter.rs:680
Method
pre_visit_select_from_clause
( self, _n: &FromMeasurementClause, )
core/iox_query_influxql/src/plan/rewriter.rs:672
Method
pre_visit_select_statement
Invoked before any children of the `SELECT` statement are visited.
core/influxdb_influxql_parser/src/visit_mut.rs:174
Method
pre_visit_var_ref
(self, n: &VarRef)
core/iox_query_influxql/src/plan/field.rs:58
Method
pre_visit_var_ref
(self, varref: &VarRef)
core/iox_query_influxql/src/plan/planner/source_field_names.rs:12
Function
predicate_display_full
()
core/predicate/src/lib.rs:396
Function
predicate_display_ts
()
core/predicate/src/lib.rs:376
Function
predicate_display_ts_and_expr
()
core/predicate/src/lib.rs:384
Function
predicate_multi_field_cols_not_supported
()
core/predicate/src/lib.rs:410
Function
predicate_proto_base64_roundtrip
()
core/ingester_query_grpc/src/lib.rs:370
Function
prefix
(s: T)
core/data_types/src/partition_template.rs:1926
Method
prepare
Create a prepared statement for execution. This involves two roundtrips: Step 1: Sends a [`ActionCreatePreparedStatementRequest`] message to the `Do
core/influxdb_iox_client/src/client/flightsql.rs:474
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/config.rs:29
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/feature_level.rs:23
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/trigger.rs:44
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/user.rs:37
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/cache.rs:82
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/table.rs:40
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/node.rs:45
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/database.rs:51
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/retention.rs:35
Method
prepare
( args: &Self::Input, _catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/restore.rs:53
Method
prepare
( args: &Self::Input, catalog: &InnerCatalog, records: &mut RecordBatch, )
influxdb3_catalog/src/catalog/versions/v3/ops/token.rs:39
Function
prepare_admin_token_lifecycle
()
influxdb3_catalog/src/catalog/versions/v3/ops/token/tests.rs:20
Function
prepare_create_admin_token_duplicate
()
influxdb3_catalog/src/catalog/versions/v3/ops/token/tests.rs:85
Function
prepare_create_database
()
influxdb3_catalog/src/catalog/versions/v3/ops/database/tests.rs:17
Function
prepare_create_database_duplicate
()
influxdb3_catalog/src/catalog/versions/v3/ops/database/tests.rs:66
Function
prepare_create_database_with_retention
()
influxdb3_catalog/src/catalog/versions/v3/ops/database/tests.rs:40
Function
prepare_create_distinct_cache_duplicate
()
influxdb3_catalog/src/catalog/versions/v3/ops/cache/tests.rs:82
Function
prepare_create_distinct_cache_invalid_column_type
()
influxdb3_catalog/src/catalog/versions/v3/ops/cache/tests.rs:57
Function
prepare_create_distinct_cache_user
()
influxdb3_catalog/src/catalog/versions/v3/ops/cache/tests.rs:29
Function
prepare_create_last_cache
()
influxdb3_catalog/src/catalog/versions/v3/ops/cache/tests.rs:165
Function
prepare_create_last_cache_duplicate
()
influxdb3_catalog/src/catalog/versions/v3/ops/cache/tests.rs:194
Function
prepare_create_resource_scoped_token
()
influxdb3_catalog/src/catalog/versions/v3/ops/token/tests.rs:143
Function
prepare_create_trigger
()
influxdb3_catalog/src/catalog/versions/v3/ops/trigger/tests.rs:29
Function
prepare_create_trigger_duplicate
()
influxdb3_catalog/src/catalog/versions/v3/ops/trigger/tests.rs:45
← previous
next →
8,401–8,500 of 11,906, ranked by callers