List of all items

Structs

• backend::Stat
• backend::WorkerState
• builder::WorkerBuilder
• codec::NoopCodec
• codec::json::JsonCodec
• data::Extensions
• error::ErrorHandlingLayer
• error::ErrorHandlingService
• interval::Interval
• layers::AckLayer
• layers::AckService
• layers::BoxCloneService
• layers::CommonLayer
• layers::Identity
• layers::ServiceBuilder
• layers::extensions::AddExtension
• layers::extensions::Data
• memory::MemoryStorage
• memory::MemoryWrapper
• monitor::Monitor
• monitor::shutdown::Shutdown
• notify::Notify
• poller::Poller
• poller::controller::Controller
• poller::stream::BackendStream
• request::Parts
• request::Request
• response::Response
• service_fn::ServiceFn
• step::StepBuilder
• step::StepRequest
• step::StepService
• task::attempt::Attempt
• task::namespace::Namespace
• task::task_id::TaskId
• test_utils::DummyService
• test_utils::TestEmitService
• test_utils::TestWrapper
• worker::Context
• worker::Ready
• worker::Runnable
• worker::Tracked
• worker::Worker
• worker::WorkerId

Enums

• error::Error
• request::State
• step::GoTo
• step::StepError
• worker::Event
• worker::WorkerError

Traits

• backend::Backend
• backend::BackendExpose
• builder::WorkerFactory
• builder::WorkerFactoryFn
• codec::Codec
• layers::Ack
• layers::Layer
• layers::Service
• mq::MessageQueue
• response::IntoResponse
• service_fn::FromRequest
• step::Step
• step::StepFn
• step::StepIndex
• step::StepWorkerFactory
• step::SteppableStorage
• storage::Storage

Macros

• generic_storage_test
• test_message_queue

Functions

• interval::interval
• layers::layer_fn
• service_fn::service_fn
• sleep
• test_utils::apalis_test_service_fn

Type Aliases

• error::BoxDynError
• request::BoxStream
• request::RequestFuture
• request::RequestStream
• service_fn::FnFuture
• worker::EventHandler