List of all items
Structs
- core::error::DeserializeError
- core::error::SerializeError
- core::message::NatsSubjectPath
- core::message::SubjectMatcher
- core::processor::EmptyErrorTracer
- core::processor::RetryLayer
- jetstream::JetStreamConsumer
- kv::KvEntry
- kv::atomic_opt::AtomicMap
- kv::atomic_opt::AtomicOptProcessor
- kv::election::Election
- kv::election::ElectionValue
- kv::election::LeaderGuardProcessor
- kv::rw_lock::DistroRwLock
- kv::rw_lock::DistroRwLockValue
- kv::rw_lock::LockedResourceReadProcessor
- kv::rw_lock::LockedResourceWriteProcessor
- layer::Adapter
- layer::AdapterWrappedProcessor
- layer::LayerWrappedProcessor
- layer::PureAdapter
- layer::PureAdapterWrappedProcessor
- service_rpc::NatsService
Enums
- core::error::Error
- core::error::PostProcessError
- core::error::PreProcessError
- core::message::SubjectMatcherField
- flow::EarlyReturn
- kv::KvReadError
- kv::KvWriteError
- kv::atomic_opt::AtomicOptError
- kv::election::ElectionDesErr
- kv::election::ElectionError
- kv::election::ElectionNodeState
- kv::election::ElectionSerErr
- kv::election::LeaderGuardError
- kv::rw_lock::DistroRwLockDesErr
- kv::rw_lock::DistroRwLockError
- kv::rw_lock::DistroRwLockMode
- kv::rw_lock::DistroRwLockSerErr
- kv::rw_lock::WithLockProcessError
- prelude::EarlyReturn
Traits
- core::message::ByteDeserialize
- core::message::ByteSerialize
- core::message::DynamicSubjectMessage
- core::message::JetStreamMessageSendTrait
- core::message::NatsRpcCallTrait
- core::message::StaticSubjectMessage
- core::processor::ErrorTracer
- jetstream::FinalJetStreamProcessor
- kv::KeyValue
- kv::KeyValueRead
- kv::KeyValueWrite
- kv::StaticKeyIndexedValue
- layer::Layer
- prelude::FinalProcessor
- prelude::Processor
- processor::FinalProcessor
- processor::Processor
- processor::RefProcessor
- service_rpc::FinalNatsProcessor
- service_rpc::ServiceEndpoint
Macros
- early_return
- jet_route
- monad_early_return
- prelude::early_return
- protobuf_des
- protobuf_ser
- service_route
- subject_matcher
- subject_path