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::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