List of all items

Structs

• checkpoint::barrier::BarrierPollHandle
• checkpoint::barrier::CheckpointBarrier
• checkpoint::barrier::CheckpointBarrierInjector
• checkpoint::checkpoint_manifest::CheckpointManifest
• checkpoint::checkpoint_manifest::ConnectorCheckpoint
• checkpoint::checkpoint_manifest::ManifestValidationError
• checkpoint::checkpoint_manifest::OperatorCheckpoint
• checkpoint::checkpoint_store::FileSystemCheckpointStore
• checkpoint::checkpoint_store::ObjectStoreCheckpointStore
• checkpoint::checkpoint_store::RecoveryReport
• checkpoint::checkpoint_store::ValidationResult
• checkpoint_decision::CheckpointDecisionStore
• cluster::control::barrier::BarrierAck
• cluster::control::barrier::BarrierAnnouncement
• cluster::control::barrier::BarrierCoordinator
• cluster::control::barrier::InMemoryKv
• cluster::control::catalog_manifest::CatalogManifest
• cluster::control::catalog_manifest::CatalogManifestEntry
• cluster::control::catalog_manifest::CatalogManifestStore
• cluster::control::chitchat_kv::ChitchatKv
• cluster::control::controller::ClusterController
• cluster::control::leader_lease::LeaderLease
• cluster::control::leader_lease::LeaderLeaseConfig
• cluster::control::leader_lease::LeaderLeaseManager
• cluster::control::leader_lease::LeaderLeaseStore
• cluster::control::snapshot::AssignmentSnapshot
• cluster::control::snapshot::AssignmentSnapshotStore
• cluster::control::tls::ClusterTls
• cluster::discovery::ArchivedNodeInfo
• cluster::discovery::ArchivedNodeMetadata
• cluster::discovery::GossipDiscovery
• cluster::discovery::GossipDiscoveryConfig
• cluster::discovery::NodeInfo
• cluster::discovery::NodeInfoResolver
• cluster::discovery::NodeMetadata
• cluster::discovery::NodeMetadataResolver
• cluster::discovery::StaticDiscovery
• cluster::discovery::StaticDiscoveryConfig
• cluster::testing::FaultyObjectStore
• cluster::testing::MiniCluster
• cluster::testing::NetworkRules
• cluster::testing::NodeHandle
• cluster::testing::PartitionableTransport
• lookup::align::KeyAligner
• lookup::lookup_cache::LookupCacheKey
• lookup::lookup_cache::LookupMemoryCache
• lookup::lookup_cache::LookupMemoryCacheConfig
• lookup::predicate::SourceCapabilities
• lookup::predicate::SplitPredicates
• lookup::source::LookupSourceCapabilities
• lookup::source::PushdownAdapter
• mv::MaterializedView
• mv::MvRegistry
• operator::Event
• operator::OperatorState
• operator::sliding_window::SlidingWindowAssigner
• operator::window::ChangelogRecord
• operator::window::TumblingWindowAssigner
• operator::window::WindowId
• serialization::BatchStreamDecoder
• serialization::BatchStreamEncoder
• shuffle::barrier_tracker::BarrierTracker
• shuffle::transport::ShuffleReceiver
• shuffle::transport::ShuffleSender
• state::config::StorageOptions
• state::in_process::InProcessBackend
• state::object_store::ObjectStoreBackend
• state::vnode::ArchivedNodeId
• state::vnode::Locality
• state::vnode::NodeId
• state::vnode::NodeIdResolver
• state::vnode::VnodeRegistry
• streaming::channel::AsyncConsumer
• streaming::channel::Producer
• streaming::checkpoint::StreamCheckpointConfig
• streaming::config::ChannelConfig
• streaming::config::SourceConfig
• streaming::error::TryPushError
• streaming::sink::Sink
• streaming::source::Source
• streaming::subscription::Subscription
• time::AscendingTimestampsGenerator
• time::BoundedOutOfOrdernessGenerator
• time::CastError
• time::EventTimeExtractor
• time::PeriodicGenerator
• time::ProcessingTimeGenerator
• time::PunctuatedGenerator
• time::SourceProvidedGenerator
• time::TimerRegistration
• time::TimerService
• time::Watermark
• time::WatermarkTracker

Enums

• Error
• checkpoint::barrier::StreamMessage
• checkpoint::checkpoint_manifest::SinkCommitStatus
• checkpoint::checkpoint_store::CheckpointStoreError
• checkpoint::checkpoint_store::ValidationIssue
• checkpoint::object_store_builder::ObjectStoreBuilderError
• checkpoint_decision::DecisionError
• cluster::control::barrier::Phase
• cluster::control::barrier::QuorumOutcome
• cluster::control::catalog_manifest::CatalogManifestError
• cluster::control::leader_lease::LeaseError
• cluster::control::leader_lease::LeaseOutcome
• cluster::control::snapshot::RotateOutcome
• cluster::control::snapshot::SnapshotError
• cluster::discovery::ArchivedNodeState
• cluster::discovery::DiscoveryError
• cluster::discovery::MembershipEvent
• cluster::discovery::NodeState
• cluster::discovery::NodeStateResolver
• cluster::testing::ObjectStoreFault
• error_codes::HotPathError
• error_codes::WarningSeverity
• lookup::LookupResult
• lookup::predicate::Predicate
• lookup::predicate::ScalarValue
• lookup::source::LookupError
• mv::MvError
• mv::MvState
• operator::OperatorError
• operator::window::CdcOperation
• operator::window::EmitStrategy
• shuffle::message::ShuffleMessage
• state::backend::StateBackendError
• state::config::DiscoveryMode
• state::config::StateBackendBuildError
• state::config::StateBackendConfig
• state::vnode::VnodeLifecycleState
• streaming::checkpoint::CheckpointError
• streaming::config::BackpressureStrategy
• streaming::config::WaitStrategy
• streaming::error::RecvError
• streaming::error::StreamingError
• time::EventTimeError
• time::ExtractionMode
• time::FilterError
• time::ThresholdOp
• time::TimeError
• time::TimestampField

Traits

• checkpoint::checkpoint_store::CheckpointStore
• cluster::control::barrier::ClusterKv
• cluster::control::query::RemoteQueryHandler
• cluster::discovery::Discovery
• lookup::source::LookupSource
• lookup::source::LookupSourceDyn
• operator::window::WindowAssigner
• state::backend::StateBackend
• streaming::source::Record
• time::WatermarkGenerator

Functions

• checkpoint::object_store_builder::build_object_store
• checkpoint::object_store_builder::file_url_path
• cluster::control::leader::leader_of
• cluster::control::leader_lease::lease_grants_leadership
• cluster::control::query::remote_scan_client
• cluster::control::tls::set_cluster_tls
• cluster::discovery::assignable_node_ids
• lookup::predicate::predicate_to_sql
• lookup::predicate::split_predicates
• lookup::source::projection_names
• serialization::deserialize_batch_stream
• serialization::serialize_batch_stream
• shuffle::routing::row_vnodes
• shuffle::routing::slice_batch_by_targets
• shuffle::routing::slice_batch_by_vnode
• shuffle::routing::slice_batch_by_vnodes
• state::vnode::key_hash
• state::vnode::owned_vnodes
• state::vnode::owners_per_domain
• state::vnode::peer_owners
• state::vnode::rendezvous_assignment
• streaming::channel::channel
• streaming::source::create
• streaming::source::create_with_config
• time::cast_to_millis_array
• time::filter_batch_by_timestamp
• time::now_unix_millis
• time::parse_duration_str

Type Aliases

• Result
• cluster::control::query::QueryClientPool
• cluster::control::query::QueryHandlerSlot
• cluster::control::query::RemoteBatchStream
• lookup::source::ColumnId
• operator::TimerKey
• operator::window::WindowIdVec
• shuffle::transport::ShufflePeerId
• time::FiredTimersVec
• time::TimerKey

Constants

• changelog::WEIGHT_COLUMN
• checkpoint::barrier::flags::CANCEL
• checkpoint::barrier::flags::DRAIN
• checkpoint::barrier::flags::FULL_SNAPSHOT
• checkpoint::barrier::flags::NONE
• checkpoint::checkpoint_manifest::DEFAULT_VNODE_COUNT
• cluster::control::barrier::ACK_KEY
• cluster::control::barrier::ANNOUNCEMENT_KEY
• cluster::control::barrier::BARRIER_ADDR_KEY
• cluster::discovery::keys::FAILURE_DOMAIN
• cluster::discovery::keys::LOAD_CORES
• cluster::discovery::keys::LOAD_MEMORY
• cluster::discovery::keys::NODE_NAME
• cluster::discovery::keys::NODE_STATE
• cluster::discovery::keys::NODE_VERSION
• cluster::discovery::keys::PARTITIONS_OWNED
• cluster::discovery::keys::RAFT_ADDRESS
• cluster::discovery::keys::RPC_ADDRESS
• error_codes::ARROW_ERROR
• error_codes::BASE64_DECODE_ERROR
• error_codes::CHECKPOINT_FAILED
• error_codes::CHECKPOINT_NOT_FOUND
• error_codes::CHECKPOINT_PRUNE_FAILED
• error_codes::CONNECTOR_AUTH_FAILED
• error_codes::CONNECTOR_CONFIG_ERROR
• error_codes::CONNECTOR_CONNECTION_FAILED
• error_codes::CONNECTOR_READ_ERROR
• error_codes::CONNECTOR_SCHEMA_ERROR
• error_codes::CONNECTOR_SERDE_ERROR
• error_codes::CONNECTOR_WRITE_ERROR
• error_codes::DESERIALIZATION_FAILED
• error_codes::DURABILITY_GATE_BACKEND_ERROR
• error_codes::DURABILITY_GATE_MISS
• error_codes::DURABILITY_GATE_ROLLBACK_FAILED
• error_codes::DURABILITY_GATE_ROLLBACK_ON_ERROR_FAILED
• error_codes::EXACTLY_ONCE_NON_REPLAYABLE
• error_codes::EXACTLY_ONCE_NO_CHECKPOINT
• error_codes::EXACTLY_ONCE_SINK_UNSUPPORTED
• error_codes::INTERNAL
• error_codes::INVALID_CONFIG
• error_codes::INVALID_OPERATION
• error_codes::JOIN_KEY_MISSING
• error_codes::JOIN_TIME_BOUND_MISSING
• error_codes::JOIN_TYPE_UNSUPPORTED
• error_codes::JSON_PARSE_ERROR
• error_codes::LATE_DATA_REJECTED
• error_codes::MANIFEST_PERSIST_FAILED
• error_codes::MATERIALIZED_VIEW_ERROR
• error_codes::MISSING_CONFIG
• error_codes::MIXED_DELIVERY_CAPABILITIES
• error_codes::NO_COMPILED_PROJECTION
• error_codes::OFFSET_METADATA_MISSING
• error_codes::PIPELINE_ERROR
• error_codes::PLAN_OPTIMIZATION_FAILED
• error_codes::QUERY_EXECUTION_FAILED
• error_codes::QUERY_PIPELINE_ERROR
• error_codes::RECOVERY_FAILED
• error_codes::SCHEMA_MISMATCH
• error_codes::SERIALIZATION_FAILED
• error_codes::SHUTDOWN
• error_codes::SIDECAR_CORRUPTION
• error_codes::SINK_ALREADY_EXISTS
• error_codes::SINK_NOT_FOUND
• error_codes::SINK_ROLLBACK_FAILED
• error_codes::SOURCE_ALREADY_EXISTS
• error_codes::SOURCE_NOT_FOUND
• error_codes::SQL_COLUMN_NOT_FOUND
• error_codes::SQL_PLANNING_FAILED
• error_codes::SQL_TABLE_NOT_FOUND
• error_codes::SQL_TYPE_MISMATCH
• error_codes::SQL_UNSUPPORTED
• error_codes::STATE_CORRUPTION
• error_codes::STATE_KEY_MISSING
• error_codes::TEMPORAL_JOIN_NO_PK
• error_codes::UNRESOLVED_CONFIG_VAR
• error_codes::WAL_CHECKSUM_MISMATCH
• error_codes::WAL_ERROR
• error_codes::WAL_INVALID_LENGTH
• error_codes::WATERMARK_REQUIRED
• error_codes::WINDOW_INVALID
• error_codes::WINDOW_SIZE_INVALID
• serialization::jsonb_tags::ARRAY
• serialization::jsonb_tags::BOOL_FALSE
• serialization::jsonb_tags::BOOL_TRUE
• serialization::jsonb_tags::FLOAT64
• serialization::jsonb_tags::INT64
• serialization::jsonb_tags::NULL
• serialization::jsonb_tags::OBJECT
• serialization::jsonb_tags::STRING
• shuffle::message::MAX_PAYLOAD_BYTES
• shuffle::transport::SHUFFLE_ADDR_KEY
• state::config::DEFAULT_VNODE_CAPACITY
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE
• time::DEFAULT_MAX_FUTURE_SKEW_MS