event_driven_library

Module prelude

Source

Macros§

paste
prepare_bulk_insert

Structs§

ContextManager
Task Local Context Manager This is called for every time Messagebus.handle is invoked within which it manages events raised in service. It spawns out Executor that manages transaction.
HandlerMapper
A hash map implemented with quadratic probing and SIMD lookup.
MessageBus
MessageMetadata
OutBox
UnitOfWork

Enums§

BaseError

Traits§

Aggregate
ApplicationError
ApplicationResponse
Command
Deserialize
A data structure that can be deserialized from any data format supported by Serde.
Executor
Executor is abstract implementation of whatever storage layer you use. Among examples are RDBMS, Queue, NoSQLs.
IOutBox
MailSendable
Message
REventManager
Serialize
A data structure that can be serialized into any data format supported by Serde.

Type Aliases§

AnyError
AtomicContextManager
Future
TCommandHandler
TEventHandler

Attribute Macros§

async_trait
entity
message_handler

Derive Macros§

Aggregate
ApplicationError
Define a Application Error type that can be used in the event-driven-library.
ApplicationResponse
Define ApplicationResponse so that could be recognized by messagebus
Command
Deserialize
Message
Serialize