List of all items

Structs

• activity_publisher::ActivityEventPublisher
• activity_publisher::TranscriptBatchPolicy
• activity_publisher::TranscriptStreamLagged
• api::deploy_grpc::DeployGrpcService
• api::grpc::WorkflowGrpcService
• api::worker_grpc::WorkerGrpcService
• assistant::descriptor::AssistantDescriptor
• assistant::descriptor::AssistantSessionContract
• assistant::descriptor::AssistantSignal
• assistant::document::EmbeddedAssistant
• assistant::install::WorkerListenerAdvice
• authoring::handlers::CompileSourceRequest
• authoring::handlers::CompileSourceResponse
• build_identity::BuildIdentity
• cluster::ClusterSupervisor
• cluster::OutboxSettlingAdopter
• cluster::SupervisorConfig
• cluster::WatchedPeer
• cluster_publisher::ClusterEventPublisher
• cluster_publisher::ClusterStreamLagged
• config::AionHome
• config::AuthConfig
• config::AuthoringConfig
• config::CliOverrides
• config::ClusterConfig
• config::ClusterPeer
• config::DeployConfig
• config::DevConfig
• config::DrainConfig
• config::ListenConfig
• config::McpConfig
• config::MetricsConfig
• config::NamespaceConfig
• config::NamespacesConfig
• config::ObservabilityConfig
• config::OpsConsoleConfig
• config::OutboxConfig
• config::ResolvedMcpConfig
• config::RuntimeConfig
• config::RuntimeSection
• config::ServerConfig
• config::ServerSection
• config::StoreConfig
• config::TlsConfig
• config::WebSocketConfig
• config::WorkerConfig
• config::WorkerSupervisionConfig
• control::incarnation::SelfIdentity
• control::outcome::OutcomeRecord
• control::outcome::ParkedWorkerRecord
• control::pid_file::PidFileGuard
• control::pid_file::PidRecord
• death_note::DeathNote
• deploy::guard::DeployGuard
• dev_ui::handlers::RegisterMockRequest
• dev_ui::handlers::RegisterMockResponse
• dev_ui::handlers::ReplayRunRequest
• dev_ui::handlers::ReplayRunResponse
• dev_ui::handlers::StreamSubscription
• dev_ui::handlers::TriggerRunRequest
• dev_ui::handlers::TriggerRunResponse
• dev_ui::mock::ActivityMockRegistry
• dev_ui::mock::DevMockingDispatcher
• error::ErrorTraceFields
• mcp::runtime::McpRuntime
• mcp::service::AionToolService
• namespace::guard::NamespaceGuard
• namespace::guard::ScheduleTarget
• namespace::guard::WorkflowTarget
• namespace::mint_forward::GrpcMintForwarder
• namespace::minter::NamespaceMinter
• namespace::resolver::CallerIdentity
• namespace::resolver::NamespaceResolver
• namespace::resolver::ScopedEngine
• namespace::resolver::StaticWorkflowNamespaces
• namespace::resolver::WorkflowAttribution
• namespace::route::MintCredentials
• namespace::route::NamespaceRouting
• namespace::schedule_source::StaticScheduleNamespaces
• observability::health::HealthState
• observability::instrumented_store::InstrumentedEventStore
• observability::metrics::Metrics
• routing::DirectoryPeer
• routing::GrpcRequestForwarder
• routing::NodeRef
• routing::StaticShardDirectory
• shutdown::DrainState
• shutdown::ShutdownReport
• state::ServerState
• stream::namespace_filter::NamespaceEventGate
• stream::selector::SubscriptionSelector
• stream::socket::EncodedEventStream
• stream::subscribe::EventSubscription
• stream::subscribe::MappedSubscription
• update_check::document::EmbeddedUpdateCheck
• worker::activity_cancel::CancelRequest
• worker::activity_cancel::InFlightCancellation
• worker::admission_audit::AdmissionAudit
• worker::admission_audit::RememberedRefusal
• worker::backpressure::Backpressure
• worker::backpressure::OwnedShardFraction
• worker::bridge::PendingActivities
• worker::bridge::WorkerActivityDispatcher
• worker::contracts::WorkerAdvertisement
• worker::declared_body::DeclaredBodySource
• worker::declared_body::DeclaredCommandDispatcher
• worker::declared_body::DispatchingRun
• worker::declared_body::EngineDeclaredBodies
• worker::declared_body_ambiguity::DeclaringVersion
• worker::declared_body_cancel::DeclaredAttemptRegistration
• worker::declared_body_cancel::DeclaredCommandAttempts
• worker::dispatch::ActivityCompletion
• worker::dispatch::ActivityDispatcher
• worker::dispatch::ScheduledActivity
• worker::envelope::CompletionFences
• worker::envelope::CompletionToken
• worker::grpc_liveness::GrpcLivenessTarget
• worker::grpc_liveness::GrpcLivenessWaiters
• worker::heartbeat::ExcludedWorker
• worker::heartbeat::HeartbeatSweeper
• worker::heartbeat::HeartbeatTracker
• worker::heartbeat::HeartbeatUpdate
• worker::heartbeat::InFlightActivity
• worker::heartbeat::LostWorkerReport
• worker::heartbeat::TaskLiveness
• worker::intervention::AttemptKey
• worker::intervention::AttemptOwnerIndex
• worker::intervention::InterventionRouter
• worker::liminal_liveness::LivenessPing
• worker::liminal_liveness::LivenessPong
• worker::liminal_liveness::LivenessProbe
• worker::liminal_liveness::LivenessTarget
• worker::liminal_transport::DispatchRequest
• worker::liminal_transport::DispatchResponse
• worker::liminal_transport::InterventionReply
• worker::liminal_transport::InterventionRequest
• worker::liminal_transport::LiminalCompletionSource
• worker::liminal_transport::LiminalConnectionNotifier
• worker::liminal_transport::LiminalInterventionTransport
• worker::liminal_transport::LiminalWorkerDelivery
• worker::liminal_transport::RegistryLiminalDispatch
• worker::liminal_transport::WorkerCapabilitiesAnnouncement
• worker::liminal_transport::WorkerLivenessBeat
• worker::outbox_delivery::ServerOutboxDeliveryCallback
• worker::outbox_dispatcher::DeliveryGate
• worker::outbox_dispatcher::DeliveryGuard
• worker::outbox_dispatcher::MissingDispatch
• worker::outbox_dispatcher::OutboxDispatcher
• worker::outbox_dispatcher::OutboxDispatcherConfig
• worker::outbox_dispatcher::WorkerOutboxDispatch
• worker::outbox_reconciler::OutboxReconciler
• worker::outbox_reconciler::OutboxReconcilerConfig
• worker::placement_cache::PlacementCache
• worker::queue_service::census::PoolCensus
• worker::queue_service::declarations::EngineQueueDeclarations
• worker::queue_service::declarations::QueueDeclarationSource
• worker::queue_service::policy::QueueServiceConfig
• worker::queue_service::policy::QueueServiceOverride
• worker::queue_service::reachability::ActivityReachability
• worker::queue_service::reachability::OpenActivity
• worker::queue_service::state::Parked
• worker::queue_service::state::QueueServiceState
• worker::queue_service::state::UnservedDispatch
• worker::queue_service::state::UnservedKey
• worker::queue_service::state::UnservedQueue
• worker::queue_service::taxonomy::ServiceAddress
• worker::queue_service::taxonomy::UnavailableSummary
• worker::queue_service::taxonomy::WorkerUnavailable
• worker::queue_service::wait::ObservedMiss
• worker::queue_service::wait::ServiceWait
• worker::quota_broadcast::QuotaBroadcaster
• worker::quota_cache::QuotaCache
• worker::registry::ConnectedWorkerRegistry
• worker::registry::PoolAddress
• worker::registry::WorkerHandle
• worker::registry::WorkerId
• worker::registry::WorkerInstanceIdentity
• worker::registry::WorkerRegistration
• worker::supervisor::fleet::FleetShutdownReport
• worker::supervisor::fleet::WorkerSupervisor
• worker::supervisor::policy::SupervisionPolicy
• worker::supervisor::status::ManagedWorkerExit
• worker::supervisor::status::ManagedWorkerReport
• worker::supervisor::status::ManagedWorkerStatus
• worker::supervisor::status::SpawnedBinary
• worker::transport_loss::TransportLossLedger
• worker::transport_loss::TransportLossVerdict
• worker::workspace_root::ExpandedCommand
• worker::workspace_root::WorkspaceRoot

Enums

• api::handlers::deploy::DeployApiError
• assistant::descriptor::AssistantResidency
• assistant::document::EmbeddedAssistantError
• assistant::install::AssistantInstall
• assistant::install::RoutedQueues
• authoring::error::AuthoringApiError
• config::AutoCreate
• config::HomeSource
• config::NamespaceMode
• config::OpsConsoleAssetSource
• config::OutboxTransport
• config::StoreBackend
• control::incarnation::IncarnationProbe
• control::outcome::NoteFate
• control::pid_file::StaleReconciliation
• control::stop::StopOutcome
• control::stop::StopRefusal
• control::stop::StopVerdict
• dev_ui::handlers::MockOutcome
• dev_ui::mock::MockedActivity
• error::CompletionRejectionReason
• error::ServerError
• error::StreamFailure
• namespace::guard::NamespaceOperation
• namespace::guard::SubscriptionScope
• namespace::route::ForwardMintError
• namespace::route::MintOwner
• namespace::route::MintRoute
• observability::metrics::MetricsError
• routing::ForwardReply
• routing::ForwardRequest
• routing::OwnerView
• routing::RemintOutcome
• routing::RouteDecision
• routing::SteerDecision
• shutdown::ShutdownOutcome
• stream::namespace_filter::GateVerdict
• update_check::document::EmbeddedUpdateCheckError
• update_check::install::UpdateCheckInstall
• worker::activity_cancel::CancelDelivery
• worker::admission_audit::RefusalSite
• worker::attempt_progress::AttemptProgress
• worker::contracts::ContractAdmissionError
• worker::declared_body::DeclaredBodyLookup
• worker::dispatch::ActivityCompletionOutcome
• worker::heartbeat::DispatchExclusion
• worker::outbox_redrive::RedriveRefused
• worker::placement_cache::WorkerSelection
• worker::queue_service::declarations::QueueDeclaration
• worker::queue_service::delivery::DeliveryRefusal
• worker::queue_service::policy::QueueServicePolicy
• worker::queue_service::taxonomy::ExpiredClock
• worker::queue_service::taxonomy::QueueServiceReason
• worker::queue_service::wait::SelectionRefusal
• worker::registry::WorkerDelivery
• worker::registry::WorkerMessage
• worker::supervisor::error::SupervisionError
• worker::supervisor::executable::ManagedExecutable
• worker::supervisor::status::ManagedWorkerState
• worker::workspace_root::WorkspaceRootError

Traits

• cluster::PeerLiveness
• cluster::ShardAdopter
• namespace::resolver::WorkflowNamespaceSource
• namespace::route::MintForwarder
• namespace::route::MintShardOwners
• namespace::route::NamespaceShardResolver
• namespace::schedule_source::ScheduleNamespaceSource
• routing::RequestForwarder
• routing::ShardDirectory
• worker::bridge::OutboxDeliveryCallback
• worker::declared_body::DeclaredBodies
• worker::dispatch::ActivityCompletionSink
• worker::intervention::InterventionTransport
• worker::outbox_dispatcher::OutboxRowDispatch
• worker::queue_service::declarations::QueueDeclarations

Functions

• api::deploy_grpc::deploy_service
• api::grpc::workflow_service
• api::handlers::cancel
• api::handlers::count
• api::handlers::deploy::list_versions
• api::handlers::deploy::load_package
• api::handlers::deploy::route_version
• api::handlers::deploy::unload_version
• api::handlers::describe
• api::handlers::list
• api::handlers::pause
• api::handlers::query
• api::handlers::rename
• api::handlers::reopen
• api::handlers::resume
• api::handlers::retire_workloop
• api::handlers::signal
• api::handlers::start
• api::handlers::start_with_placement
• api::http::http_router
• api::http::workflow_router
• api::schedule_handlers::create_schedule
• api::schedule_handlers::delete_schedule
• api::schedule_handlers::describe_schedule
• api::schedule_handlers::list_schedules
• api::schedule_handlers::pause_schedule
• api::schedule_handlers::resume_schedule
• api::schedule_handlers::update_schedule
• api::worker_grpc::worker_service
• api::ws_subscription::decode_subscription_request
• api::ws_subscription::read_subscription_request
• assistant::descriptor::describe
• assistant::document::embedded_assistant
• assistant::document::private_task_queue
• assistant::install::install_embedded_assistant
• assistant::install::install_embedded_assistant_for_server
• authoring::handlers::compile_and_load
• authoring::handlers::compile_and_load_document
• authoring::handlers::compile_and_load_with_options
• changelog::changelog_text
• cluster_publisher::cluster_event_meta
• config::aion_home
• config::env::overlay
• config::file::load_required
• control::incarnation::probe
• control::incarnation::self_identity
• control::outcome::read_fate
• control::outcome::render_entry
• control::pid_file::claim
• control::pid_file::pid_file_path
• control::pid_file::read
• control::pid_file::remove_if_matches
• control::stop::stop
• death_note::breadcrumb
• death_note::note_path
• dev_ui::handlers::register_mock
• dev_ui::handlers::replay_run
• dev_ui::handlers::trigger_run
• namespace::route::decode_mint_origin
• namespace::route::encode_mint_origin
• observability::health::live
• observability::health::ready
• observability::metrics::metrics_handler
• observability::tracing::init
• ops_console::assets::ops_console_router
• routing::current_hops
• routing::not_owner_wire
• routing::owner_refusal
• routing::route_mutation
• routing::route_start
• routing::route_start_steered
• run::run
• shutdown::drain_after_first_signal
• stream::cluster_stream::serve_cluster_socket
• stream::resume::splice
• stream::socket::forward_subscription
• stream::socket::handle_subscription_socket
• stream::socket::spawn_encoded_event_stream
• stream::subscribe::map_subscription_request
• stream::subscribe::subscribe_events
• stream::transcript_stream::serve_transcript_socket
• update_check::document::embedded_update_check
• update_check::install::install_embedded_update_check
• update_check::install::install_embedded_update_check_for_server
• worker::activity_cancel::cancel_in_flight_activities
• worker::attempt_progress::attempt_progress
• worker::contracts::validate_worker_contracts
• worker::declared_body_ambiguity::ambiguous_body_refusal
• worker::declared_body_selection::select_declared_body
• worker::dispatch::handle_activity_result
• worker::envelope::idempotency_key
• worker::heartbeat::sweep_interval
• worker::liminal_transport::channel_for_row
• worker::liminal_transport::dispatch_channel_name
• worker::liminal_transport::payload_from_request
• worker::liminal_transport::request_for_row
• worker::outbox_redrive::list_dead_letters
• worker::outbox_redrive::redrive_dead_lettered_row
• worker::outbox_settle::is_settle_terminal
• worker::outbox_settle::settle_terminal_outbox_rows
• worker::placement_cache::preferred_node_order
• worker::placement_cache::worker_selection_for
• worker::queue_service::census::classify
• worker::queue_service::delivery::deliver_within_schedule_to_start
• worker::queue_service::reachability::open_activities_in_active_segment
• worker::queue_service::wait::clear_selection_miss
• worker::queue_service::wait::observe_selection_miss
• worker::queue_service::wait::select_worker_or_refuse
• worker::transport_loss::is_transport_domain_reason
• worker::transport_loss::worker_lost_detail

Type Aliases

• stream::resume::LiveEventStream
• stream::socket::EncodedFrame
• worker::registry::WorkerTaskSender

Constants

• assistant::document::CONTINUE_END_FIELD
• assistant::document::CONTINUE_MESSAGE_FIELD
• assistant::document::CONTINUE_SIGNAL
• assistant::document::EMBEDDED_ASSISTANT_DOCUMENT
• assistant::document::EMBEDDED_ASSISTANT_FILENAME
• assistant::document::OBJECTIVE_INPUT
• assistant::document::REPO_PATH_INPUT
• assistant::document::STATUS_QUERY
• config::DEFAULT_AUTHORING_WORKSPACE_DIR
• config::DEFAULT_CLUSTER_BROADCAST_CAPACITY
• config::DEFAULT_DEPLOY_MAX_ARCHIVE_BYTES
• config::DEFAULT_DEPLOY_MAX_INFLATED_BYTES
• config::DEFAULT_EVENT_BROADCAST_CAPACITY
• config::DEFAULT_FAILOVER_CONFIRMATIONS
• config::DEFAULT_FAILOVER_POLL_INTERVAL_MS
• config::DEFAULT_HAEMATITE_DATA_DIR
• config::DEFAULT_HTTP_ADDRESS
• config::DEFAULT_MAX_IN_FLIGHT_ACTIVITIES
• config::DEFAULT_MCP_DISCOVER_TTL_MS
• config::DEFAULT_MCP_TASK_POLL_INTERVAL_MS
• config::DEFAULT_MCP_TOOLS_LIST_TTL_MS
• config::DEFAULT_OBSERVABILITY_MAX_EVENT_BYTES
• config::DEFAULT_OBSERVABILITY_MAX_STREAM_EVENTS
• config::DEFAULT_OUTBOX_BACKOFF_BASE_MS
• config::DEFAULT_OUTBOX_BACKOFF_MAX_MS
• config::DEFAULT_OUTBOX_BACKOFF_MULTIPLIER
• config::DEFAULT_OUTBOX_BATCH_SIZE
• config::DEFAULT_OUTBOX_MAX_ATTEMPTS
• config::DEFAULT_OUTBOX_POLL_INTERVAL_MS
• config::DEFAULT_QUERY_TIMEOUT_MS
• config::DEFAULT_WORKLOOP_SWEEP_INTERVAL_MS
• config::FIRST_RUN_CONFIG
• config::MAX_TRANSCRIPT_WINDOW_LIMIT
• config::OBSERVABILITY_MAX_BATCH_EVENTS_REQUIRED
• config::OBSERVABILITY_MAX_BATCH_HOLD_MS_REQUIRED
• config::STORE_NODE_CACHE_BUDGET_REQUIRED
• namespace::resolver::DISPLAY_NAME_ATTRIBUTE
• namespace::resolver::NAMESPACE_ATTRIBUTE
• namespace::resolver::TASK_QUEUE_ATTRIBUTE
• routing::FORWARD_HOPS_METADATA
• routing::MAX_FORWARD_HOPS
• stream::resume::RESUME_CURSOR_AHEAD_OF_HISTORY
• stream::socket::SEQUENCE_CONTIGUITY_VIOLATION
• update_check::document::EMBEDDED_UPDATE_CHECK_DOCUMENT
• update_check::document::EMBEDDED_UPDATE_CHECK_FILENAME
• update_check::document::FETCH_ACTION
• update_check::document::FETCH_COMMAND
• update_check::document::UPDATE_CHECK_QUEUE
• update_check::document::UPDATE_CHECK_WORKFLOW_TYPE
• worker::WORKSPACE_ROOT_PLACEHOLDER
• worker::liminal_transport::WORKER_CAPABILITIES_CHANNEL
• worker::liminal_transport::WORKER_LIVENESS_CHANNEL
• worker::queue_service::delivery::PARK_POLL_INTERVAL
• worker::registry::DEFAULT_TASK_QUEUE
• worker::supervisor::policy::UNCOMMISSIONED_REMEDY
• worker::transport_loss::TRANSPORT_EXHAUSTED_REASON_PREFIX
• worker::transport_loss::TRANSPORT_LOSS_BUDGET_WINDOWS
• worker::transport_loss::WORKER_LOST_REASON_PREFIX
• worker::workspace_root::WORKSPACE_ROOT_PLACEHOLDER