List of all items

Structs

• checkpoint::assignment::AssignmentDrainId
• checkpoint::assignment::AssignmentDrainTransition
• checkpoint::assignment::CheckpointAssignmentAdoption
• checkpoint::assignment::CheckpointAssignmentFence
• checkpoint::assignment::CheckpointParticipant
• checkpoint::authority::LeaderProof
• checkpoint::authority::LeaderProofOwner
• 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_manifest::PipelineIdentity
• checkpoint::checkpoint_store::CheckpointArtifacts
• checkpoint::checkpoint_store::FileSystemCheckpointStore
• checkpoint::checkpoint_store::ObjectStoreCheckpointStore
• checkpoint::checkpoint_store::RecoveryReport
• checkpoint::checkpoint_store::ValidationResult
• checkpoint::prepared_witness::PreparedCheckpointWitness
• checkpoint::recovery_capsule::ClusterRecoveryCapsule
• checkpoint::recovery_capsule::CommittedSourceHandoff
• checkpoint::recovery_capsule::ParticipantRecoveryRef
• checkpoint::recovery_capsule::RecoveryCapsuleRef
• checkpoint::recovery_capsule::SourceHandoffState
• checkpoint_decision::CheckpointDecisionStore
• checkpoint_decision::CheckpointOutcome
• checkpoint_decision::CheckpointSinkOpenWitness
• checkpoint_decision::OutcomeRetentionBoundary
• checkpoint_decision::RecoveryCapsuleGcStep
• cluster::control::LeaseDeadline
• cluster::control::NamespaceProofError
• cluster::control::VerifiedClusterNamespaces
• 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::CatalogManifestRef
• cluster::control::catalog_manifest::CatalogManifestStore
• cluster::control::chitchat_kv::ChitchatKv
• cluster::control::controller::ClusterController
• cluster::control::controller::RecoveryAdmissionSnapshot
• cluster::control::controller::RecoveryAnnouncement
• cluster::control::controller::RecoveryFault
• cluster::control::controller::RecoveryFaultInventory
• cluster::control::controller::RecoveryFaultRequest
• cluster::control::controller::RecoveryReleaseGuard
• cluster::control::controller::RecoveryRound
• cluster::control::controller::RecoveryRoundId
• cluster::control::controller::RecoveryStoppedReport
• cluster::control::leader_lease::AssignmentDrainDecision
• cluster::control::leader_lease::AssignmentRecoveryDecision
• cluster::control::leader_lease::ClusterOutcomeInventory
• cluster::control::leader_lease::ClusterOutcomeRetentionBoundary
• cluster::control::leader_lease::LeaderCandidacy
• cluster::control::leader_lease::LeaderLease
• cluster::control::leader_lease::LeaderLeaseConfig
• cluster::control::leader_lease::LeaderLeaseManager
• cluster::control::leader_lease::LeaderLeaseObservation
• cluster::control::leader_lease::LeaderLeaseOwner
• cluster::control::leader_lease::LeaderLeaseStore
• cluster::control::process_lease::ProcessLease
• cluster::control::process_lease::ProcessLeaseAuthority
• cluster::control::process_lease::ProcessLeaseConfig
• cluster::control::process_lease::ProcessLeaseFence
• cluster::control::process_lease::ProcessLeaseManager
• cluster::control::process_lease::ProcessLeaseObservation
• cluster::control::process_lease::ProcessLeaseStore
• cluster::control::snapshot::AssignmentSnapshot
• cluster::control::snapshot::AssignmentSnapshotRef
• 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::BoundedBytesWriter
• shuffle::routing::CheckpointRoutePlan
• shuffle::routing::LocalRoute
• shuffle::routing::RemoteRoute
• shuffle::transport::ReceivedBatch
• shuffle::transport::ReceivedShuffle
• shuffle::transport::ShuffleBatchAdmission
• shuffle::transport::ShuffleReceiver
• shuffle::transport::ShuffleSender
• state::backend::ArchivedCheckpointAttempt
• state::backend::CheckpointAttempt
• state::backend::CheckpointAttemptResolver
• state::backend::CheckpointSealInventory
• state::backend::SealedCommitDescriptor
• state::backend::SealedCommitDescriptorWriter
• state::backend::SealedVnodePartial
• state::backend::SealedVnodeWriter
• state::config::StorageOptions
• state::in_process::InProcessBackend
• state::object_store::ObjectStoreBackend
• state::vnode::ArchivedNodeId
• state::vnode::InvalidKeyGroupCount
• state::vnode::KeyGroupCount
• state::vnode::Locality
• state::vnode::NodeId
• state::vnode::NodeIdResolver
• state::vnode::VnodeAssignmentReadGuard
• state::vnode::VnodeAssignmentSnapshot
• 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::WatermarkRestoreError
• time::WatermarkTracker

Enums

• Error
• catalog::CatalogObjectKind
• checkpoint::barrier::StreamMessage
• checkpoint::checkpoint_manifest::DurableCheckpointPhase
• checkpoint::checkpoint_store::CheckpointStoreError
• checkpoint::checkpoint_store::ValidationIssue
• checkpoint::object_store_builder::ObjectStoreBuilderError
• checkpoint::recovery_capsule::CheckpointWatermark
• checkpoint_decision::CheckpointScope
• checkpoint_decision::CheckpointVerdict
• checkpoint_decision::DecisionError
• checkpoint_decision::RecordOutcomeResult
• cluster::control::barrier::Phase
• cluster::control::barrier::QuorumOutcome
• cluster::control::catalog_manifest::CatalogManifestError
• cluster::control::catalog_manifest::CatalogSealOutcome
• cluster::control::controller::CheckpointPrepareObservation
• cluster::control::controller::RecoverPhase
• cluster::control::controller::RecoveryControlError
• cluster::control::controller::RecoveryFaultReportOutcome
• cluster::control::controller::ReleaseCommitStatus
• cluster::control::leader_lease::AssignmentDrainVerdict
• cluster::control::leader_lease::ClusterCheckpointAuthorityError
• cluster::control::leader_lease::LeaseError
• cluster::control::leader_lease::LeaseOutcome
• cluster::control::leader_lease::RecordAssignmentDrainDecisionResult
• cluster::control::leader_lease::RecordAssignmentRecoveryDecisionResult
• cluster::control::process_lease::ProcessLeaseError
• cluster::control::process_lease::ProcessLeaseOutcome
• 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
• durable_fs::DurableRenameMode
• 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
• shuffle::routing::ShuffleRoutingError
• state::backend::CheckpointAttemptRelation
• state::backend::StateBackendDurability
• state::backend::StateBackendError
• state::config::StateBackendBuildError
• state::config::StateBackendConfig
• state::vnode::VnodeLifecycleState
• 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::discovery::Discovery
• lookup::source::LookupSource
• lookup::source::LookupSourceDyn
• operator::window::WindowAssigner
• state::backend::StateBackend
• streaming::source::Record
• time::WatermarkGenerator

Functions

• checkpoint::checkpoint_store::validate_max_checkpoint_state_bytes
• checkpoint::object_store_builder::build_object_store
• checkpoint::object_store_builder::file_url_path
• checkpoint::object_store_builder::is_absolute_local_file_url
• checkpoint::recovery_capsule::canonical_json_bytes
• checkpoint::recovery_capsule::canonical_json_sha256
• cluster::control::leader::leader_of
• cluster::control::leader_lease::lease_grants_leadership
• cluster::control::leader_lease::lease_grants_proof
• cluster::control::prove_shared_object_store_namespaces
• cluster::control::tls::claim_cluster_plaintext
• cluster::control::tls::set_cluster_tls
• cluster::discovery::assignable_node_ids
• durable_fs::durable_rename
• durable_fs::ensure_durable_directory
• lookup::predicate::predicate_to_sql
• lookup::predicate::split_predicates
• lookup::source::projection_names
• serialization::deserialize_batch_stream
• serialization::serialize_batch_stream
• serialization::serialize_batches_stream_bounded
• shuffle::routing::route_checkpointed_batch
• shuffle::routing::row_vnodes
• shuffle::transport::is_scope_cancelled
• 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
• lookup::source::ColumnId
• operator::TimerKey
• operator::window::WindowIdVec
• shuffle::transport::ShufflePeerId
• time::FiredTimersVec
• time::TimerKey

Constants

• changelog::WEIGHT_COLUMN
• checkpoint::assignment::MAX_CHECKPOINT_PARTICIPANTS
• checkpoint::barrier::flags::CANCEL
• checkpoint::barrier::flags::DRAIN
• checkpoint::barrier::flags::FULL_SNAPSHOT
• checkpoint::barrier::flags::NONE
• checkpoint::checkpoint_manifest::CHECKPOINT_MANIFEST_VERSION
• checkpoint::checkpoint_manifest::PIPELINE_IDENTITY_VERSION
• checkpoint::checkpoint_store::DEFAULT_MAX_CHECKPOINT_STATE_BYTES
• checkpoint::checkpoint_store::MAX_CHECKPOINT_INVENTORY_ENTRIES
• checkpoint::prepared_witness::MAX_PREPARED_CHECKPOINT_WITNESSES
• checkpoint::recovery_capsule::CLUSTER_RECOVERY_CAPSULE_VERSION
• checkpoint::recovery_capsule::MAX_RECOVERY_CAPSULE_BYTES
• cluster::control::MAX_SHARED_NAMESPACE_PROOF_TIMEOUT
• 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::METADATA_TAGS
• cluster::discovery::keys::NODE_NAME
• cluster::discovery::keys::NODE_STATE
• cluster::discovery::keys::NODE_VERSION
• 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::CLUSTER_STATE_LIFECYCLE_UNSUPPORTED
• 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::DELIVERY_STATE_DURABILITY_MISMATCH
• 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_PROTOCOL_INCOMPLETE
• error_codes::EXACTLY_ONCE_SINK_UNSUPPORTED
• error_codes::EXACTLY_ONCE_SOURCE_UNCERTIFIED
• 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_CHECKPOINT_REQUIRED
• 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::routing::ROUTE_MAX_BATCH_BYTES
• shuffle::routing::ROUTE_MAX_BATCH_ROWS
• shuffle::routing::ROUTE_TARGET_BATCH_BYTES
• shuffle::transport::SHUFFLE_ADDR_KEY
• state::vnode::DEFAULT_CLUSTER_KEY_GROUP_COUNT
• state::vnode::LOCAL_KEY_GROUP_COUNT
• state::vnode::MAX_KEY_GROUP_COUNT
• state::vnode::PARTITIONING_ABI_VERSION
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE
• time::DEFAULT_MAX_FUTURE_SKEW_MS