eventsourcing
v7.2.0
Introduction
Support options
Quick start
Design
Features
Installation guide
Domain model layer
Infrastructure layer
Application layer
Notifications
Projections
Distributed systems
Snapshotting
Deployment
Stand-alone example
Background
Release notes
Contributing
Module docs
eventsourcing
Docs
»
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__assert_not_discarded__() (eventsourcing.domain.model.entity.DomainEntity method)
__change_attribute__() (eventsourcing.domain.model.entity.DomainEntity method)
__check_hash__() (eventsourcing.domain.model.events.EventWithHash method)
__check_obj__() (eventsourcing.domain.model.entity.DomainEntity.Event method)
(eventsourcing.domain.model.entity.EntityWithHashchain.Event method)
(eventsourcing.domain.model.entity.VersionedEntity.Event method)
__create__() (eventsourcing.domain.model.entity.DomainEntity class method)
(eventsourcing.domain.model.entity.EntityWithHashchain class method)
__discard__() (eventsourcing.domain.model.entity.DomainEntity method)
__enter__() (eventsourcing.application.system.System method)
(eventsourcing.application.system.SystemRunner method)
__eq__() (eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.events.DomainEvent method)
__event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute)
__exit__() (eventsourcing.application.system.System method)
(eventsourcing.application.system.SystemRunner method)
__getattr__() (eventsourcing.application.system.System method)
(eventsourcing.application.system.SystemRunner method)
__getitem__() (eventsourcing.application.notificationlog.AbstractNotificationLog method)
(eventsourcing.application.notificationlog.LocalNotificationLog method)
(eventsourcing.domain.model.array.AbstractArrayRepository method)
(eventsourcing.domain.model.array.AbstractBigArrayRepository method)
(eventsourcing.domain.model.array.BigArray method)
(eventsourcing.interface.notificationlog.RemoteNotificationLog method)
__getnewargs__() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
__hash__() (eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.domain.model.events.EventWithHash method)
__hash_object__() (eventsourcing.domain.model.events.DomainEvent class method)
__init__() (eventsourcing.application.actors.ActorModelRunner method)
(eventsourcing.application.actors.PipelineActor method)
(eventsourcing.application.actors.ProcessMaster method)
(eventsourcing.application.actors.ProcessSlave method)
(eventsourcing.application.actors.SystemActor method)
(eventsourcing.application.django.DjangoApplication method)
(eventsourcing.application.multiprocess.MultiprocessRunner method)
(eventsourcing.application.multiprocess.OperatingSystemProcess method)
(eventsourcing.application.notificationlog.BigArrayNotificationLog method)
(eventsourcing.application.notificationlog.LocalNotificationLog method)
(eventsourcing.application.notificationlog.NotificationLogReader method)
(eventsourcing.application.notificationlog.RecordManagerNotificationLog method)
(eventsourcing.application.notificationlog.Section method)
(eventsourcing.application.pipeline.PipelineExpression method)
(eventsourcing.application.policies.PersistencePolicy method)
(eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.process.WrappedRepository method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication method)
(eventsourcing.application.system.BarrierControlledApplicationThread method)
(eventsourcing.application.system.BarrierControllingClockThread method)
(eventsourcing.application.system.ClockThread method)
(eventsourcing.application.system.MultiThreadedRunner method)
(eventsourcing.application.system.ProcessRunningClockThread method)
(eventsourcing.application.system.PromptOutbox method)
(eventsourcing.application.system.PromptQueuedApplicationThread method)
(eventsourcing.application.system.SingleThreadedRunner method)
(eventsourcing.application.system.SteppingMultiThreadedRunner method)
(eventsourcing.application.system.SteppingRunner method)
(eventsourcing.application.system.SteppingSingleThreadedRunner method)
(eventsourcing.application.system.System method)
(eventsourcing.application.system.SystemRunner method)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot method)
(eventsourcing.domain.model.array.AbstractArrayRepository method)
(eventsourcing.domain.model.array.BigArray method)
(eventsourcing.domain.model.array.ItemAssigned method)
(eventsourcing.domain.model.collection.Collection method)
(eventsourcing.domain.model.command.Command method)
(eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.domain.model.events.EventWithHash method)
(eventsourcing.domain.model.events.EventWithOriginatorID method)
(eventsourcing.domain.model.events.EventWithOriginatorVersion method)
(eventsourcing.domain.model.events.EventWithTimestamp method)
(eventsourcing.domain.model.events.EventWithTimeuuid method)
(eventsourcing.domain.model.snapshot.Snapshot method)
(eventsourcing.domain.model.timebucketedlog.MessageLogged method)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog method)
(eventsourcing.example.application.ApplicationWithEventStores method)
(eventsourcing.example.application.ApplicationWithPersistencePolicies method)
(eventsourcing.example.application.ExampleApplication method)
(eventsourcing.example.domainmodel.Example method)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem method)
(eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.cassandra.datastore.CassandraSettings method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory method)
(eventsourcing.infrastructure.eventstore.EventStore method)
(eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.integersequencegenerators.redisincr.RedisIncr method)
(eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
(eventsourcing.infrastructure.iterators.GetEntityEventsThread method)
(eventsourcing.infrastructure.repositories.array.BigArrayRepository method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
(eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemySettings method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord method)
(eventsourcing.interface.notificationlog.NotificationLogView method)
(eventsourcing.interface.notificationlog.RemoteNotificationLog method)
(eventsourcing.utils.cipher.aes.AESCipher method)
(eventsourcing.utils.transcoding.ObjectJSONDecoder method)
(eventsourcing.utils.transcoding.ObjectJSONEncoder method)
__iter__() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
(eventsourcing.infrastructure.iterators.SequencedItemIterator method)
(eventsourcing.infrastructure.iterators.ThreadedSequencedItemIterator method)
__json_encoder_class__ (eventsourcing.domain.model.events.DomainEvent attribute)
__len__() (eventsourcing.domain.model.array.BigArray method)
__mutate__() (eventsourcing.domain.model.collection.Collection.ItemAdded method)
(eventsourcing.domain.model.collection.Collection.ItemRemoved method)
(eventsourcing.domain.model.entity.DomainEntity.AttributeChanged method)
(eventsourcing.domain.model.entity.DomainEntity.Created method)
(eventsourcing.domain.model.entity.DomainEntity.Discarded method)
(eventsourcing.domain.model.entity.EntityWithHashchain.Created method)
(eventsourcing.domain.model.entity.EntityWithHashchain.Discarded method)
(eventsourcing.domain.model.entity.EntityWithHashchain.Event method)
(eventsourcing.domain.model.entity.TimestampedEntity.Event method)
(eventsourcing.domain.model.entity.VersionedEntity.Event method)
(eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.domain.model.events.EventWithHash method)
__ne__() (eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.events.DomainEvent method)
__new__() (eventsourcing.infrastructure.sequenceditem.SequencedItem static method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent static method)
__next__() (eventsourcing.infrastructure.integersequencegenerators.redisincr.RedisIncr method)
__or__() (eventsourcing.application.pipeline.PipeableMetaclass method)
__publish__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method)
(eventsourcing.domain.model.entity.DomainEntity method)
__publish_to_subscribers__() (eventsourcing.domain.model.entity.DomainEntity method)
__repr__() (eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
__save__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method)
__setattr__() (eventsourcing.domain.model.events.DomainEvent method)
__setitem__() (eventsourcing.domain.model.array.BigArray method)
__trigger_event__() (eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.entity.EntityWithHashchain method)
(eventsourcing.domain.model.entity.VersionedEntity method)
_asdict() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
_inc_page_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
_inc_query_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
_make() (eventsourcing.infrastructure.sequenceditem.SequencedItem class method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent class method)
_prepare_insert() (eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
_replace() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
A
a (eventsourcing.example.domainmodel.Example attribute)
AbstractArrayRepository (class in eventsourcing.domain.model.array)
AbstractBigArrayRepository (class in eventsourcing.domain.model.array)
AbstractDatastore (class in eventsourcing.infrastructure.datastore)
AbstractEventStore (class in eventsourcing.infrastructure.eventstore)
AbstractNotificationLog (class in eventsourcing.application.notificationlog)
AbstractSequencedItemIterator (class in eventsourcing.infrastructure.iterators)
AbstractSequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
AbstractSequencedItemRecordManager (class in eventsourcing.infrastructure.base)
AbstractSnapshop (class in eventsourcing.domain.model.snapshot)
AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
ACIDRecordManager (class in eventsourcing.infrastructure.base)
ActorModelRunner (class in eventsourcing.application.actors)
AESCipher (class in eventsourcing.utils.cipher.aes)
AggregateRoot (class in eventsourcing.domain.model.aggregate)
AggregateRoot.AttributeChanged (class in eventsourcing.domain.model.aggregate)
AggregateRoot.Created (class in eventsourcing.domain.model.aggregate)
AggregateRoot.Discarded (class in eventsourcing.domain.model.aggregate)
AggregateRoot.Event (class in eventsourcing.domain.model.aggregate)
AggregateRootWithHashchainedEvents (class in eventsourcing.domain.model.aggregate)
AggregateRootWithHashchainedEvents.AttributeChanged (class in eventsourcing.domain.model.aggregate)
AggregateRootWithHashchainedEvents.Created (class in eventsourcing.domain.model.aggregate)
AggregateRootWithHashchainedEvents.Discarded (class in eventsourcing.domain.model.aggregate)
AggregateRootWithHashchainedEvents.Event (class in eventsourcing.domain.model.aggregate)
all_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
all_sequence_ids() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
ApplicationWithConcreteInfrastructure (class in eventsourcing.application.simple)
ApplicationWithEventStores (class in eventsourcing.example.application)
ApplicationWithPersistencePolicies (class in eventsourcing.example.application)
ArrayIndexError
ArrayRepository (class in eventsourcing.infrastructure.repositories.array)
assert_event_handlers_empty() (in module eventsourcing.domain.model.events)
attribute() (in module eventsourcing.domain.model.decorators)
AttributeChanged (class in eventsourcing.domain.model.events)
B
b (eventsourcing.example.domainmodel.Example attribute)
BarrierControlledApplicationThread (class in eventsourcing.application.system)
BarrierControllingClockThread (class in eventsourcing.application.system)
BaseAggregateRoot (class in eventsourcing.domain.model.aggregate)
BaseAggregateRoot.AttributeChanged (class in eventsourcing.domain.model.aggregate)
BaseAggregateRoot.Created (class in eventsourcing.domain.model.aggregate)
BaseAggregateRoot.Discarded (class in eventsourcing.domain.model.aggregate)
BaseAggregateRoot.Event (class in eventsourcing.domain.model.aggregate)
BigArray (class in eventsourcing.domain.model.array)
BigArrayNotificationLog (class in eventsourcing.application.notificationlog)
BigArrayRepository (class in eventsourcing.infrastructure.repositories.array)
bind() (eventsourcing.application.system.System method)
C
calc_parent() (eventsourcing.domain.model.array.BigArray method)
CassandraDatastore (class in eventsourcing.infrastructure.cassandra.datastore)
CassandraInfrastructureFactory (class in eventsourcing.infrastructure.cassandra.factory)
CassandraRecordManager (class in eventsourcing.infrastructure.cassandra.manager)
CassandraSettings (class in eventsourcing.infrastructure.cassandra.datastore)
CausalDependencyFailed
clear_event_handlers() (in module eventsourcing.domain.model.events)
ClockThread (class in eventsourcing.application.system)
close() (eventsourcing.application.actors.ActorModelRunner method)
(eventsourcing.application.multiprocess.MultiprocessRunner method)
(eventsourcing.application.system.InProcessRunner method)
(eventsourcing.application.system.MultiThreadedRunner method)
(eventsourcing.application.system.SteppingMultiThreadedRunner method)
(eventsourcing.application.system.SteppingSingleThreadedRunner method)
(eventsourcing.application.system.SystemRunner method)
close_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
close_example_application() (in module eventsourcing.example.application)
Collection (class in eventsourcing.domain.model.collection)
Collection.Created (class in eventsourcing.domain.model.collection)
Collection.Discarded (class in eventsourcing.domain.model.collection)
Collection.Event (class in eventsourcing.domain.model.collection)
Collection.EventWithItem (class in eventsourcing.domain.model.collection)
Collection.ItemAdded (class in eventsourcing.domain.model.collection)
Collection.ItemRemoved (class in eventsourcing.domain.model.collection)
CollectionRepository (class in eventsourcing.infrastructure.repositories.collection_repo)
Command (class in eventsourcing.domain.model.command)
Command.AttributeChanged (class in eventsourcing.domain.model.command)
Command.Created (class in eventsourcing.domain.model.command)
Command.Discarded (class in eventsourcing.domain.model.command)
Command.Done (class in eventsourcing.domain.model.command)
Command.Event (class in eventsourcing.domain.model.command)
CommandProcess (class in eventsourcing.application.command)
ConcurrencyError
ConsistencyError
construct_app() (eventsourcing.application.system.System method)
construct_datastore() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_example_application() (in module eventsourcing.example.application)
construct_infrastructure_factory() (eventsourcing.application.simple.SimpleApplication method)
construct_integer_sequenced_event_store() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
construct_integer_sequenced_record_manager() (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory method)
(eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_item_args() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
construct_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_sequenced_item_mapper() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
construct_snapshot_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
construct_timestamp_sequenced_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
create_new_example() (eventsourcing.example.application.ExampleApplication method)
(in module eventsourcing.example.domainmodel)
Created (class in eventsourcing.domain.model.events)
D
DataIntegrityError
DatasourceSettingsError
DatastoreConnectionError
DatastoreError
DatastoreSettings (class in eventsourcing.infrastructure.datastore)
DatastoreTableError
datetime_from_timestamp() (in module eventsourcing.utils.times)
decimaltimestamp() (in module eventsourcing.utils.times)
decimaltimestamp_from_uuid() (in module eventsourcing.utils.times)
decode_bytes() (in module eventsourcing.utils.random)
decrypt() (eventsourcing.utils.cipher.aes.AESCipher method)
default() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
delete_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
Discarded (class in eventsourcing.domain.model.events)
DjangoApplication (class in eventsourcing.application.django)
DjangoInfrastructureFactory (class in eventsourcing.infrastructure.django.factory)
DjangoRecordManager (class in eventsourcing.infrastructure.django.manager)
DomainEntity (class in eventsourcing.domain.model.entity)
DomainEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
DomainEntity.Created (class in eventsourcing.domain.model.entity)
DomainEntity.Discarded (class in eventsourcing.domain.model.entity)
DomainEntity.Event (class in eventsourcing.domain.model.entity)
DomainEvent (class in eventsourcing.domain.model.events)
drop_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
E
encode_bytes() (in module eventsourcing.utils.random)
encode_random_bytes() (in module eventsourcing.utils.random)
encrypt() (eventsourcing.utils.cipher.aes.AESCipher method)
entity_from_snapshot() (in module eventsourcing.infrastructure.snapshotting)
EntityIsDiscarded
EntitySnapshotRecord (class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.sqlalchemy.records)
EntitySnapshotRecord.DoesNotExist
EntitySnapshotRecord.MultipleObjectsReturned
EntityVersionNotFound
EntityWithHashchain (class in eventsourcing.domain.model.entity)
EntityWithHashchain.AttributeChanged (class in eventsourcing.domain.model.entity)
EntityWithHashchain.Created (class in eventsourcing.domain.model.entity)
EntityWithHashchain.Discarded (class in eventsourcing.domain.model.entity)
EntityWithHashchain.Event (class in eventsourcing.domain.model.entity)
event_from_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
event_store_class (eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.infrastructure.factory.InfrastructureFactory attribute)
EventHandlersNotEmptyError
EventHashError
EventRecordNotFound
EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
eventsourcing.application.actors (module)
eventsourcing.application.command (module)
eventsourcing.application.django (module)
eventsourcing.application.multiprocess (module)
eventsourcing.application.notificationlog (module)
eventsourcing.application.pipeline (module)
eventsourcing.application.policies (module)
eventsourcing.application.popo (module)
eventsourcing.application.process (module)
eventsourcing.application.simple (module)
eventsourcing.application.snapshotting (module)
eventsourcing.application.sqlalchemy (module)
eventsourcing.application.system (module)
eventsourcing.domain.model.aggregate (module)
,
[1]
eventsourcing.domain.model.array (module)
,
[1]
eventsourcing.domain.model.collection (module)
,
[1]
eventsourcing.domain.model.command (module)
,
[1]
eventsourcing.domain.model.decorator (module)
eventsourcing.domain.model.decorators (module)
eventsourcing.domain.model.entity (module)
,
[1]
eventsourcing.domain.model.events (module)
,
[1]
eventsourcing.domain.model.snapshot (module)
,
[1]
eventsourcing.domain.model.timebucketedlog (module)
,
[1]
eventsourcing.example.application (module)
eventsourcing.example.domainmodel (module)
eventsourcing.example.infrastructure (module)
eventsourcing.example.interface.flaskapp (module)
eventsourcing.exceptions (module)
eventsourcing.infrastructure.base (module)
,
[1]
eventsourcing.infrastructure.cassandra (module)
eventsourcing.infrastructure.cassandra.datastore (module)
eventsourcing.infrastructure.cassandra.factory (module)
eventsourcing.infrastructure.cassandra.manager (module)
eventsourcing.infrastructure.cassandra.records (module)
eventsourcing.infrastructure.datastore (module)
,
[1]
eventsourcing.infrastructure.django (module)
eventsourcing.infrastructure.django.factory (module)
eventsourcing.infrastructure.django.manager (module)
eventsourcing.infrastructure.django.models (module)
eventsourcing.infrastructure.django.utils (module)
eventsourcing.infrastructure.eventplayer (module)
,
[1]
eventsourcing.infrastructure.eventsourcedrepository (module)
,
[1]
eventsourcing.infrastructure.eventstore (module)
,
[1]
eventsourcing.infrastructure.factory (module)
,
[1]
eventsourcing.infrastructure.integersequencegenerators (module)
eventsourcing.infrastructure.integersequencegenerators.base (module)
eventsourcing.infrastructure.integersequencegenerators.redisincr (module)
eventsourcing.infrastructure.iterators (module)
,
[1]
eventsourcing.infrastructure.repositories (module)
eventsourcing.infrastructure.repositories.array (module)
eventsourcing.infrastructure.repositories.collection_repo (module)
eventsourcing.infrastructure.repositories.timebucketedlog_repo (module)
eventsourcing.infrastructure.sequenceditem (module)
,
[1]
eventsourcing.infrastructure.sequenceditemmapper (module)
,
[1]
eventsourcing.infrastructure.snapshotting (module)
,
[1]
eventsourcing.infrastructure.sqlalchemy (module)
eventsourcing.infrastructure.sqlalchemy.datastore (module)
eventsourcing.infrastructure.sqlalchemy.factory (module)
eventsourcing.infrastructure.sqlalchemy.manager (module)
eventsourcing.infrastructure.sqlalchemy.records (module)
eventsourcing.infrastructure.timebucketedlog_reader (module)
,
[1]
eventsourcing.interface.notificationlog (module)
eventsourcing.utils.cipher (module)
eventsourcing.utils.cipher.aes (module)
eventsourcing.utils.random (module)
,
[1]
eventsourcing.utils.times (module)
,
[1]
eventsourcing.utils.topic (module)
,
[1]
eventsourcing.utils.transcoding (module)
,
[1]
EventSourcingError
EventStore (class in eventsourcing.infrastructure.eventstore)
EventWithHash (class in eventsourcing.domain.model.events)
EventWithOriginatorID (class in eventsourcing.domain.model.events)
EventWithOriginatorVersion (class in eventsourcing.domain.model.events)
EventWithTimestamp (class in eventsourcing.domain.model.events)
EventWithTimeuuid (class in eventsourcing.domain.model.events)
Example (class in eventsourcing.example.domainmodel)
Example.AttributeChanged (class in eventsourcing.example.domainmodel)
Example.Created (class in eventsourcing.example.domainmodel)
Example.Discarded (class in eventsourcing.example.domainmodel)
Example.Event (class in eventsourcing.example.domainmodel)
Example.Heartbeat (class in eventsourcing.example.domainmodel)
ExampleApplication (class in eventsourcing.example.application)
ExampleRepository (class in eventsourcing.example.infrastructure)
F
foo (eventsourcing.example.domainmodel.Example attribute)
from_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
G
get_domain_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_example_application() (in module eventsourcing.example.application)
get_item() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
get_items() (eventsourcing.application.notificationlog.BigArrayNotificationLog method)
(eventsourcing.application.notificationlog.LocalNotificationLog method)
(eventsourcing.application.notificationlog.RecordManagerNotificationLog method)
(eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
get_last_array() (eventsourcing.domain.model.array.BigArray method)
get_max_record_id() (eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_max_tracking_record_id() (eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_most_recent_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_next_position() (eventsourcing.application.notificationlog.BigArrayNotificationLog method)
(eventsourcing.application.notificationlog.LocalNotificationLog method)
(eventsourcing.application.notificationlog.RecordManagerNotificationLog method)
get_notifications() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_pipeline_and_notification_id() (eventsourcing.infrastructure.base.ACIDRecordManager method)
get_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_record_table_name() (eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_records() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_snapshot() (eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method)
(eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method)
get_timebucketedlog_reader() (in module eventsourcing.infrastructure.timebucketedlog_reader)
get_topic() (in module eventsourcing.utils.topic)
GetEntityEventsThread (class in eventsourcing.infrastructure.iterators)
H
handle_prompt() (eventsourcing.application.system.InProcessRunner method)
(eventsourcing.application.system.MultiThreadedRunner method)
(eventsourcing.application.system.SingleThreadedRunner method)
(eventsourcing.application.system.SteppingMultiThreadedRunner method)
(eventsourcing.application.system.SteppingSingleThreadedRunner method)
has_tracking_record() (eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
HeadHashError
I
id (eventsourcing.domain.model.entity.DomainEntity attribute)
infrastructure_factory_class (eventsourcing.application.django.DjangoApplication attribute)
(eventsourcing.application.popo.PopoApplication attribute)
(eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute)
InfrastructureFactory (class in eventsourcing.infrastructure.factory)
init_example_application() (in module eventsourcing.example.application)
initial_section_id (eventsourcing.application.notificationlog.NotificationLogReader attribute)
InProcessRunner (class in eventsourcing.application.system)
insert_select_max (eventsourcing.infrastructure.base.SQLRecordManager attribute)
insert_tracking_record (eventsourcing.infrastructure.base.SQLRecordManager attribute)
insert_values (eventsourcing.infrastructure.base.SQLRecordManager attribute)
integer_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
IntegerSequencedItem (class in eventsourcing.example.interface.flaskapp)
IntegerSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
IntegerSequencedRecord (class in eventsourcing.infrastructure.cassandra.records)
(class in eventsourcing.infrastructure.django.models)
(in module eventsourcing.infrastructure.sqlalchemy.records)
IntegerSequencedRecord.DoesNotExist
,
[1]
IntegerSequencedRecord.MultipleObjectsReturned
,
[1]
IntegerSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
is_prompt() (eventsourcing.application.system.System method)
item_from_event() (eventsourcing.infrastructure.eventstore.EventStore method)
(eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
ItemAssigned (class in eventsourcing.domain.model.array)
iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute)
iterencode() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
L
list_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
LocalNotificationLog (class in eventsourcing.application.notificationlog)
Logged (class in eventsourcing.domain.model.events)
M
MessageLogged (class in eventsourcing.domain.model.timebucketedlog)
MismatchedOriginatorError
MultiprocessRunner (class in eventsourcing.application.multiprocess)
MultiThreadedRunner (class in eventsourcing.application.system)
mutate() (eventsourcing.domain.model.command.Command.Done method)
(eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.example.domainmodel.Example.Heartbeat method)
mutator() (in module eventsourcing.domain.model.decorators)
MutatorRequiresTypeNotInstance
N
notification_log_reader_class (eventsourcing.application.process.ProcessApplication attribute)
NotificationLogReader (class in eventsourcing.application.notificationlog)
NotificationLogView (class in eventsourcing.interface.notificationlog)
NotificationTrackingRecord (class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.sqlalchemy.records)
NotificationTrackingRecord.DoesNotExist
NotificationTrackingRecord.MultipleObjectsReturned
O
ObjectJSONDecoder (class in eventsourcing.utils.transcoding)
ObjectJSONEncoder (class in eventsourcing.utils.transcoding)
OperatingSystemProcess (class in eventsourcing.application.multiprocess)
OperationalError
originator_id (eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
originator_topic (eventsourcing.domain.model.entity.DomainEntity.Created attribute)
originator_version (eventsourcing.domain.model.events.EventWithOriginatorVersion attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
OriginatorIDError
OriginatorVersionError
P
persist_event_type (eventsourcing.application.command.CommandProcess attribute)
PersistencePolicy (class in eventsourcing.application.policies)
Pipeable (class in eventsourcing.application.pipeline)
PipeableMetaclass (class in eventsourcing.application.pipeline)
PipelineActor (class in eventsourcing.application.actors)
PipelineExpression (class in eventsourcing.application.pipeline)
policy() (eventsourcing.application.process.ProcessApplication static method)
PopoApplication (class in eventsourcing.application.popo)
position (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
present_section() (eventsourcing.interface.notificationlog.NotificationLogView method)
ProcessApplication (class in eventsourcing.application.process)
ProcessApplicationWithSnapshotting (class in eventsourcing.application.process)
ProcessMaster (class in eventsourcing.application.actors)
ProcessRunningClockThread (class in eventsourcing.application.system)
ProcessSlave (class in eventsourcing.application.actors)
ProgrammingError
PromptFailed
PromptOutbox (class in eventsourcing.application.system)
PromptQueuedApplicationThread (class in eventsourcing.application.system)
publish() (in module eventsourcing.domain.model.events)
publish_prompt() (eventsourcing.application.process.ProcessApplication method)
put() (eventsourcing.application.system.PromptOutbox method)
R
random_bytes() (in module eventsourcing.utils.random)
receiveMessage() (eventsourcing.application.actors.PipelineActor method)
(eventsourcing.application.actors.ProcessMaster method)
(eventsourcing.application.actors.ProcessSlave method)
(eventsourcing.application.actors.SystemActor method)
record_manager_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
record_sequenced_item() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
record_sequenced_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
RecordConflictError
RecordManagerNotificationLog (class in eventsourcing.application.notificationlog)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
RemoteNotificationLog (class in eventsourcing.interface.notificationlog)
RepositoryKeyError
reset_connection_after_forking() (eventsourcing.application.django.DjangoApplication class method)
resolve_attr() (in module eventsourcing.utils.topic)
resolve_topic() (in module eventsourcing.utils.topic)
retry() (in module eventsourcing.domain.model.decorators)
run() (eventsourcing.application.multiprocess.OperatingSystemProcess method)
(eventsourcing.application.system.BarrierControlledApplicationThread method)
(eventsourcing.application.system.BarrierControllingClockThread method)
(eventsourcing.application.system.ProcessRunningClockThread method)
(eventsourcing.application.system.PromptQueuedApplicationThread method)
(eventsourcing.infrastructure.iterators.GetEntityEventsThread method)
run_followers() (eventsourcing.application.system.SingleThreadedRunner method)
S
save_orm_obj() (eventsourcing.application.process.WrappedRepository method)
Section (class in eventsourcing.application.notificationlog)
seek() (eventsourcing.application.notificationlog.NotificationLogReader method)
sequence_id (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
sequenced_item_class (eventsourcing.infrastructure.factory.InfrastructureFactory attribute)
sequenced_item_mapper_class (eventsourcing.application.popo.PopoApplication attribute)
(eventsourcing.infrastructure.factory.InfrastructureFactory attribute)
SequencedItem (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemIterator (class in eventsourcing.infrastructure.iterators)
SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
setup_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
setup_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
SimpleApplication (class in eventsourcing.application.simple)
SingleThreadedRunner (class in eventsourcing.application.system)
Snapshot (class in eventsourcing.domain.model.snapshot)
snapshot_record_class (eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute)
(eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
SnapshotRecord (class in eventsourcing.infrastructure.cassandra.records)
(class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.sqlalchemy.records)
SnapshotRecord.DoesNotExist
,
[1]
SnapshotRecord.MultipleObjectsReturned
,
[1]
SnapshottingApplication (class in eventsourcing.application.snapshotting)
SQLAlchemyApplication (class in eventsourcing.application.sqlalchemy)
SQLAlchemyDatastore (class in eventsourcing.infrastructure.sqlalchemy.datastore)
SQLAlchemyInfrastructureFactory (class in eventsourcing.infrastructure.sqlalchemy.factory)
SQLAlchemyRecordManager (class in eventsourcing.infrastructure.sqlalchemy.manager)
SQLAlchemySettings (class in eventsourcing.infrastructure.sqlalchemy.datastore)
SQLRecordManager (class in eventsourcing.infrastructure.base)
start() (eventsourcing.application.actors.ActorModelRunner method)
(eventsourcing.application.multiprocess.MultiprocessRunner method)
(eventsourcing.application.system.InProcessRunner method)
(eventsourcing.application.system.MultiThreadedRunner method)
(eventsourcing.application.system.SteppingMultiThreadedRunner method)
(eventsourcing.application.system.SteppingSingleThreadedRunner method)
(eventsourcing.application.system.SystemRunner method)
state (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
SteppingMultiThreadedRunner (class in eventsourcing.application.system)
SteppingRunner (class in eventsourcing.application.system)
SteppingSingleThreadedRunner (class in eventsourcing.application.system)
store() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
stored_event_record_class (eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute)
StoredEvent (class in eventsourcing.infrastructure.sequenceditem)
StoredEventRecord (class in eventsourcing.infrastructure.cassandra.records)
(class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.sqlalchemy.records)
StoredEventRecord.DoesNotExist
,
[1]
StoredEventRecord.MultipleObjectsReturned
,
[1]
subrepo (eventsourcing.domain.model.array.AbstractBigArrayRepository attribute)
(eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute)
subrepo_class (eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute)
subscribe() (in module eventsourcing.domain.model.events)
subscribe_to() (in module eventsourcing.domain.model.decorators)
System (class in eventsourcing.application.system)
SystemActor (class in eventsourcing.application.actors)
SystemRunner (class in eventsourcing.application.system)
T
take_snapshot() (eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method)
(eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method)
ThreadedSequencedItemIterator (class in eventsourcing.infrastructure.iterators)
Timebucketedlog (class in eventsourcing.domain.model.timebucketedlog)
Timebucketedlog.BucketSizeChanged (class in eventsourcing.domain.model.timebucketedlog)
Timebucketedlog.Event (class in eventsourcing.domain.model.timebucketedlog)
Timebucketedlog.Started (class in eventsourcing.domain.model.timebucketedlog)
TimebucketedlogRepo (class in eventsourcing.infrastructure.repositories.timebucketedlog_repo)
TimeSequenceError
timestamp (eventsourcing.domain.model.events.EventWithTimestamp attribute)
timestamp_long_from_uuid() (in module eventsourcing.utils.times)
timestamp_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
TimestampedEntity (class in eventsourcing.domain.model.entity)
TimestampedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
TimestampedEntity.Created (class in eventsourcing.domain.model.entity)
TimestampedEntity.Discarded (class in eventsourcing.domain.model.entity)
TimestampedEntity.Event (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Created (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Discarded (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Event (class in eventsourcing.domain.model.entity)
TimestampSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
TimestampSequencedRecord (class in eventsourcing.infrastructure.cassandra.records)
(class in eventsourcing.infrastructure.django.models)
(in module eventsourcing.infrastructure.sqlalchemy.records)
TimestampSequencedRecord.DoesNotExist
,
[1]
TimestampSequencedRecord.MultipleObjectsReturned
,
[1]
TimestampSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
TimeuuidedEntity (class in eventsourcing.domain.model.entity)
TimeuuidedVersionedEntity (class in eventsourcing.domain.model.entity)
TimeuuidSequencedRecord (class in eventsourcing.infrastructure.cassandra.records)
TimeuuidSequencedRecord.DoesNotExist
TimeuuidSequencedRecord.MultipleObjectsReturned
to_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
topic (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
TopicResolutionError
tracking_record_class (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
TrackingRecordNotFound
truncate_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
U
unsubscribe() (in module eventsourcing.domain.model.events)
V
VersionedEntity (class in eventsourcing.domain.model.entity)
VersionedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
VersionedEntity.Created (class in eventsourcing.domain.model.entity)
VersionedEntity.Discarded (class in eventsourcing.domain.model.entity)
VersionedEntity.Event (class in eventsourcing.domain.model.entity)
W
WrappedRepository (class in eventsourcing.application.process)
write_records() (eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
Read the Docs
v: v7.2.0
Versions
latest
stable
v7.2.0
v7.1.6
v7.1.5
v7.1.4
v7.1.3
v7.1.2
v7.1.1
v7.1.0
v7.0.0
v6.3.0
v6.2.0
v6.1.0
v6.0.0
v5.1.1
v5.1.0
v5.0.0
v4.0.0
v3.1.0
v3.0.0
Downloads
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.