List of all items
Structs
- Args
- cluster::ClusterHandle
- cluster_config::ClusterConfig
- cluster_config::ClusterNodeId
- config::AiSection
- config::CheckpointSection
- config::ColumnDef
- config::CoordinationSection
- config::DiscoverySection
- config::LookupCacheConfig
- config::LookupConfig
- config::ModelConfig
- config::PipelineConfig
- config::ProviderConfig
- config::Secret
- config::ServerConfig
- config::ServerSection
- config::SinkConfig
- config::SourceConfig
- config::WatermarkConfig
- http::AppState
- http::CheckpointResponse
- http::ErrorBody
- http::HealthResponse
- http::SinkResponse
- http::SourceResponse
- http::SqlRequest
- http::SqlResponse
- http::StreamResponse
- metrics::ServerMetrics
- pgwire::ActiveCursor
- pgwire::ConnState
- pgwire::CursorInner
- pgwire::FailureTracker
- pgwire::LaminarAuthSource
- pgwire::LaminarHandlerFactory
- pgwire::LaminarPgwireHandler
- pgwire::LaminarQueryParser
- pgwire::TlsConfigPaths
- pgwire::TlsPaths
- pgwire::TlsReloadState
- reload::ConfigDiff
- reload::ReloadFailure
- reload::ReloadGuard
- reload::ReloadGuardHandle
- reload::ReloadOp
- reload::ReloadResult
Enums
- cluster::ClusterStartupError
- cluster::DiscoveryImpl
- cluster_config::ClusterConfigError
- config::ConfigError
- config::TaskSpec
- pgwire::FetchTarget
- pgwire::LaminarStmt
- pgwire::StartupAuth
- pgwire::TlsMinVersion
- server::ServerError
- server::ServerHandle
Functions
- ai::build_ai_runtime
- ai::build_err
- ai::build_provider
- ai::maybe_rate_limit
- ai::provider_kind
- ai::resolve_key
- build_checkpoint_store
- cluster::build_shuffle_receiver
- cluster::build_shuffle_sender
- cluster::num_cpus
- cluster::resolve_vnode_assignment
- cluster::shuffle_advertise_addr
- cluster::spawn_membership_watcher
- cluster::start_cluster
- config::default_ai_max_concurrency
- config::default_bind
- config::default_cache_size
- config::default_cache_ttl
- config::default_checkpoint_interval
- config::default_checkpoint_url
- config::default_coordination_strategy
- config::default_delivery
- config::default_election_timeout
- config::default_format
- config::default_gossip_port
- config::default_heartbeat_interval
- config::default_lookup_strategy
- config::default_max_ooo
- config::default_max_retained
- config::default_mode
- config::default_pgwire_max_auth_failures_per_min
- config::default_pgwire_max_connections
- config::default_pgwire_tls_min_version
- config::default_raft_port
- config::default_true
- config::load_config
- config::substitute_env_vars
- config::validate_ai
- config::validate_config
- http::batch_to_json
- http::build_router
- http::cluster_status
- http::error_response
- http::execute_sql
- http::get_stream
- http::handle_reload
- http::health_check
- http::list_sinks
- http::list_sources
- http::list_streams
- http::prometheus_metrics
- http::readiness_check
- http::request_logging
- http::serve
- http::trigger_checkpoint
- http::ws_client
- http::ws_upgrade
- main
- metrics::build_registry
- metrics::render
- pgwire::apply_set
- pgwire::arrow_to_pg_type
- pgwire::build_client_cert_verifier
- pgwire::check_cert_expiry
- pgwire::classify_outcome
- pgwire::driver_select_response
- pgwire::encode_batch
- pgwire::encode_field_binary
- pgwire::encode_field_text
- pgwire::encode_row
- pgwire::engine_metadata_response
- pgwire::ensure_tls_provider
- pgwire::fetch_direction_count
- pgwire::fetch_response
- pgwire::field_infos
- pgwire::handle_close
- pgwire::handle_declare_cursor
- pgwire::handle_fetch
- pgwire::list_text_elements
- pgwire::load_tls_acceptor
- pgwire::open_portal_for_subscribe
- pgwire::outer_md5_challenge
- pgwire::parse_pre_hashed_md5
- pgwire::pg_text_array_literal
- pgwire::record_batch_response
- pgwire::serve
- pgwire::show_sql
- pgwire::standard_or_cursor_response
- pgwire::standard_response
- pgwire::stream_subscribe_flushing
- pgwire::subscription_query_response
- pgwire::text_response
- pgwire::try_reload_tls
- pgwire::unsupported_select
- pgwire::user_error
- pgwire::value_to_u64
- pgwire::warn_if_key_world_readable
- pgwire::watch_tls_files
- reload::apply_reload
- reload::diff_configs
- reload::diff_named_section
- reload::exec_ddl
- server::apply_checkpoint_config
- server::execute_config_ddl
- server::file_url_to_path
- server::lookup_to_ddl
- server::pipeline_to_ddl
- server::run_server
- server::sink_to_ddl
- server::source_to_ddl
- server::spawn_config_watcher
- server::start_http_api
- server::toml_value_to_sql
- server::wait_for_termination_signal
- validate_checkpoints_and_exit
- watcher::file_content_hash
- watcher::watch_config