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::ComputeReplicaConfig
• controller::ComputeReplicaLogging
• 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::replica::ReplicaClient
• controller::replica::ReplicaConfig
• controller::replica::ReplicaTask
• controller::sequential_hydration::Collection
• controller::sequential_hydration::SequentialHydration
• logging::LoggingConfig
• logging::ProtoComputeLog
• logging::ProtoDifferentialLog
• logging::ProtoIndexLog
• logging::ProtoLogVariant
• logging::ProtoLoggingConfig
• logging::ProtoTimelyLog
• 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::command::ProtoComputeCommand
• protocol::command::ProtoComputeParameters
• protocol::command::ProtoIndexTarget
• protocol::command::ProtoInstanceConfig
• protocol::command::ProtoPeek
• protocol::command::ProtoPersistTarget
• protocol::command::ProtoWorkloadClass
• protocol::command::proto_compute_command::ProtoCreateTimely
• protocol::history::ComputeCommandHistory
• protocol::response::FrontiersResponse
• protocol::response::OperatorHydrationStatus
• protocol::response::ProtoComputeResponse
• protocol::response::ProtoCopyToResponse
• protocol::response::ProtoFrontiersResponse
• protocol::response::ProtoOperatorHydrationStatus
• protocol::response::ProtoPeekResponse
• protocol::response::ProtoStatusResponse
• protocol::response::ProtoSubscribeBatch
• protocol::response::ProtoSubscribeResponse
• protocol::response::SubscribeBatch
• protocol::response::proto_compute_response::ProtoCopyToResponseKind
• protocol::response::proto_compute_response::ProtoFrontiersKind
• protocol::response::proto_compute_response::ProtoPeekResponseKind
• protocol::response::proto_compute_response::ProtoSubscribeResponseKind
• protocol::response::proto_subscribe_batch::ProtoSubscribeBatchContents
• protocol::response::proto_subscribe_batch::ProtoSubscribeUpdates
• protocol::response::proto_subscribe_batch::ProtoUpdate
• service::PartitionedComputeState
• service::PendingSubscribe
• service::TrackedFrontiers
• service::proto_compute_client::ProtoComputeClient
• service::proto_compute_server::ProtoComputeServer

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
• logging::proto_compute_log::Kind
• logging::proto_differential_log::Kind
• logging::proto_log_variant::Kind
• logging::proto_timely_log::Kind
• protocol::command::ComputeCommand
• protocol::command::PeekTarget
• protocol::command::proto_compute_command::Kind
• protocol::command::proto_peek::Target
• protocol::response::ComputeResponse
• protocol::response::CopyToResponse
• protocol::response::PeekResponse
• protocol::response::StatusResponse
• protocol::response::SubscribeResponse
• protocol::response::proto_compute_response::Kind
• protocol::response::proto_copy_to_response::Kind
• protocol::response::proto_peek_response::Kind
• protocol::response::proto_status_response::Kind
• protocol::response::proto_subscribe_batch::proto_subscribe_batch_contents::Kind
• protocol::response::proto_subscribe_response::Kind
• service::ComputeProtoServiceTypes

Traits

• controller::ComputeControllerTimestamp
• service::ComputeClient
• service::proto_compute_server::ProtoCompute

Functions

• as_of_selection::fixpoint
• as_of_selection::run
• as_of_selection::step_back_frontier
• controller::sequential_hydration::forward_messages
• protocol::command::empty_otel_ctx

Type Aliases

• controller::IntrospectionUpdates
• controller::StorageCollections
• controller::instance::Command
• controller::instance::ReplicaResponse
• controller::replica::Client
• controller::sequential_hydration::Token
• metrics::Counter
• metrics::Gauge
• metrics::Histogram
• metrics::IntCounter
• metrics::UIntGauge
• service::ComputeGrpcClient

Constants

• controller::error::ERROR_TARGET_REPLICA_FAILED
• logging::_IMPL_ARBITRARY_FOR_ComputeLog
• logging::_IMPL_ARBITRARY_FOR_DifferentialLog
• logging::_IMPL_ARBITRARY_FOR_LogVariant
• logging::_IMPL_ARBITRARY_FOR_TimelyLog
• protocol::command::_IMPL_ARBITRARY_FOR_ComputeParameters
• protocol::command::_IMPL_ARBITRARY_FOR_InstanceConfig
• protocol::command::_IMPL_ARBITRARY_FOR_Peek
• protocol::command::_IMPL_ARBITRARY_FOR_PeekTarget
• protocol::response::_IMPL_ARBITRARY_FOR_OperatorHydrationStatus
• protocol::response::_IMPL_ARBITRARY_FOR_StatusResponse