eventsourcing
v8.3.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
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__assert_not_discarded__() (eventsourcing.domain.model.entity.DomainEntity method)
__call__() (eventsourcing.system.grpc.runner.MethodWrapper 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.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.application.simple.SimpleApplication method)
(eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.definition.System method)
__eq__() (eventsourcing.application.simple.PromptToPull method)
(eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.events.DomainEvent method)
__event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute)
__exit__() (eventsourcing.application.simple.SimpleApplication method)
(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.eventsourcedrepository.EventSourcedRepository method)
(eventsourcing.interface.notificationlog.RemoteNotificationLog method)
(eventsourcing.system.grpc.processor.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_v1__() (eventsourcing.domain.model.events.DomainEvent class method)
__hash_object_v2__() (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.WrappedRepository method)
(eventsourcing.application.simple.ProcessEvent method)
(eventsourcing.application.simple.PromptToPull 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.domain.model.versioning.Upcastable 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.AbstractEventStore method)
(eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.BaseRecordManager method)
(eventsourcing.infrastructure.base.RecordManagerWithTracking 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.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.popo.manager.PopoRecordManager method)
(eventsourcing.infrastructure.popo.records.IntegerSequencedRecord 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.definition.AbstractSystemRunner method)
(eventsourcing.system.definition.System method)
(eventsourcing.system.grpc.processor.NotificationLogView method)
(eventsourcing.system.grpc.processor.ProcessorServer method)
(eventsourcing.system.grpc.processor.PullNotifications method)
(eventsourcing.system.grpc.processor.RemoteNotificationLog method)
(eventsourcing.system.grpc.processor.StartClient method)
(eventsourcing.system.grpc.runner.ClientWrapper method)
(eventsourcing.system.grpc.runner.GrpcRunner method)
(eventsourcing.system.grpc.runner.MethodWrapper method)
(eventsourcing.system.grpc.runner.ProcessorListener method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.multiprocess.OperatingSystemProcess method)
(eventsourcing.system.ray.RayRunner 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.system.thespian.PipelineActor method)
(eventsourcing.system.thespian.ProcessMaster method)
(eventsourcing.system.thespian.ProcessSlave method)
(eventsourcing.system.thespian.SystemActor method)
(eventsourcing.system.thespian.ThespianRunner 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)
__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.AbstractSnapshot method)
(eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.domain.model.events.EventWithHash method)
(eventsourcing.domain.model.snapshot.Snapshot 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.simple.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)
__upcast__() (eventsourcing.domain.model.versioning.Upcastable class method)
__upcast_state__() (eventsourcing.domain.model.versioning.Upcastable class 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)
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)
AbstractSnapshot (class in eventsourcing.domain.model.events)
AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
AbstractSystemRunner (class in eventsourcing.system.definition)
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.popo.manager.PopoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
applicationpolicy() (in module eventsourcing.application.decorators)
applicationpolicy2() (in module eventsourcing.application.decorators)
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)
call_policy() (eventsourcing.application.process.ProcessApplication method)
CallApplicationMethod() (eventsourcing.system.grpc.processor.ProcessorServer method)
can_drop_tables (eventsourcing.infrastructure.datastore.AbstractDatastore attribute)
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
change_pipeline() (eventsourcing.application.simple.SimpleApplication method)
check_causal_dependencies() (eventsourcing.application.process.ProcessApplication method)
clear_event_handlers() (in module eventsourcing.domain.model.events)
ClientWrapper (class in eventsourcing.system.grpc.runner)
ClockThread (class in eventsourcing.system.runner)
close() (eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(eventsourcing.system.definition.AbstractSystemRunner method)
(eventsourcing.system.grpc.runner.GrpcRunner method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.ray.RayRunner method)
(eventsourcing.system.runner.InProcessRunner method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.SteppingSingleThreadedRunner method)
(eventsourcing.system.thespian.ThespianRunner 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)
collect_pending_events() (eventsourcing.application.process.ProcessApplication method)
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.application.simple.SimpleApplication method)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication method)
(eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_event_records() (eventsourcing.application.simple.SimpleApplication method)
construct_event_store() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
construct_example_application() (in module eventsourcing.example.application)
construct_infrastructure() (eventsourcing.application.django.DjangoApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication method)
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_notification_log() (eventsourcing.application.simple.SimpleApplication method)
construct_persistence_policy() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
construct_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_repository() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication 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_address() (eventsourcing.system.grpc.runner.GrpcRunner 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)
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.popo.manager.PopoRecordManager 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.application.process.ProcessApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(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() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
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)
EntityIsDiscarded
EntitySnapshotRecord (class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.sqlalchemy.records)
EntitySnapshotRecord.DoesNotExist
EntitySnapshotRecord.MultipleObjectsReturned
EntityVersionNotFound
EntityWithECC (class in eventsourcing.domain.model.entity)
EntityWithECC.AttributeChanged (class in eventsourcing.domain.model.entity)
EntityWithECC.Created (class in eventsourcing.domain.model.entity)
EntityWithECC.Discarded (class in eventsourcing.domain.model.entity)
EntityWithECC.Event (class in eventsourcing.domain.model.entity)
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_notification() (eventsourcing.application.process.ProcessApplication method)
(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.eventsourcedrepository.EventSourcedRepository attribute)
event_store_class (eventsourcing.application.simple.SimpleApplication attribute)
EventHandlersNotEmptyError
EventHashError
EventRecordNotFound
EventSourcedRepository (class in eventsourcing.infrastructure.eventsourcedrepository)
EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
eventsourcing.application.command (module)
eventsourcing.application.decorators (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.domain.model.versioning (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.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.popo (module)
eventsourcing.infrastructure.popo.factory (module)
eventsourcing.infrastructure.popo.manager (module)
eventsourcing.infrastructure.popo.mapper (module)
eventsourcing.infrastructure.popo.records (module)
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.definition (module)
eventsourcing.system.grpc.processor (module)
eventsourcing.system.grpc.runner (module)
eventsourcing.system.multiprocess (module)
eventsourcing.system.ray (module)
eventsourcing.system.runner (module)
eventsourcing.system.thespian (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
follow() (eventsourcing.application.process.ProcessApplication method)
foo (eventsourcing.example.domainmodel.Example attribute)
from_record() (eventsourcing.infrastructure.base.BaseRecordManager method)
G
generate_ports() (eventsourcing.system.grpc.runner.GrpcRunner method)
get_and_project_events() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
get_domain_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
get_entity() (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.RecordManagerWithNotifications method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_max_tracking_record_id() (eventsourcing.infrastructure.base.RecordManagerWithTracking method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager 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_notification_log_section() (eventsourcing.system.grpc.processor.ProcessorServer method)
get_notification_records() (eventsourcing.infrastructure.base.RecordManagerWithNotifications method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository method)
get_pipeline_and_notification_id() (eventsourcing.infrastructure.base.RecordManagerWithTracking method)
get_record() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager 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.popo.manager.PopoRecordManager 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)
GetNotifications() (eventsourcing.system.grpc.processor.ProcessorServer method)
GrpcRunner (class in eventsourcing.system.grpc.runner)
H
handle_prompt() (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.RecordManagerWithTracking method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager 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.popo.factory.PopoInfrastructureFactory 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)
(class in eventsourcing.infrastructure.popo.records)
(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)
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)
K
kill_process() (eventsourcing.system.grpc.runner.GrpcRunner method)
L
Lead() (eventsourcing.system.grpc.processor.ProcessorServer method)
lead() (eventsourcing.system.grpc.processor.ProcessorServer method)
list_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
list_items() (eventsourcing.infrastructure.base.BaseRecordManager method)
listen() (eventsourcing.system.grpc.runner.GrpcRunner 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)
MethodWrapper (class in eventsourcing.system.grpc.runner)
MismatchedOriginatorError
mixin() (eventsourcing.application.simple.SimpleApplication class method)
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.eventsourcedrepository.EventSourcedRepository 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)
(class in eventsourcing.system.grpc.processor)
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.AbstractSnapshot attribute)
(eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
originator_topic (eventsourcing.domain.model.entity.DomainEntity.Created attribute)
originator_version (eventsourcing.domain.model.events.AbstractSnapshot attribute)
(eventsourcing.domain.model.events.EventWithOriginatorVersion attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
OriginatorIDError
OriginatorVersionError
P
persist_event_type (eventsourcing.application.command.CommandProcess attribute)
PersistencePolicy (class in eventsourcing.application.policies)
Ping() (eventsourcing.system.grpc.processor.ProcessorServer method)
(eventsourcing.system.grpc.runner.ProcessorListener method)
Pipeable (class in eventsourcing.application.pipeline)
PipeableMetaclass (class in eventsourcing.application.pipeline)
PipelineActor (class in eventsourcing.system.thespian)
PipelineExpression (class in eventsourcing.application.pipeline)
policy() (eventsourcing.application.process.ProcessApplication method)
PopoApplication (class in eventsourcing.application.popo)
PopoInfrastructureFactory (class in eventsourcing.infrastructure.popo.factory)
PopoRecordManager (class in eventsourcing.infrastructure.popo.manager)
position (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
present_resource() (eventsourcing.interface.notificationlog.NotificationLogView method)
process_upstream_event() (eventsourcing.application.process.ProcessApplication method)
ProcessApplication (class in eventsourcing.application.process)
ProcessApplicationWithSnapshotting (class in eventsourcing.application.process)
ProcessEvent (class in eventsourcing.application.simple)
ProcessMaster (class in eventsourcing.system.thespian)
ProcessorListener (class in eventsourcing.system.grpc.runner)
ProcessorServer (class in eventsourcing.system.grpc.processor)
ProcessRunningClockThread (class in eventsourcing.system.runner)
ProcessSlave (class in eventsourcing.system.thespian)
ProgrammingError
project_events() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
Prompt (class in eventsourcing.application.simple)
Prompt() (eventsourcing.system.grpc.processor.ProcessorServer method)
prompt() (eventsourcing.system.grpc.processor.ProcessorServer method)
Prompt() (eventsourcing.system.grpc.runner.ProcessorListener method)
prompt() (eventsourcing.system.grpc.runner.ProcessorListener method)
PromptFailed
PromptOutbox (class in eventsourcing.system.runner)
PromptQueuedApplicationThread (class in eventsourcing.system.runner)
PromptToPull (class in eventsourcing.application.simple)
PromptToQuit (class in eventsourcing.application.process)
publish() (in module eventsourcing.domain.model.events)
publish_prompt() (eventsourcing.application.simple.SimpleApplication method)
publish_prompt_for_events() (eventsourcing.application.process.ProcessApplication method)
PullNotifications (class in eventsourcing.system.grpc.processor)
put() (eventsourcing.system.runner.PromptOutbox method)
R
random_bytes() (in module eventsourcing.utils.random)
RayRunner (class in eventsourcing.system.ray)
read_items() (eventsourcing.application.notificationlog.NotificationLogReader method)
read_list() (eventsourcing.application.notificationlog.NotificationLogReader method)
receiveMessage() (eventsourcing.system.thespian.PipelineActor method)
(eventsourcing.system.thespian.ProcessMaster method)
(eventsourcing.system.thespian.ProcessSlave method)
(eventsourcing.system.thespian.SystemActor method)
reconstruct_object() (in module eventsourcing.utils.topic)
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)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager method)
record_manager_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute)
(eventsourcing.infrastructure.popo.factory.PopoInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
record_process_event() (eventsourcing.application.simple.SimpleApplication method)
RecordConflictError
RecordManagerNotificationLog (class in eventsourcing.application.notificationlog)
RecordManagerWithNotifications (class in eventsourcing.infrastructure.base)
RecordManagerWithTracking (class in eventsourcing.infrastructure.base)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
RemoteNotificationLog (class in eventsourcing.interface.notificationlog)
(class in eventsourcing.system.grpc.processor)
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.application.process.ProcessApplication method)
(eventsourcing.infrastructure.iterators.GetEntityEventsThread method)
(eventsourcing.system.grpc.processor.PullNotifications method)
(eventsourcing.system.grpc.processor.StartClient 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() (eventsourcing.application.simple.SimpleApplication method)
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)
(eventsourcing.system.grpc.processor.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)
SequencedItemMapperForPopo (class in eventsourcing.infrastructure.popo.mapper)
serve() (eventsourcing.system.grpc.processor.ProcessorServer method)
(eventsourcing.system.grpc.runner.ProcessorListener method)
set_reader_position() (eventsourcing.system.grpc.processor.PullNotifications method)
setup_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.AbstractDatastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
setup_table() (eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(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.popo.factory.PopoInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
SnapshotRecord (class in eventsourcing.infrastructure.cassandra.records)
(class in eventsourcing.infrastructure.django.models)
(class in eventsourcing.infrastructure.popo.records)
(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.definition.AbstractSystemRunner method)
(eventsourcing.system.grpc.runner.GrpcRunner method)
(eventsourcing.system.multiprocess.MultiprocessRunner method)
(eventsourcing.system.ray.RayRunner method)
(eventsourcing.system.runner.InProcessRunner method)
(eventsourcing.system.runner.MultiThreadedRunner method)
(eventsourcing.system.runner.SteppingMultiThreadedRunner method)
(eventsourcing.system.runner.SteppingSingleThreadedRunner method)
(eventsourcing.system.thespian.ThespianRunner method)
start_client() (eventsourcing.system.grpc.processor.ProcessorServer method)
start_processor() (eventsourcing.system.grpc.runner.GrpcRunner method)
StartClient (class in eventsourcing.system.grpc.processor)
state (eventsourcing.domain.model.events.AbstractSnapshot attribute)
(eventsourcing.domain.model.snapshot.Snapshot 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)
stop() (eventsourcing.system.grpc.processor.ProcessorServer method)
stop_process() (eventsourcing.system.grpc.runner.GrpcRunner method)
store_events() (eventsourcing.infrastructure.base.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
stored_event_record_class (eventsourcing.application.popo.PopoApplication attribute)
(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.popo.records)
(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.thespian)
T
take_snapshot() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
(eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method)
(eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method)
take_snapshots() (eventsourcing.application.process.ProcessApplicationWithSnapshotting method)
ThespianRunner (class in eventsourcing.system.thespian)
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)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager method)
topic (eventsourcing.domain.model.events.AbstractSnapshot 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)
Upcastable (class in eventsourcing.domain.model.versioning)
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
wait_for_termination() (eventsourcing.system.grpc.processor.ProcessorServer method)
WrappedRepository (class in eventsourcing.application.process)
write_records() (eventsourcing.infrastructure.base.RecordManagerWithTracking method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.popo.manager.PopoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
Read the Docs
v: v8.3.0
Versions
latest
stable
v9.0.0
v8.3.0
v8.2.5
v8.2.4
v8.2.3
v8.2.2
v8.2.1
v8.2.0
v8.1.0
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
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.