Modules¶
This library contains several modules that can help with event sourcing in Python.
domain— Domain models- Aggregates in DDD
- Event-sourced aggregates
- Domain events
- Aggregate events
- Aggregate “created” events
- “Subsequent” aggregate events
- “Discarded” events
- Aggregate base class
- Creating new aggregates
- Aggregate object attributes
- Triggering subsequent events
- Collecting pending events
- Simple example
- Namespaced IDs
- Alternative styles for implementing aggregate projector
- Avoiding repetition
- Declarative syntax
- Create new aggregate by calling the aggregate class directly
- Using the init method to define the created event class
- Dataclass-style init methods
- Declaring the created event class name
- Defining the aggregate ID
- The event decorator
- Inferring the event class name from the method name
- Using an explicitly defined event class
- The Dog aggregate class revisited
- The Page and Index aggregates revisited
- Non-trivial command methods
- Raising exceptions in the body of decorated methods
- The
@aggregatedecorator
- Timestamp timezones
- Initial version number
- Topic strings
- Registering topics
- Explicit topics
- Versioning
- Snapshots
- Notes
- Code reference
TZINFOEventsourcingTypeDomainEventProtocolMutableAggregateProtocolImmutableAggregateProtocolMutableOrImmutableAggregateTMutableOrImmutableAggregateCollectEventsProtocolCanMutateProtocoldatetime_now_with_tzinfo()create_utc_datetime_now()CanCreateTimestampHasOriginatorIDVersionCanMutateAggregateCanInitAggregateMetaDomainEventDomainEventAggregateEventAggregateCreatedEventSourcingErrorProgrammingErrorLogEventevent()triggers()UnboundCommandMethodDecoratorBoundCommandMethodDecoratorDecoratorEventMetaAggregateBaseAggregateOriginatorIDErrorOriginatorVersionErrorSnapshotProtocolCanSnapshotAggregateSnapshotAggregateaggregate()random()TopicErrorget_topic()resolve_topic()register_topic()retry()strtobool()Environmentsingledispatchmethod
application— Applications- Domain-driven design
- Application objects
- Simple example
- Repository
- Notification log
- Mappers, transcoders and transcodings
- Saving multiple aggregates
- Event-sourced log
- Application configuration
- Configuring aggregate caching
- Configuring persistence
- Configuring compression
- Configuring encryption
- Snapshotting
- Code reference
persistence— Persistence- Requirements
- Overview
- Stored event
- Transcoder
- Transcodings
- Mapper
- Compression
- Encryption
- Compression and encryption
- Notification
- Tracking
- Recorders
- Persistence modules
- Event store
- Infrastructure factory
- Code reference
TranscodingTranscoderTranscodingNotRegisteredErrorJSONTranscoderUUIDAsHexDecimalAsStrDatetimeAsISOStoredEventCompressorCipherMapperDeserialisationErrorMapperRecordConflictErrorPersistenceErrorInterfaceErrorDatabaseErrorDataErrorOperationalErrorIntegrityErrorInternalErrorProgrammingErrorNotSupportedErrorWaitInterruptedErrorAggregateRecorderNotificationApplicationRecorderTrackingRecorderProcessRecorderRecordingEventStoreInfrastructureFactoryErrorInfrastructureFactoryTrackingCursorConnectionConnectionPoolClosedErrorConnectionNotFromPoolErrorConnectionUnavailableErrorConnectionPoolSubscriptionListenNotifySubscriptionPOPOAggregateRecorderPOPOApplicationRecorderPOPOSubscriptionPOPOTrackingRecorderPOPOProcessRecorderPOPOFactoryFactorySQLiteCursorSQLiteConnectionSQLiteConnectionPoolSQLiteAggregateRecorderSQLiteApplicationRecorderSQLiteTrackingRecorderSQLiteProcessRecorderSQLiteFactoryFactoryConnectionPoolPostgresDatastorePostgresRecorderPostgresAggregateRecorderPostgresApplicationRecorderPostgresSubscriptionPostgresTrackingRecorderPostgresProcessRecorderPostgresFactoryFactory
projection— Projectionssystem— Event-driven systems- System of applications
- Single-threaded runner
- Multi-threaded runner
- Code reference
RecordingEventFollowerRecordingEventReceiverLeaderProcessApplicationSystemRunnerRunnerAlreadyStartedErrorNotificationPullingErrorNotificationConvertingErrorEventProcessingErrorSingleThreadedRunnerNewSingleThreadedRunnerMultiThreadedRunnerMultiThreadedRunnerThreadNewMultiThreadedRunnerPullingThreadConvertingThreadProcessingThreadNotificationLogReader
interface— Interface