Index A | B | C | D | E | F | G | H | M | N | P | R | S | U A AbstractMessageSerializer (class in messagebus) Adapter add() (messagebus.AsyncEventstoreAbstractRepository method) (messagebus.SyncEventstoreAbstractRepository method) add_listener() (messagebus.AsyncMessageBus method) (messagebus.SyncMessageBus method) Architecture Patterns With Python async_listen() (in module messagebus) AsyncAbstractEventstreamTransport (class in messagebus) AsyncAbstractRepository (class in messagebus) AsyncAbstractUnitOfWork (class in messagebus) AsyncEventstoreAbstractRepository (class in messagebus) AsyncEventstreamPublisher (class in messagebus) AsyncMessageBus (class in messagebus) AsyncSinkholeEventstoreRepository (class in messagebus) AsyncSinkholeEventstreamTransport (class in messagebus) AsyncUnitOfWorkTransaction (class in messagebus) B Breaking Change C casualcms collect_new_events() (messagebus.AsyncAbstractUnitOfWork method) (messagebus.SyncAbstractUnitOfWork method) Command (in module messagebus) commit() (messagebus.AsyncAbstractUnitOfWork method) (messagebus.AsyncUnitOfWorkTransaction method) (messagebus.SyncAbstractUnitOfWork method) (messagebus.SyncUnitOfWorkTransaction method) created_at (messagebus.Message attribute) D DDD Domain Driven Design Domain Model E Event (in module messagebus) Event Replay Event Sourcing Event Store Event Stream eventstore (messagebus.AsyncAbstractUnitOfWork attribute) (messagebus.AsyncUnitOfWorkTransaction property) (messagebus.SyncAbstractUnitOfWork attribute) (messagebus.SyncUnitOfWorkTransaction property) F Field() (in module messagebus) G Gandi GenericCommand (class in messagebus) GenericEvent (class in messagebus) GenericModel (class in messagebus) H handle() (messagebus.AsyncMessageBus method) (messagebus.SyncMessageBus method) Hexagonal Architecture M Message (class in messagebus) Message Bus message_id (messagebus.Message attribute) messagebus module messages (messagebus.GenericModel attribute) Metadata (class in messagebus) metadata (messagebus.Message attribute) Model (in module messagebus) model_config (messagebus.GenericCommand attribute) (messagebus.GenericEvent attribute) (messagebus.GenericModel attribute) (messagebus.Message attribute) (messagebus.Metadata attribute) module messagebus N name (messagebus.Metadata attribute) P publish_eventstream() (messagebus.AsyncEventstoreAbstractRepository method) (messagebus.SyncEventstoreAbstractRepository method) published (messagebus.Metadata attribute) purgatory R remove_listener() (messagebus.AsyncMessageBus method) (messagebus.SyncMessageBus method) Repository rollback() (messagebus.AsyncAbstractUnitOfWork method) (messagebus.AsyncUnitOfWorkTransaction method) (messagebus.SyncAbstractUnitOfWork method) (messagebus.SyncUnitOfWorkTransaction method) S scan() (messagebus.AsyncMessageBus method) (messagebus.SyncMessageBus method) schema_version (messagebus.Metadata attribute) seen (messagebus.AsyncAbstractRepository attribute) (messagebus.SyncAbstractRepository attribute) send_message() (messagebus.AsyncEventstreamPublisher method) (messagebus.SyncEventstreamPublisher method) send_message_serialized() (messagebus.AsyncAbstractEventstreamTransport method) (messagebus.AsyncSinkholeEventstreamTransport method) (messagebus.SyncAbstractEventstreamTransport method) (messagebus.SyncSinkholeEventstreamTransport method) serialize_message() (messagebus.AbstractMessageSerializer method) Service Handler status (messagebus.AsyncUnitOfWorkTransaction attribute) (messagebus.SyncUnitOfWorkTransaction attribute) sync_listen() (in module messagebus) SyncAbstractEventstreamTransport (class in messagebus) SyncAbstractRepository (class in messagebus) SyncAbstractUnitOfWork (class in messagebus) SyncEventstoreAbstractRepository (class in messagebus) SyncEventstreamPublisher (class in messagebus) SyncMessageBus (class in messagebus) SyncSinkholeEventstoreRepository (class in messagebus) SyncSinkholeEventstreamTransport (class in messagebus) SyncUnitOfWorkTransaction (class in messagebus) U Ubiquitous Language Unit Of Work uow (messagebus.AsyncUnitOfWorkTransaction attribute) (messagebus.SyncUnitOfWorkTransaction attribute)