List of all items

Structs

• as_of_selection::AsOfBounds
• as_of_selection::Collection
• as_of_selection::Constraint
• as_of_selection::Context
• controller::Collection
• controller::CollectionFrontiers
• controller::ComputeController
• controller::InstanceState
• controller::error::CollectionMissing
• controller::error::HydrationCheckBadTarget
• controller::error::InstanceExists
• controller::error::InstanceMissing
• controller::instance::ActiveSubscribe
• controller::instance::Client
• controller::instance::CollectionIntrospection
• controller::instance::CollectionState
• controller::instance::FrontiersIntrospectionState
• controller::instance::Instance
• controller::instance::PendingPeek
• controller::instance::RefreshIntrospectionState
• controller::instance::ReplicaCollectionIntrospection
• controller::instance::ReplicaCollectionState
• controller::instance::ReplicaExists
• controller::instance::ReplicaMissing
• controller::instance::ReplicaState
• controller::instance::SharedCollectionState
• controller::introspection::IntrospectionSink
• controller::replica::ReplicaClient
• controller::replica::ReplicaConfig
• controller::replica::ReplicaTask
• controller::sequential_hydration::Collection
• controller::sequential_hydration::SequentialHydration
• logging::LoggingConfig
• metrics::CommandMetrics
• metrics::ComputeControllerMetrics
• metrics::HistoryMetrics
• metrics::InstanceMetrics
• metrics::PeekMetrics
• metrics::ReplicaCollectionMetrics
• metrics::ReplicaMetrics
• metrics::ReplicaMetricsInner
• metrics::ResponseMetrics
• protocol::command::ComputeParameters
• protocol::command::InstanceConfig
• protocol::command::Peek
• protocol::history::ComputeCommandHistory
• protocol::response::FrontiersResponse
• protocol::response::StashedPeekResponse
• protocol::response::SubscribeBatch
• service::PartitionedComputeState
• service::PendingSubscribe
• service::TrackedFrontiers

Enums

• as_of_selection::BoundType
• as_of_selection::ConstraintType
• controller::ComputeControllerResponse
• controller::PeekNotification
• controller::error::CollectionLookupError
• controller::error::CollectionUpdateError
• controller::error::DataflowCreationError
• controller::error::PeekError
• controller::error::ReadPolicyError
• controller::error::RemoveOrphansError
• controller::error::ReplicaCreationError
• controller::error::ReplicaDropError
• controller::instance::DataflowCreationError
• controller::instance::PeekError
• controller::instance::ReadPolicyError
• controller::sequential_hydration::State
• logging::ComputeLog
• logging::DifferentialLog
• logging::LogVariant
• logging::TimelyLog
• protocol::command::ComputeCommand
• protocol::command::PeekTarget
• protocol::response::ComputeResponse
• protocol::response::CopyToResponse
• protocol::response::PeekResponse
• protocol::response::StatusResponse
• protocol::response::SubscribeResponse

Traits

• controller::ComputeControllerTimestamp
• service::ComputeClient

Functions

• as_of_selection::fixpoint
• as_of_selection::run
• as_of_selection::step_back_frontier
• controller::introspection::spawn_introspection_sink
• controller::sequential_hydration::forward_messages
• service::merge_peek_responses

Type Aliases

• controller::StorageCollections
• controller::instance::Command
• controller::instance::ReplicaResponse
• controller::introspection::AppendOnlySender
• controller::introspection::DifferentialSender
• controller::introspection::IntrospectionUpdates
• controller::introspection::Notifier
• controller::replica::Client
• controller::replica::ComputeCtpClient
• controller::sequential_hydration::Token
• metrics::Counter
• metrics::Histogram
• metrics::IntCounter
• metrics::UIntGauge

Constants

• controller::error::ERROR_TARGET_REPLICA_FAILED