List of all items
Structs
- CommandHandler
- CommandResponseWithEventFutures
- Context
- ContextManager
- EventMetadata
- HandlerMapper
- MessageBus
- OutBox
- SnowFlake
- command::CommandHandler
- serde::de::IgnoredAny
- serde::de::value::BoolDeserializer
- serde::de::value::BorrowedBytesDeserializer
- serde::de::value::BorrowedStrDeserializer
- serde::de::value::BytesDeserializer
- serde::de::value::CharDeserializer
- serde::de::value::CowStrDeserializer
- serde::de::value::EnumAccessDeserializer
- serde::de::value::Error
- serde::de::value::F32Deserializer
- serde::de::value::F64Deserializer
- serde::de::value::I128Deserializer
- serde::de::value::I16Deserializer
- serde::de::value::I32Deserializer
- serde::de::value::I64Deserializer
- serde::de::value::I8Deserializer
- serde::de::value::IsizeDeserializer
- serde::de::value::MapAccessDeserializer
- serde::de::value::MapDeserializer
- serde::de::value::SeqAccessDeserializer
- serde::de::value::SeqDeserializer
- serde::de::value::StrDeserializer
- serde::de::value::StringDeserializer
- serde::de::value::U128Deserializer
- serde::de::value::U16Deserializer
- serde::de::value::U32Deserializer
- serde::de::value::U64Deserializer
- serde::de::value::U8Deserializer
- serde::de::value::UnitDeserializer
- serde::de::value::UsizeDeserializer
- serde::ser::Impossible
- serde_json::Deserializer
- serde_json::Error
- serde_json::Map
- serde_json::Number
- serde_json::Serializer
- serde_json::StreamDeserializer
- serde_json::de::Deserializer
- serde_json::de::IoRead
- serde_json::de::SliceRead
- serde_json::de::StrRead
- serde_json::de::StreamDeserializer
- serde_json::error::Error
- serde_json::map::IntoIter
- serde_json::map::Iter
- serde_json::map::IterMut
- serde_json::map::Keys
- serde_json::map::Map
- serde_json::map::OccupiedEntry
- serde_json::map::VacantEntry
- serde_json::map::Values
- serde_json::map::ValuesMut
- serde_json::ser::CompactFormatter
- serde_json::ser::PrettyFormatter
- serde_json::ser::Serializer
- serde_json::value::Map
- serde_json::value::Number
- serde_json::value::Serializer
- tokio::io::Error
- tokio::io::ReadBuf
- tokio::runtime::Builder
- tokio::runtime::EnterGuard
- tokio::runtime::Handle
- tokio::runtime::Runtime
- tokio::runtime::RuntimeMetrics
- tokio::runtime::TryCurrentError
- tokio::sync::AcquireError
- tokio::sync::Barrier
- tokio::sync::BarrierWaitResult
- tokio::sync::MappedMutexGuard
- tokio::sync::Mutex
- tokio::sync::MutexGuard
- tokio::sync::Notify
- tokio::sync::OnceCell
- tokio::sync::OwnedMappedMutexGuard
- tokio::sync::OwnedMutexGuard
- tokio::sync::OwnedRwLockMappedWriteGuard
- tokio::sync::OwnedRwLockReadGuard
- tokio::sync::OwnedRwLockWriteGuard
- tokio::sync::OwnedSemaphorePermit
- tokio::sync::RwLock
- tokio::sync::RwLockMappedWriteGuard
- tokio::sync::RwLockReadGuard
- tokio::sync::RwLockWriteGuard
- tokio::sync::Semaphore
- tokio::sync::SemaphorePermit
- tokio::sync::TryLockError
- tokio::sync::broadcast::Receiver
- tokio::sync::broadcast::Sender
- tokio::sync::broadcast::error::SendError
- tokio::sync::futures::Notified
- tokio::sync::mpsc::OwnedPermit
- tokio::sync::mpsc::Permit
- tokio::sync::mpsc::PermitIterator
- tokio::sync::mpsc::Receiver
- tokio::sync::mpsc::Sender
- tokio::sync::mpsc::UnboundedReceiver
- tokio::sync::mpsc::UnboundedSender
- tokio::sync::mpsc::WeakSender
- tokio::sync::mpsc::WeakUnboundedSender
- tokio::sync::mpsc::error::SendError
- tokio::sync::oneshot::Receiver
- tokio::sync::oneshot::Sender
- tokio::sync::oneshot::error::RecvError
- tokio::sync::watch::Receiver
- tokio::sync::watch::Ref
- tokio::sync::watch::Sender
- tokio::sync::watch::error::RecvError
- tokio::sync::watch::error::SendError
- tokio::task::AbortHandle
- tokio::task::JoinError
- tokio::task::JoinHandle
- tokio::task::JoinSet
- tokio::task::LocalEnterGuard
- tokio::task::LocalKey
- tokio::task::LocalSet
- tokio::task::Unconstrained
- tokio::task::futures::TaskLocalFuture
- tracing::Dispatch
- tracing::Event
- tracing::Id
- tracing::Level
- tracing::Metadata
- tracing::Span
- tracing::callsite::DefaultCallsite
- tracing::callsite::Identifier
- tracing::dispatcher::DefaultGuard
- tracing::dispatcher::Dispatch
- tracing::dispatcher::SetGlobalDefaultError
- tracing::dispatcher::WeakDispatch
- tracing::event::Event
- tracing::field::DebugValue
- tracing::field::DisplayValue
- tracing::field::Empty
- tracing::field::Field
- tracing::field::FieldSet
- tracing::field::Iter
- tracing::field::ValueSet
- tracing::instrument::Instrumented
- tracing::instrument::WithDispatch
- tracing::level_filters::LevelFilter
- tracing::level_filters::ParseLevelFilterError
- tracing::metadata::Kind
- tracing::metadata::Level
- tracing::metadata::LevelFilter
- tracing::metadata::Metadata
- tracing::metadata::ParseLevelError
- tracing::metadata::ParseLevelFilterError
- tracing::span::Attributes
- tracing::span::Entered
- tracing::span::EnteredSpan
- tracing::span::Id
- tracing::span::Record
- tracing::span::Span
- tracing::subscriber::DefaultGuard
- tracing::subscriber::Interest
- tracing::subscriber::NoSubscriber
- tracing::subscriber::SetGlobalDefaultError
Enums
- BaseError
- EventHandlers
- event::EventHandlers
- serde::de::Unexpected
- serde_json::Value
- serde_json::error::Category
- serde_json::map::Entry
- serde_json::ser::CharEscape
- serde_json::value::Value
- tokio::io::ErrorKind
- tokio::io::SeekFrom
- tokio::runtime::RuntimeFlavor
- tokio::sync::SetError
- tokio::sync::TryAcquireError
- tokio::sync::broadcast::error::RecvError
- tokio::sync::broadcast::error::TryRecvError
- tokio::sync::mpsc::error::TryRecvError
- tokio::sync::mpsc::error::TrySendError
- tokio::sync::oneshot::error::TryRecvError
Traits
- ApplicationError
- ApplicationResponse
- AsyncFunc
- Deserialize
- Serialize
- TAggregate
- TCommand
- TCommandService
- TConnection
- TEvent
- TEventBus
- TGetHandler
- TMessageBus
- TSetCurrentEvents
- TUnitOfWork
- TUnitOfWorkCommandHandler
- command::AsyncFunc
- command::TGetHandler
- command::TUnitOfWorkCommandHandler
- command::uow::TUnitOfWorkCommandHandler
- serde::Deserialize
- serde::Deserializer
- serde::Serialize
- serde::Serializer
- serde::de::Deserialize
- serde::de::DeserializeOwned
- serde::de::DeserializeSeed
- serde::de::Deserializer
- serde::de::EnumAccess
- serde::de::Error
- serde::de::Expected
- serde::de::IntoDeserializer
- serde::de::MapAccess
- serde::de::SeqAccess
- serde::de::StdError
- serde::de::VariantAccess
- serde::de::Visitor
- serde::ser::Error
- serde::ser::Serialize
- serde::ser::SerializeMap
- serde::ser::SerializeSeq
- serde::ser::SerializeStruct
- serde::ser::SerializeStructVariant
- serde::ser::SerializeTuple
- serde::ser::SerializeTupleStruct
- serde::ser::SerializeTupleVariant
- serde::ser::Serializer
- serde::ser::StdError
- serde_json::de::Read
- serde_json::ser::Formatter
- serde_json::value::Index
- tokio::io::AsyncBufRead
- tokio::io::AsyncRead
- tokio::io::AsyncSeek
- tokio::io::AsyncWrite
- tokio::net::ToSocketAddrs
- tracing::Callsite
- tracing::Instrument
- tracing::Subscriber
- tracing::Value
- tracing::callsite::Callsite
- tracing::field::AsField
- tracing::field::Value
- tracing::field::Visit
- tracing::instrument::Instrument
- tracing::instrument::WithSubscriber
- tracing::span::AsId
- tracing::subscriber::Subscriber
Macros
- error
- init_event_handler
- make_conversion
- make_smart_pointer
- prepare_bulk_operation
- register_uow_services
- serde::forward_to_deserialize_any
- serde_json::json
- tokio::join
- tokio::pin
- tokio::select
- tokio::task_local
- tokio::try_join
- tracing::debug
- tracing::debug_span
- tracing::enabled
- tracing::error
- tracing::error_span
- tracing::event
- tracing::event_enabled
- tracing::info
- tracing::info_span
- tracing::metadata
- tracing::span
- tracing::span_enabled
- tracing::trace
- tracing::trace_span
- tracing::warn
- tracing::warn_span
Attribute Macros
Derive Macros
- ApplicationError
- ApplicationResponse
- Deserialize
- Serialize
- TConstruct
- TEvent
- serde::Deserialize
- serde::Serialize
Functions
- serde_json::de::from_reader
- serde_json::de::from_slice
- serde_json::de::from_str
- serde_json::from_reader
- serde_json::from_slice
- serde_json::from_str
- serde_json::from_value
- serde_json::ser::to_string
- serde_json::ser::to_string_pretty
- serde_json::ser::to_vec
- serde_json::ser::to_vec_pretty
- serde_json::ser::to_writer
- serde_json::ser::to_writer_pretty
- serde_json::to_string
- serde_json::to_string_pretty
- serde_json::to_value
- serde_json::to_vec
- serde_json::to_vec_pretty
- serde_json::to_writer
- serde_json::to_writer_pretty
- serde_json::value::from_value
- serde_json::value::to_value
- tokio::spawn
- tokio::sync::broadcast::channel
- tokio::sync::mpsc::channel
- tokio::sync::mpsc::unbounded_channel
- tokio::sync::oneshot::channel
- tokio::sync::watch::channel
- tokio::task::consume_budget
- tokio::task::spawn
- tokio::task::spawn_blocking
- tokio::task::spawn_local
- tokio::task::unconstrained
- tokio::task::yield_now
- tracing::callsite::rebuild_interest_cache
- tracing::callsite::register
- tracing::dispatcher::get_default
- tracing::dispatcher::set_default
- tracing::dispatcher::set_global_default
- tracing::dispatcher::with_default
- tracing::field::debug
- tracing::field::display
- tracing::subscriber::set_default
- tracing::subscriber::set_global_default
- tracing::subscriber::with_default
Type Aliases
- AtomicContextManager
- Future
- FutureResult
- Handlers
- TEventHandler
- event::Future
- event::FutureResult
- event::Handlers
- serde_json::Result
- serde_json::error::Result
- tokio::io::Result