List of all items
Structs
- canonical_message::CanonicalMessage
- canonical_message::MessageContext
- command_handler::CommandPublisher
- endpoints::fanout::FanoutPublisher
- endpoints::file::FileConsumer
- endpoints::file::FilePublisher
- endpoints::memory::MemoryChannel
- endpoints::memory::MemoryPublisher
- endpoints::memory::MemoryQueueConsumer
- endpoints::memory::MemoryResponseChannel
- endpoints::memory::MemorySubscriber
- endpoints::memory::ipc_unix::UnixIpcTransport
- endpoints::memory::memory_transport::MemoryTransport
- endpoints::null::NullPublisher
- endpoints::reader::ReaderPublisher
- endpoints::response::ResponsePublisher
- endpoints::static_endpoint::StaticEndpointPublisher
- endpoints::static_endpoint::StaticRequestConsumer
- endpoints::stream_buffer::StreamBufferConsumer
- endpoints::stream_buffer::StreamBufferPublisher
- endpoints::switch::SwitchPublisher
- event_handler::EventPublisher
- event_store::EventStore
- event_store::EventStoreConsumer
- event_store::RetentionPolicy
- event_store::StoredEvent
- models::AmqpConfig
- models::AwsConfig
- models::BufferMiddleware
- models::CookieJarMiddleware
- models::DeadLetterQueueMiddleware
- models::DeduplicationMiddleware
- models::DelayMiddleware
- models::Endpoint
- models::FileConfig
- models::GrpcConfig
- models::HttpConfig
- models::IbmMqConfig
- models::KafkaConfig
- models::LimiterMiddleware
- models::MemoryConfig
- models::MetricsMiddleware
- models::MongoDbConfig
- models::MqttConfig
- models::NatsConfig
- models::RandomPanicMiddleware
- models::ResponseConfig
- models::RetryMiddleware
- models::Route
- models::RouteOptions
- models::SledConfig
- models::SqlxConfig
- models::StaticConfig
- models::StreamBufferConfig
- models::SwitchConfig
- models::TlsConfig
- models::WeakJoinMiddleware
- models::WebSocketConfig
- models::ZeroMqConfig
- outcomes::Received
- outcomes::ReceivedBatch
- publisher::Publisher
- route::RouteHandle
- traits::EndpointStatus
- traits::SimpleHandler
- type_handler::TypeHandler
Enums
- endpoints::memory::MemoryConsumer
- endpoints::memory::transport::TransportUrl
- errors::ConsumerError
- errors::ProcessingError
- models::EndpointType
- models::FaultMode
- models::FileConsumerMode
- models::FileFormat
- models::HttpServerProtocol
- models::Middleware
- models::MongoDbFormat
- models::MqttProtocol
- models::NatsDeliverPolicy
- models::WebSocketExecutionMode
- models::ZeroMqSocketType
- outcomes::Handled
- outcomes::Sent
- outcomes::SentBatch
- traits::MessageDisposition
Traits
- endpoints::memory::transport::TransportChannel
- models::SecretExtractor
- response::ErgonomicResponse
- response::IntoHandled
- response::IntoHandlerResult
- response::ToHandlerError
- traits::AsyncHandler
- traits::CustomEndpointFactory
- traits::CustomMiddlewareFactory
- traits::Handler
- traits::MessageConsumer
- traits::MessagePublisher
- type_handler::IntoTypedHandler
Macros
Functions
- canonical_message::deserialize_u128
- canonical_message::print_uuidv7
- endpoints::check_consumer
- endpoints::check_publisher
- endpoints::create_consumer_from_route
- endpoints::create_publisher_from_route
- endpoints::memory::get_or_create_channel
- endpoints::memory::get_or_create_response_channel
- event_store::event_store_exists
- event_store::get_or_create_event_store
- extensions::get_endpoint_factory
- extensions::get_middleware_factory
- extensions::register_endpoint_factory
- extensions::register_middleware_factory
- middleware::apply_middlewares_to_consumer
- middleware::apply_middlewares_to_publisher
- models::extract_config_secrets
- publisher::get_publisher
- publisher::list_publishers
- publisher::register_publisher
- publisher::unregister_publisher
- route::get_endpoint
- route::get_route
- route::list_routes
- route::register_endpoint
- route::stop_route
- traits::into_batch_commit_func
- traits::into_commit_func
- traits::send_batch_helper
Type Aliases
- errors::HandlerError
- errors::PublisherError
- models::Config
- models::PublisherConfig
- traits::BatchCommitFunc
- traits::BoxFuture
- traits::CommitFunc