eventsourcing
v8.0.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
|
J
|
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)
__contains__() (eventsourcing.infrastructure.base.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository 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.system.definition.AbstractSystemRunner method)
(eventsourcing.system.definition.System method)
__eq__() (eventsourcing.application.process.PromptToPull method)
(eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.events.DomainEvent method)
__event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute)
__exit__() (eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.definition.System 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.infrastructure.base.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository 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.django.DjangoApplication 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.policies.SnapshottingPolicy method)
(eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.process.ProcessEvent method)
(eventsourcing.application.process.PromptToPull method)
(eventsourcing.application.process.WrappedRepository method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication 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.AbstractEventStore method)
(eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.BaseRecordManager 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.eventplayer.EventPlayer method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
(eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.integersequencegenerators.base.SimpleIntegerSequenceGenerator 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.AbstractSequencedItemMapper 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.system.actors.ActorModelRunner method)
(eventsourcing.system.actors.PipelineActor method)
(eventsourcing.system.actors.ProcessMaster method)
(eventsourcing.system.actors.ProcessSlave method)
(eventsourcing.system.actors.SystemActor method)
(eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.definition.System method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.multiprocess.OperatingSystemProcess method)
(eventsourcing.system.runner.BarrierControlledApplicationThread method)
(eventsourcing.system.runner.BarrierControllingClockThread method)
(eventsourcing.system.runner.ClockThread method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.ProcessRunningClockThread method)
(eventsourcing.system.runner.PromptOutbox method)
(eventsourcing.system.runner.PromptQueuedApplicationThread method)
(eventsourcing.system.runner.SingleThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.SteppingRunner method)
(eventsourcing.system.runner.SteppingSingleThreadedRunner method)
(eventsourcing.utils.cipher.aes.AESCipher method)
(eventsourcing.utils.transcoding.ObjectJSONDecoder method)
__iter__() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
(eventsourcing.infrastructure.iterators.SequencedItemIterator method)
(eventsourcing.infrastructure.iterators.ThreadedSequencedItemIterator method)
__len__() (eventsourcing.domain.model.array.BigArray method)
__mutate__() (eventsourcing.domain.model.entity.DomainEntity 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.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.base.AbstractIntegerSequenceGenerator method)
(eventsourcing.infrastructure.integersequencegenerators.base.SimpleIntegerSequenceGenerator method)
(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.application.process.PromptToPull method)
(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.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)
AbstractCollectionRepository (class in eventsourcing.domain.model.collection)
AbstractDatastore (class in eventsourcing.infrastructure.datastore)
AbstractEntityRepository (class in eventsourcing.infrastructure.base)
AbstractEventPlayer (class in eventsourcing.infrastructure.base)
AbstractEventStore (class in eventsourcing.infrastructure.base)
AbstractExampleRepository (class in eventsourcing.example.domainmodel)
AbstractIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base)
AbstractNotificationLog (class in eventsourcing.application.notificationlog)
AbstractRecordManager (class in eventsourcing.infrastructure.base)
AbstractSequencedItemIterator (class in eventsourcing.infrastructure.iterators)
AbstractSequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
AbstractSnapshop (class in eventsourcing.infrastructure.base)
AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
AbstractSystemRunner (class in eventsourcing.system.definition)
ACIDRecordManager (class in eventsourcing.infrastructure.base)
ActorModelRunner (class in eventsourcing.system.actors)
ActualOccasion (class in eventsourcing.whitehead)
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_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
all_sequence_ids() (eventsourcing.infrastructure.base.AbstractRecordManager 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)
AttributeChangedEvent (class in eventsourcing.domain.model.events)
B
b (eventsourcing.example.domainmodel.Example attribute)
BarrierControlledApplicationThread (class in eventsourcing.system.runner)
BarrierControllingClockThread (class in eventsourcing.system.runner)
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)
BaseRecordManager (class in eventsourcing.infrastructure.base)
BigArray (class in eventsourcing.domain.model.array)
BigArrayNotificationLog (class in eventsourcing.application.notificationlog)
BigArrayRepository (class in eventsourcing.infrastructure.repositories.array)
bind() (eventsourcing.system.definition.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.system.runner)
close() (eventsourcing.system.actors.ActorModelRunner method)
(eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.runner.InProcessRunner method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.SteppingSingleThreadedRunner 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.system.definition.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)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication 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)
CreatedEvent (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)
decoderpolicy() (in module eventsourcing.utils.transcoding)
decrypt() (eventsourcing.utils.cipher.aes.AESCipher method)
default() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
delete_orm_obj() (eventsourcing.application.process.WrappedRepository method)
delete_record() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
DiscardedEvent (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_table() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
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)
encoded_random_bytes() (in module eventsourcing.utils.random)
encoderpolicy() (in module eventsourcing.utils.transcoding)
EncoderTypeError
encrypt() (eventsourcing.utils.cipher.aes.AESCipher method)
EnduringObject (class in eventsourcing.whitehead)
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 (class in eventsourcing.whitehead)
event_from_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
event_from_topic_and_state() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
event_store (eventsourcing.infrastructure.base.AbstractEventPlayer attribute)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository attribute)
event_store_class (eventsourcing.application.simple.SimpleApplication attribute)
EventHandlersNotEmptyError
EventHashError
EventPlayer (class in eventsourcing.infrastructure.eventplayer)
EventRecordNotFound
EventSourcedRepository (class in eventsourcing.infrastructure.eventsourcedrepository)
EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
eventsourcing.application.command (module)
eventsourcing.application.django (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.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]
,
[2]
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.system.actors (module)
eventsourcing.system.definition (module)
eventsourcing.system.multiprocess (module)
eventsourcing.system.runner (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]
eventsourcing.whitehead (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.BaseRecordManager method)
G
get_and_project_events() (eventsourcing.infrastructure.base.AbstractEventPlayer method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
get_domain_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
get_entity() (eventsourcing.infrastructure.base.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
get_event() (eventsourcing.infrastructure.base.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_example_application() (in module eventsourcing.example.application)
get_item() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.BaseRecordManager method)
get_items() (eventsourcing.application.notificationlog.BigArrayNotificationLog method)
(eventsourcing.application.notificationlog.LocalNotificationLog method)
(eventsourcing.application.notificationlog.RecordManagerNotificationLog method)
(eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.BaseRecordManager method)
get_last_array() (eventsourcing.domain.model.array.BigArray method)
get_max_notification_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.base.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.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository method)
get_pipeline_and_notification_id() (eventsourcing.infrastructure.base.ACIDRecordManager method)
get_record() (eventsourcing.infrastructure.base.AbstractRecordManager 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.AbstractRecordManager 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_topic() (in module eventsourcing.utils.topic)
GetEntityEventsThread (class in eventsourcing.infrastructure.iterators)
H
handle_prompts() (eventsourcing.system.runner.InProcessRunner method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.SingleThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.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.system.runner)
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)
item_from_event() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
ItemAssigned (class in eventsourcing.domain.model.array)
items_from_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
iter_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute)
iterencode() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
J
json_dumps() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
json_loads() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
L
list_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
list_items() (eventsourcing.infrastructure.base.BaseRecordManager method)
LocalNotificationLog (class in eventsourcing.application.notificationlog)
LoggedEvent (class in eventsourcing.domain.model.events)
M
make_placeholder() (eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
MessageLogged (class in eventsourcing.domain.model.timebucketedlog)
MetaDomainEntity (class in eventsourcing.domain.model.entity)
MismatchedOriginatorError
MultiprocessRunner (class in eventsourcing.system.multiprocess)
MultiThreadedRunner (class in eventsourcing.system.runner)
mutate() (eventsourcing.domain.model.collection.Collection.ItemAdded method)
(eventsourcing.domain.model.collection.Collection.ItemRemoved method)
(eventsourcing.domain.model.command.Command.Done method)
(eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.example.domainmodel.Example.Heartbeat method)
(eventsourcing.infrastructure.eventplayer.EventPlayer static 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.system.multiprocess)
OperationalError
originator_id (eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.infrastructure.base.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.infrastructure.base.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.system.actors)
PipelineExpression (class in eventsourcing.application.pipeline)
policy() (eventsourcing.application.process.ProcessApplication method)
PopoApplication (class in eventsourcing.application.popo)
position (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
present_resource() (eventsourcing.interface.notificationlog.NotificationLogView method)
ProcessApplication (class in eventsourcing.application.process)
ProcessApplicationWithSnapshotting (class in eventsourcing.application.process)
ProcessEvent (class in eventsourcing.application.process)
ProcessMaster (class in eventsourcing.system.actors)
ProcessRunningClockThread (class in eventsourcing.system.runner)
ProcessSlave (class in eventsourcing.system.actors)
ProgrammingError
project_events() (eventsourcing.infrastructure.eventplayer.EventPlayer method)
Prompt (class in eventsourcing.application.process)
PromptFailed
PromptOutbox (class in eventsourcing.system.runner)
PromptQueuedApplicationThread (class in eventsourcing.system.runner)
PromptToPull (class in eventsourcing.application.process)
PromptToQuit (class in eventsourcing.application.process)
publish() (in module eventsourcing.domain.model.events)
publish_prompt() (eventsourcing.application.process.ProcessApplication method)
put() (eventsourcing.system.runner.PromptOutbox method)
R
random_bytes() (in module eventsourcing.utils.random)
read_items() (eventsourcing.application.notificationlog.NotificationLogReader method)
read_list() (eventsourcing.application.notificationlog.NotificationLogReader method)
receiveMessage() (eventsourcing.system.actors.PipelineActor method)
(eventsourcing.system.actors.ProcessMaster method)
(eventsourcing.system.actors.ProcessSlave method)
(eventsourcing.system.actors.SystemActor method)
record_class (eventsourcing.infrastructure.base.AbstractRecordManager attribute)
(eventsourcing.infrastructure.base.BaseRecordManager attribute)
record_item() (eventsourcing.infrastructure.base.AbstractRecordManager method)
record_items() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.SQLRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
record_manager_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
RecordConflictError
RecordManagerNotificationLog (class in eventsourcing.application.notificationlog)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
RemoteNotificationLog (class in eventsourcing.interface.notificationlog)
repository_class (eventsourcing.application.simple.SimpleApplication attribute)
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.infrastructure.iterators.GetEntityEventsThread method)
(eventsourcing.system.multiprocess.OperatingSystemProcess method)
(eventsourcing.system.runner.BarrierControlledApplicationThread method)
(eventsourcing.system.runner.BarrierControllingClockThread method)
(eventsourcing.system.runner.ProcessRunningClockThread method)
(eventsourcing.system.runner.PromptQueuedApplicationThread method)
run_followers() (eventsourcing.system.runner.SingleThreadedRunner method)
S
save_orm_obj() (eventsourcing.application.process.WrappedRepository method)
Section (class in eventsourcing.application.notificationlog)
section_size (eventsourcing.application.notificationlog.AbstractNotificationLog attribute)
(eventsourcing.application.notificationlog.LocalNotificationLog attribute)
(eventsourcing.interface.notificationlog.RemoteNotificationLog attribute)
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_table() (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)
SimpleIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base)
SingleThreadedRunner (class in eventsourcing.system.runner)
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)
SnapshottingPolicy (class in eventsourcing.application.policies)
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.system.actors.ActorModelRunner method)
(eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.runner.InProcessRunner method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.SteppingSingleThreadedRunner method)
state (eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.infrastructure.base.AbstractSnapshop attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
SteppingMultiThreadedRunner (class in eventsourcing.system.runner)
SteppingRunner (class in eventsourcing.system.runner)
SteppingSingleThreadedRunner (class in eventsourcing.system.runner)
store_events() (eventsourcing.infrastructure.base.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]
subclassevents() (in module eventsourcing.domain.model.decorators)
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.system.definition)
SystemActor (class in eventsourcing.system.actors)
T
take_snapshot() (eventsourcing.infrastructure.base.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
(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)
TimebucketedlogRepository (class in eventsourcing.domain.model.timebucketedlog)
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.BaseRecordManager method)
topic (eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.infrastructure.base.AbstractSnapshop 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: v8.0.0
Versions
latest
stable
v8.0.0
v7.2.4
v7.2.3
v7.2.2
v7.2.1
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
.