Index

_

__assert_not_discarded__() (eventsourcing.domain.model.entity.DomainEntity method) __change_attribute__() (eventsourcing.domain.model.entity.DomainEntity method) __check_hash__() (eventsourcing.domain.model.events.EventWithHash method) __check_obj__() (eventsourcing.domain.model.entity.DomainEntity.Event method) (eventsourcing.domain.model.entity.EntityWithHashchain.Event method) (eventsourcing.domain.model.entity.VersionedEntity.Event method) __create__() (eventsourcing.domain.model.entity.DomainEntity class method) (eventsourcing.domain.model.entity.EntityWithHashchain class method) __discard__() (eventsourcing.domain.model.entity.DomainEntity method) __enter__() (eventsourcing.application.system.System method) __eq__() (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.events.DomainEvent method) __event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute) __exit__() (eventsourcing.application.system.System method) __getitem__() (eventsourcing.application.notificationlog.AbstractNotificationLog method) (eventsourcing.application.notificationlog.LocalNotificationLog method) (eventsourcing.domain.model.array.AbstractArrayRepository method) (eventsourcing.domain.model.array.AbstractBigArrayRepository method) (eventsourcing.domain.model.array.BigArray method) (eventsourcing.interface.notificationlog.RemoteNotificationLog method) __getnewargs__() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) __hash__() (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) __hash_object__() (eventsourcing.domain.model.events.DomainEvent class method) __init__() (eventsourcing.application.actors.ActorModelRunner method) (eventsourcing.application.actors.PipelineActor method) (eventsourcing.application.actors.ProcessMaster method) (eventsourcing.application.actors.ProcessSlave method) (eventsourcing.application.actors.SystemActor method) (eventsourcing.application.multiprocess.MultiprocessRunner method) (eventsourcing.application.multiprocess.OperatingSystemProcess method) (eventsourcing.application.notificationlog.BigArrayNotificationLog method) (eventsourcing.application.notificationlog.LocalNotificationLog method) (eventsourcing.application.notificationlog.NotificationLogReader method) (eventsourcing.application.notificationlog.RecordManagerNotificationLog method) (eventsourcing.application.notificationlog.Section method) (eventsourcing.application.pipeline.PipelineExpression method) (eventsourcing.application.policies.PersistencePolicy method) (eventsourcing.application.process.ProcessApplication method) (eventsourcing.application.simple.SimpleApplication method) (eventsourcing.application.snapshotting.SnapshottingApplication method) (eventsourcing.application.sqlalchemy.SQLAlchemyApplication method) (eventsourcing.application.system.BarrierControlledApplicationThread method) (eventsourcing.application.system.BarrierControllingClockThread method) (eventsourcing.application.system.ClockThread method) (eventsourcing.application.system.MultiThreadedRunner method) (eventsourcing.application.system.ProcessRunningClockThread method) (eventsourcing.application.system.PromptOutbox method) (eventsourcing.application.system.PromptQueuedApplicationThread method) (eventsourcing.application.system.SingleThreadedRunner method) (eventsourcing.application.system.SteppingMultiThreadedRunner method) (eventsourcing.application.system.SteppingRunner method) (eventsourcing.application.system.SteppingSingleThreadedRunner method) (eventsourcing.application.system.System method) (eventsourcing.application.system.SystemRunner method) (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) (eventsourcing.domain.model.array.AbstractArrayRepository method) (eventsourcing.domain.model.array.BigArray method) (eventsourcing.domain.model.array.ItemAssigned method) (eventsourcing.domain.model.collection.Collection method) (eventsourcing.domain.model.command.Command method) (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) (eventsourcing.domain.model.events.EventWithOriginatorID method) (eventsourcing.domain.model.events.EventWithOriginatorVersion method) (eventsourcing.domain.model.events.EventWithTimestamp method) (eventsourcing.domain.model.events.EventWithTimeuuid method) (eventsourcing.domain.model.snapshot.Snapshot method) (eventsourcing.domain.model.timebucketedlog.MessageLogged method) (eventsourcing.domain.model.timebucketedlog.Timebucketedlog method) (eventsourcing.example.application.ApplicationWithEventStores method) (eventsourcing.example.application.ApplicationWithPersistencePolicies method) (eventsourcing.example.application.ExampleApplication method) (eventsourcing.example.domainmodel.Example method) (eventsourcing.example.interface.flaskapp.IntegerSequencedItem method) (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.eventstore.EventStore method) (eventsourcing.infrastructure.factory.InfrastructureFactory method) (eventsourcing.infrastructure.integersequencegenerators.redisincr.RedisIncr method) (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) (eventsourcing.infrastructure.iterators.GetEntityEventsThread method) (eventsourcing.infrastructure.repositories.array.BigArrayRepository method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) (eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemySettings method) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) (eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord method) (eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord method) (eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord method) (eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord method) (eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord method) (eventsourcing.interface.notificationlog.NotificationLogView method) (eventsourcing.interface.notificationlog.RemoteNotificationLog method) (eventsourcing.utils.cipher.aes.AESCipher method) (eventsourcing.utils.transcoding.ObjectJSONDecoder method) (eventsourcing.utils.transcoding.ObjectJSONEncoder method)

__iter__() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) (eventsourcing.infrastructure.iterators.SequencedItemIterator method) (eventsourcing.infrastructure.iterators.ThreadedSequencedItemIterator method) __json_encoder_class__ (eventsourcing.domain.model.events.DomainEvent attribute) __len__() (eventsourcing.domain.model.array.BigArray method) __mutate__() (eventsourcing.domain.model.collection.Collection.ItemAdded method) (eventsourcing.domain.model.collection.Collection.ItemRemoved method) (eventsourcing.domain.model.entity.DomainEntity.AttributeChanged method) (eventsourcing.domain.model.entity.DomainEntity.Created method) (eventsourcing.domain.model.entity.DomainEntity.Discarded method) (eventsourcing.domain.model.entity.EntityWithHashchain.Created method) (eventsourcing.domain.model.entity.EntityWithHashchain.Discarded method) (eventsourcing.domain.model.entity.EntityWithHashchain.Event method) (eventsourcing.domain.model.entity.TimestampedEntity.Event method) (eventsourcing.domain.model.entity.VersionedEntity.Event method) (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) __ne__() (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.events.DomainEvent method) __new__() (eventsourcing.infrastructure.sequenceditem.SequencedItem static method) (eventsourcing.infrastructure.sequenceditem.StoredEvent static method) __next__() (eventsourcing.infrastructure.integersequencegenerators.redisincr.RedisIncr method) __or__() (eventsourcing.application.pipeline.PipeableMetaclass method) __publish__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) (eventsourcing.domain.model.entity.DomainEntity method) __publish_to_subscribers__() (eventsourcing.domain.model.entity.DomainEntity method) __repr__() (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) __save__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) __setattr__() (eventsourcing.domain.model.events.DomainEvent method) __setitem__() (eventsourcing.domain.model.array.BigArray method) __trigger_event__() (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.entity.EntityWithHashchain method) (eventsourcing.domain.model.entity.VersionedEntity method) _asdict() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) _inc_page_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) _inc_query_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) _make() (eventsourcing.infrastructure.sequenceditem.SequencedItem class method) (eventsourcing.infrastructure.sequenceditem.StoredEvent class method) _prepare_insert() (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) _replace() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method)

A

a (eventsourcing.example.domainmodel.Example attribute) AbstractArrayRepository (class in eventsourcing.domain.model.array) AbstractBigArrayRepository (class in eventsourcing.domain.model.array) AbstractDatastore (class in eventsourcing.infrastructure.datastore) AbstractEventStore (class in eventsourcing.infrastructure.eventstore) AbstractNotificationLog (class in eventsourcing.application.notificationlog) AbstractSequencedItemIterator (class in eventsourcing.infrastructure.iterators) AbstractSequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper) AbstractSequencedItemRecordManager (class in eventsourcing.infrastructure.base) AbstractSnapshop (class in eventsourcing.domain.model.snapshot) AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting) ACIDRecordManager (class in eventsourcing.infrastructure.base) ActorModelRunner (class in eventsourcing.application.actors) AESCipher (class in eventsourcing.utils.cipher.aes) AggregateRoot (class in eventsourcing.domain.model.aggregate) AggregateRoot.AttributeChanged (class in eventsourcing.domain.model.aggregate) AggregateRoot.Created (class in eventsourcing.domain.model.aggregate) AggregateRoot.Discarded (class in eventsourcing.domain.model.aggregate) AggregateRoot.Event (class in eventsourcing.domain.model.aggregate)

AggregateRootWithHashchainedEvents (class in eventsourcing.domain.model.aggregate) AggregateRootWithHashchainedEvents.AttributeChanged (class in eventsourcing.domain.model.aggregate) AggregateRootWithHashchainedEvents.Created (class in eventsourcing.domain.model.aggregate) AggregateRootWithHashchainedEvents.Discarded (class in eventsourcing.domain.model.aggregate) AggregateRootWithHashchainedEvents.Event (class in eventsourcing.domain.model.aggregate) all_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) all_sequence_ids() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) ApplicationWithConcreteInfrastructure (class in eventsourcing.application.simple) ApplicationWithEventStores (class in eventsourcing.example.application) ApplicationWithPersistencePolicies (class in eventsourcing.example.application) ArrayIndexError ArrayRepository (class in eventsourcing.infrastructure.repositories.array) assert_event_handlers_empty() (in module eventsourcing.domain.model.events) attribute() (in module eventsourcing.domain.model.decorators) AttributeChanged (class in eventsourcing.domain.model.events)

B

b (eventsourcing.example.domainmodel.Example attribute) BarrierControlledApplicationThread (class in eventsourcing.application.system) BarrierControllingClockThread (class in eventsourcing.application.system) BaseAggregateRoot (class in eventsourcing.domain.model.aggregate) BaseAggregateRoot.AttributeChanged (class in eventsourcing.domain.model.aggregate)

BaseAggregateRoot.Created (class in eventsourcing.domain.model.aggregate) BaseAggregateRoot.Discarded (class in eventsourcing.domain.model.aggregate) BaseAggregateRoot.Event (class in eventsourcing.domain.model.aggregate) BigArray (class in eventsourcing.domain.model.array) BigArrayNotificationLog (class in eventsourcing.application.notificationlog) BigArrayRepository (class in eventsourcing.infrastructure.repositories.array)

C

calc_parent() (eventsourcing.domain.model.array.BigArray method) CassandraDatastore (class in eventsourcing.infrastructure.cassandra.datastore) CassandraInfrastructureFactory (class in eventsourcing.infrastructure.cassandra.factory) CassandraRecordManager (class in eventsourcing.infrastructure.cassandra.manager) CassandraSettings (class in eventsourcing.infrastructure.cassandra.datastore) CausalDependencyFailed clear_event_handlers() (in module eventsourcing.domain.model.events) ClockThread (class in eventsourcing.application.system) close() (eventsourcing.application.actors.ActorModelRunner method) close_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) close_example_application() (in module eventsourcing.example.application) Collection (class in eventsourcing.domain.model.collection) Collection.Created (class in eventsourcing.domain.model.collection) Collection.Discarded (class in eventsourcing.domain.model.collection) Collection.Event (class in eventsourcing.domain.model.collection) Collection.EventWithItem (class in eventsourcing.domain.model.collection) Collection.ItemAdded (class in eventsourcing.domain.model.collection) Collection.ItemRemoved (class in eventsourcing.domain.model.collection) CollectionRepository (class in eventsourcing.infrastructure.repositories.collection_repo) Command (class in eventsourcing.domain.model.command) Command.AttributeChanged (class in eventsourcing.domain.model.command)

Command.Created (class in eventsourcing.domain.model.command) Command.Discarded (class in eventsourcing.domain.model.command) Command.Done (class in eventsourcing.domain.model.command) Command.Event (class in eventsourcing.domain.model.command) CommandProcess (class in eventsourcing.application.command) ConcurrencyError ConsistencyError construct_app() (eventsourcing.application.system.System method) construct_datastore() (eventsourcing.infrastructure.factory.InfrastructureFactory method) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method) construct_example_application() (in module eventsourcing.example.application) construct_infrastructure_factory() (eventsourcing.application.simple.SimpleApplication method) construct_integer_sequenced_event_store() (eventsourcing.infrastructure.factory.InfrastructureFactory method) construct_integer_sequenced_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method) construct_item_args() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) construct_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method) construct_sequenced_item_mapper() (eventsourcing.infrastructure.factory.InfrastructureFactory method) construct_snapshot_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method) construct_timestamp_sequenced_record_manager() (eventsourcing.infrastructure.factory.InfrastructureFactory method) create_new_example() (eventsourcing.example.application.ExampleApplication method) (in module eventsourcing.example.domainmodel) Created (class in eventsourcing.domain.model.events)

D

DataIntegrityError DatasourceSettingsError DatastoreConnectionError DatastoreError DatastoreSettings (class in eventsourcing.infrastructure.datastore) DatastoreTableError datetime_from_timestamp() (in module eventsourcing.utils.times) decimaltimestamp() (in module eventsourcing.utils.times) decimaltimestamp_from_uuid() (in module eventsourcing.utils.times) decode_bytes() (in module eventsourcing.utils.random) decrypt() (eventsourcing.utils.cipher.aes.AESCipher method) default() (eventsourcing.utils.transcoding.ObjectJSONEncoder method) delete_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)

Discarded (class in eventsourcing.domain.model.events) DjangoApplication (class in eventsourcing.application.django) DjangoInfrastructureFactory (class in eventsourcing.infrastructure.django.factory) DjangoRecordManager (class in eventsourcing.infrastructure.django.manager) DomainEntity (class in eventsourcing.domain.model.entity) DomainEntity.AttributeChanged (class in eventsourcing.domain.model.entity) DomainEntity.Created (class in eventsourcing.domain.model.entity) DomainEntity.Discarded (class in eventsourcing.domain.model.entity) DomainEntity.Event (class in eventsourcing.domain.model.entity) DomainEvent (class in eventsourcing.domain.model.events) drop_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)

E

encode_bytes() (in module eventsourcing.utils.random) encode_random_bytes() (in module eventsourcing.utils.random) encrypt() (eventsourcing.utils.cipher.aes.AESCipher method) entity_from_snapshot() (in module eventsourcing.infrastructure.snapshotting) EntityIsDiscarded EntitySnapshotRecord (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) EntitySnapshotRecord.DoesNotExist EntitySnapshotRecord.MultipleObjectsReturned EntityVersionNotFound EntityWithHashchain (class in eventsourcing.domain.model.entity) EntityWithHashchain.AttributeChanged (class in eventsourcing.domain.model.entity) EntityWithHashchain.Created (class in eventsourcing.domain.model.entity) EntityWithHashchain.Discarded (class in eventsourcing.domain.model.entity) EntityWithHashchain.Event (class in eventsourcing.domain.model.entity) event_from_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) event_store_class (eventsourcing.application.simple.SimpleApplication attribute) (eventsourcing.infrastructure.factory.InfrastructureFactory attribute) EventHandlersNotEmptyError EventHashError EventRecordNotFound EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting) eventsourcing.application.actors (module) eventsourcing.application.command (module) eventsourcing.application.django (module) eventsourcing.application.multiprocess (module) eventsourcing.application.notificationlog (module) eventsourcing.application.pipeline (module) eventsourcing.application.policies (module) eventsourcing.application.popo (module) eventsourcing.application.process (module) eventsourcing.application.simple (module) eventsourcing.application.snapshotting (module) eventsourcing.application.sqlalchemy (module) eventsourcing.application.system (module) eventsourcing.domain.model.aggregate (module), [1] eventsourcing.domain.model.array (module), [1] eventsourcing.domain.model.collection (module), [1] eventsourcing.domain.model.command (module), [1] eventsourcing.domain.model.decorator (module) eventsourcing.domain.model.decorators (module) eventsourcing.domain.model.entity (module), [1] eventsourcing.domain.model.events (module), [1] eventsourcing.domain.model.snapshot (module), [1] eventsourcing.domain.model.timebucketedlog (module), [1] eventsourcing.example.application (module) eventsourcing.example.domainmodel (module) eventsourcing.example.infrastructure (module) eventsourcing.example.interface.flaskapp (module) eventsourcing.exceptions (module) eventsourcing.infrastructure.base (module), [1] eventsourcing.infrastructure.cassandra (module)

eventsourcing.infrastructure.cassandra.datastore (module) eventsourcing.infrastructure.cassandra.factory (module) eventsourcing.infrastructure.cassandra.manager (module) eventsourcing.infrastructure.cassandra.records (module) eventsourcing.infrastructure.datastore (module), [1] eventsourcing.infrastructure.django (module) eventsourcing.infrastructure.django.factory (module) eventsourcing.infrastructure.django.manager (module) eventsourcing.infrastructure.django.models (module) eventsourcing.infrastructure.django.utils (module) eventsourcing.infrastructure.eventplayer (module), [1] eventsourcing.infrastructure.eventsourcedrepository (module), [1] eventsourcing.infrastructure.eventstore (module), [1] eventsourcing.infrastructure.factory (module), [1] eventsourcing.infrastructure.integersequencegenerators (module) eventsourcing.infrastructure.integersequencegenerators.base (module) eventsourcing.infrastructure.integersequencegenerators.redisincr (module) eventsourcing.infrastructure.iterators (module), [1] eventsourcing.infrastructure.repositories (module) eventsourcing.infrastructure.repositories.array (module) eventsourcing.infrastructure.repositories.collection_repo (module) eventsourcing.infrastructure.repositories.timebucketedlog_repo (module) eventsourcing.infrastructure.sequenceditem (module), [1] eventsourcing.infrastructure.sequenceditemmapper (module), [1] eventsourcing.infrastructure.snapshotting (module), [1] eventsourcing.infrastructure.sqlalchemy (module) eventsourcing.infrastructure.sqlalchemy.datastore (module) eventsourcing.infrastructure.sqlalchemy.factory (module) eventsourcing.infrastructure.sqlalchemy.manager (module) eventsourcing.infrastructure.sqlalchemy.records (module) eventsourcing.infrastructure.timebucketedlog_reader (module), [1] eventsourcing.interface.notificationlog (module) eventsourcing.utils.cipher (module) eventsourcing.utils.cipher.aes (module) eventsourcing.utils.random (module), [1] eventsourcing.utils.times (module), [1] eventsourcing.utils.topic (module), [1] eventsourcing.utils.transcoding (module), [1] EventSourcingError EventStore (class in eventsourcing.infrastructure.eventstore) EventWithHash (class in eventsourcing.domain.model.events) EventWithOriginatorID (class in eventsourcing.domain.model.events) EventWithOriginatorVersion (class in eventsourcing.domain.model.events) EventWithTimestamp (class in eventsourcing.domain.model.events) EventWithTimeuuid (class in eventsourcing.domain.model.events) Example (class in eventsourcing.example.domainmodel) Example.AttributeChanged (class in eventsourcing.example.domainmodel) Example.Created (class in eventsourcing.example.domainmodel) Example.Discarded (class in eventsourcing.example.domainmodel) Example.Event (class in eventsourcing.example.domainmodel) Example.Heartbeat (class in eventsourcing.example.domainmodel) ExampleApplication (class in eventsourcing.example.application) ExampleRepository (class in eventsourcing.example.infrastructure)

F

foo (eventsourcing.example.domainmodel.Example attribute)

from_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)

G

get_domain_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) get_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) get_example_application() (in module eventsourcing.example.application) get_item() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) get_items() (eventsourcing.application.notificationlog.BigArrayNotificationLog method) (eventsourcing.application.notificationlog.LocalNotificationLog method) (eventsourcing.application.notificationlog.RecordManagerNotificationLog method) (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) get_last_array() (eventsourcing.domain.model.array.BigArray method) get_max_record_id() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_max_tracking_record_id() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_most_recent_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) get_next_position() (eventsourcing.application.notificationlog.BigArrayNotificationLog method) (eventsourcing.application.notificationlog.LocalNotificationLog method) (eventsourcing.application.notificationlog.RecordManagerNotificationLog method)

get_notifications() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_pipeline_and_notification_id() (eventsourcing.infrastructure.base.ACIDRecordManager method) get_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_record_table_name() (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_records() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) get_snapshot() (eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method) (eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method) get_timebucketedlog_reader() (in module eventsourcing.infrastructure.timebucketedlog_reader) get_topic() (in module eventsourcing.utils.topic) GetEntityEventsThread (class in eventsourcing.infrastructure.iterators)

H

handle_prompt() (eventsourcing.application.system.InProcessRunner method) (eventsourcing.application.system.MultiThreadedRunner method) (eventsourcing.application.system.SingleThreadedRunner method) (eventsourcing.application.system.SteppingMultiThreadedRunner method) (eventsourcing.application.system.SteppingSingleThreadedRunner method)

has_tracking_record() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) HeadHashError

I

id (eventsourcing.domain.model.entity.DomainEntity attribute) infrastructure_factory_class (eventsourcing.application.popo.PopoApplication attribute) (eventsourcing.application.simple.SimpleApplication attribute) (eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute) InfrastructureFactory (class in eventsourcing.infrastructure.factory) init_example_application() (in module eventsourcing.example.application) initial_section_id (eventsourcing.application.notificationlog.NotificationLogReader attribute) InProcessRunner (class in eventsourcing.application.system) insert_select_max (eventsourcing.infrastructure.base.SQLRecordManager attribute) insert_tracking_record (eventsourcing.infrastructure.base.SQLRecordManager attribute) insert_values (eventsourcing.infrastructure.base.SQLRecordManager attribute) integer_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute) (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)

IntegerSequencedItem (class in eventsourcing.example.interface.flaskapp) IntegerSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) IntegerSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (in module eventsourcing.infrastructure.sqlalchemy.records) IntegerSequencedRecord.DoesNotExist, [1] IntegerSequencedRecord.MultipleObjectsReturned, [1] IntegerSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) is_prompt() (eventsourcing.application.system.System method) item_from_event() (eventsourcing.infrastructure.eventstore.EventStore method) (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) ItemAssigned (class in eventsourcing.domain.model.array) iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute) iterencode() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)

L

list_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)

LocalNotificationLog (class in eventsourcing.application.notificationlog) Logged (class in eventsourcing.domain.model.events)

M

MessageLogged (class in eventsourcing.domain.model.timebucketedlog) MismatchedOriginatorError MultiprocessRunner (class in eventsourcing.application.multiprocess) MultiThreadedRunner (class in eventsourcing.application.system)

mutate() (eventsourcing.domain.model.command.Command.Done method) (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.example.domainmodel.Example.Heartbeat method) mutator() (in module eventsourcing.domain.model.decorators) MutatorRequiresTypeNotInstance

N

notification_log_reader_class (eventsourcing.application.process.ProcessApplication attribute) NotificationLogReader (class in eventsourcing.application.notificationlog) NotificationLogView (class in eventsourcing.interface.notificationlog)

NotificationTrackingRecord (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) NotificationTrackingRecord.DoesNotExist NotificationTrackingRecord.MultipleObjectsReturned

O

ObjectJSONDecoder (class in eventsourcing.utils.transcoding) ObjectJSONEncoder (class in eventsourcing.utils.transcoding) OperatingSystemProcess (class in eventsourcing.application.multiprocess) OperationalError originator_id (eventsourcing.domain.model.events.EventWithOriginatorID attribute) (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)

originator_topic (eventsourcing.domain.model.entity.DomainEntity.Created attribute) originator_version (eventsourcing.domain.model.events.EventWithOriginatorVersion attribute) (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute) OriginatorIDError OriginatorVersionError

P

persist_event_type (eventsourcing.application.command.CommandProcess attribute) PersistencePolicy (class in eventsourcing.application.policies) Pipeable (class in eventsourcing.application.pipeline) PipeableMetaclass (class in eventsourcing.application.pipeline) PipelineActor (class in eventsourcing.application.actors) PipelineExpression (class in eventsourcing.application.pipeline) policy() (eventsourcing.application.process.ProcessApplication static method) PopoApplication (class in eventsourcing.application.popo) position (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) present_section() (eventsourcing.interface.notificationlog.NotificationLogView method) ProcessApplication (class in eventsourcing.application.process)

ProcessApplicationWithSnapshotting (class in eventsourcing.application.process) ProcessMaster (class in eventsourcing.application.actors) ProcessRunningClockThread (class in eventsourcing.application.system) ProcessSlave (class in eventsourcing.application.actors) ProgrammingError PromptFailed PromptOutbox (class in eventsourcing.application.system) PromptQueuedApplicationThread (class in eventsourcing.application.system) publish() (in module eventsourcing.domain.model.events) publish_prompt() (eventsourcing.application.process.ProcessApplication method) put() (eventsourcing.application.system.PromptOutbox method)

R

random_bytes() (in module eventsourcing.utils.random) receiveMessage() (eventsourcing.application.actors.PipelineActor method) (eventsourcing.application.actors.ProcessMaster method) (eventsourcing.application.actors.ProcessSlave method) (eventsourcing.application.actors.SystemActor method) record_manager_class (eventsourcing.application.django.DjangoApplication attribute) (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute) (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) record_sequenced_item() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) record_sequenced_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) RecordConflictError

RecordManagerNotificationLog (class in eventsourcing.application.notificationlog) RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr) RemoteNotificationLog (class in eventsourcing.interface.notificationlog) RepositoryKeyError reset_connection_after_forking() (eventsourcing.application.django.DjangoApplication class method) resolve_attr() (in module eventsourcing.utils.topic) resolve_topic() (in module eventsourcing.utils.topic) retry() (in module eventsourcing.domain.model.decorators) run() (eventsourcing.application.multiprocess.OperatingSystemProcess method) (eventsourcing.application.system.BarrierControlledApplicationThread method) (eventsourcing.application.system.BarrierControllingClockThread method) (eventsourcing.application.system.ProcessRunningClockThread method) (eventsourcing.application.system.PromptQueuedApplicationThread method) (eventsourcing.infrastructure.iterators.GetEntityEventsThread method) run_followers() (eventsourcing.application.system.SingleThreadedRunner method)

S

Section (class in eventsourcing.application.notificationlog) seek() (eventsourcing.application.notificationlog.NotificationLogReader method) sequence_id (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) sequenced_item_class (eventsourcing.infrastructure.factory.InfrastructureFactory attribute) sequenced_item_mapper_class (eventsourcing.application.popo.PopoApplication attribute) (eventsourcing.infrastructure.factory.InfrastructureFactory attribute) SequencedItem (class in eventsourcing.infrastructure.sequenceditem) SequencedItemIterator (class in eventsourcing.infrastructure.iterators) SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper) setup_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) setup_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) SimpleApplication (class in eventsourcing.application.simple) SingleThreadedRunner (class in eventsourcing.application.system) Snapshot (class in eventsourcing.domain.model.snapshot) snapshot_record_class (eventsourcing.application.django.DjangoApplication attribute) (eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute) (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute) (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) SnapshotRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) SnapshotRecord.DoesNotExist, [1] SnapshotRecord.MultipleObjectsReturned, [1] SnapshottingApplication (class in eventsourcing.application.snapshotting) SQLAlchemyApplication (class in eventsourcing.application.sqlalchemy) SQLAlchemyDatastore (class in eventsourcing.infrastructure.sqlalchemy.datastore) SQLAlchemyInfrastructureFactory (class in eventsourcing.infrastructure.sqlalchemy.factory) SQLAlchemyRecordManager (class in eventsourcing.infrastructure.sqlalchemy.manager)

SQLAlchemySettings (class in eventsourcing.infrastructure.sqlalchemy.datastore) SQLRecordManager (class in eventsourcing.infrastructure.base) start() (eventsourcing.application.actors.ActorModelRunner method) (eventsourcing.application.multiprocess.MultiprocessRunner method) (eventsourcing.application.system.InProcessRunner method) (eventsourcing.application.system.MultiThreadedRunner method) (eventsourcing.application.system.SteppingMultiThreadedRunner method) (eventsourcing.application.system.SteppingSingleThreadedRunner method) (eventsourcing.application.system.SystemRunner method) state (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute) (eventsourcing.domain.model.snapshot.Snapshot attribute) (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute) SteppingMultiThreadedRunner (class in eventsourcing.application.system) SteppingRunner (class in eventsourcing.application.system) SteppingSingleThreadedRunner (class in eventsourcing.application.system) store() (eventsourcing.infrastructure.eventstore.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) stored_event_record_class (eventsourcing.application.django.DjangoApplication 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.sqlalchemy.records) StoredEventRecord.DoesNotExist, [1] StoredEventRecord.MultipleObjectsReturned, [1] subrepo (eventsourcing.domain.model.array.AbstractBigArrayRepository attribute) (eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute) subrepo_class (eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute) subscribe() (in module eventsourcing.domain.model.events) subscribe_to() (in module eventsourcing.domain.model.decorators) System (class in eventsourcing.application.system) SystemActor (class in eventsourcing.application.actors) SystemRunner (class in eventsourcing.application.system)

T

take_snapshot() (eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method) (eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method) ThreadedSequencedItemIterator (class in eventsourcing.infrastructure.iterators) Timebucketedlog (class in eventsourcing.domain.model.timebucketedlog) Timebucketedlog.BucketSizeChanged (class in eventsourcing.domain.model.timebucketedlog) Timebucketedlog.Event (class in eventsourcing.domain.model.timebucketedlog) Timebucketedlog.Started (class in eventsourcing.domain.model.timebucketedlog) TimebucketedlogRepo (class in eventsourcing.infrastructure.repositories.timebucketedlog_repo) TimeSequenceError timestamp (eventsourcing.domain.model.events.EventWithTimestamp attribute) timestamp_long_from_uuid() (in module eventsourcing.utils.times) timestamp_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute) (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) TimestampedEntity (class in eventsourcing.domain.model.entity) TimestampedEntity.AttributeChanged (class in eventsourcing.domain.model.entity) TimestampedEntity.Created (class in eventsourcing.domain.model.entity) TimestampedEntity.Discarded (class in eventsourcing.domain.model.entity) TimestampedEntity.Event (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity.AttributeChanged (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity.Created (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity.Discarded (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity.Event (class in eventsourcing.domain.model.entity)

TimestampSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) TimestampSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (in module eventsourcing.infrastructure.sqlalchemy.records) TimestampSequencedRecord.DoesNotExist, [1] TimestampSequencedRecord.MultipleObjectsReturned, [1] TimestampSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) TimeuuidedEntity (class in eventsourcing.domain.model.entity) TimeuuidedVersionedEntity (class in eventsourcing.domain.model.entity) TimeuuidSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) TimeuuidSequencedRecord.DoesNotExist TimeuuidSequencedRecord.MultipleObjectsReturned to_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method) topic (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute) (eventsourcing.domain.model.snapshot.Snapshot attribute) (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute) TopicResolutionError tracking_record_class (eventsourcing.infrastructure.django.manager.DjangoRecordManager attribute) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager 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

write_records() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)