List of all items

Structs

• activity::ActivityFailure
• activity::ActivityRegistry
• activity::DuplicateActivityType
• config::ReconnectConfig
• config::TransportCredentials
• config::WorkerConfig
• config::WorkerConfigBuilder
• context::ActivityCancellationHandle
• context::ActivityContext
• context::HeartbeatRequest
• error::MissingActivityHandler
• protocol::heartbeat::ActivityExecutionKey
• protocol::heartbeat::HeartbeatBookkeeper
• protocol::reconnect::ReconnectBackoff
• protocol::reconnect::UnackedResultTracker
• protocol::session::GrpcWorkerSession
• protocol::session::RegisteredSessionInfo
• protocol::task::ActivityTask
• runtime::loop_::SessionHealth
• worker::EmptyActivitySet
• worker::Worker
• worker::WorkerBuilder

Enums

• activity::Classification
• config::WorkerConfigBuildError
• error::WorkerError
• protocol::reconnect::PendingActivityReport
• protocol::session::WorkerSessionEvent
• runtime::loop_::DispatchOutcome
• runtime::loop_::ServeEnd

Traits

• protocol::session::WorkerSession
• runtime::loop_::ActivityDispatcher

Functions

• activity::decode_payload
• activity::encode_payload
• protocol::heartbeat::send_heartbeat
• protocol::reconnect::connect_registered_grpc_session
• protocol::reconnect::re_report_unacked
• protocol::reconnect::reconnect_with_backoff
• protocol::reconnect::reconnect_with_sleep
• protocol::reconnect::register_connected_session
• protocol::session::validate_activity_handlers
• runtime::loop_::serve_activity_tasks
• runtime::loop_::serve_activity_tasks_until
• worker::run_worker_with_session

Type Aliases

• activity::HandlerFuture
• activity::TypedActivityDispatcher
• protocol::session::WorkerTaskStream
• runtime::loop_::NoShutdown