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) __contains__() (eventsourcing.infrastructure.base.AbstractEntityRepository method) (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method) __create__() (eventsourcing.domain.model.entity.DomainEntity class method) (eventsourcing.domain.model.entity.EntityWithHashchain class method) __discard__() (eventsourcing.domain.model.entity.DomainEntity method) __enter__() (eventsourcing.application.simple.SimpleApplication method) (eventsourcing.system.definition.AbstractSystemRunner method) (eventsourcing.system.definition.System method) __eq__() (eventsourcing.application.process.PromptToPull method) (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.events.DomainEvent method) __event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute) __exit__() (eventsourcing.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.base.AbstractEntityRepository method) (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method) (eventsourcing.interface.notificationlog.RemoteNotificationLog method) __getnewargs__() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) __hash__() (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) __hash_object_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.ProcessEvent method) (eventsourcing.application.process.PromptToPull method) (eventsourcing.application.process.WrappedRepository method) (eventsourcing.application.simple.SimpleApplication method) (eventsourcing.application.snapshotting.SnapshottingApplication method) (eventsourcing.application.sqlalchemy.SQLAlchemyApplication method) (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) (eventsourcing.domain.model.array.AbstractArrayRepository method) (eventsourcing.domain.model.array.BigArray method) (eventsourcing.domain.model.array.ItemAssigned method) (eventsourcing.domain.model.collection.Collection method) (eventsourcing.domain.model.command.Command method) (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) (eventsourcing.domain.model.events.EventWithOriginatorID method) (eventsourcing.domain.model.events.EventWithOriginatorVersion method) (eventsourcing.domain.model.events.EventWithTimestamp method) (eventsourcing.domain.model.events.EventWithTimeuuid method) (eventsourcing.domain.model.snapshot.Snapshot method) (eventsourcing.domain.model.timebucketedlog.MessageLogged method) (eventsourcing.domain.model.timebucketedlog.Timebucketedlog method) (eventsourcing.example.application.ApplicationWithEventStores method) (eventsourcing.example.application.ApplicationWithPersistencePolicies method) (eventsourcing.example.application.ExampleApplication method) (eventsourcing.example.domainmodel.Example method) (eventsourcing.example.interface.flaskapp.IntegerSequencedItem method) (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.base.AbstractEventStore method) (eventsourcing.infrastructure.base.AbstractRecordManager method) (eventsourcing.infrastructure.base.BaseRecordManager method) (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory method) (eventsourcing.infrastructure.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.manager.PopoStoredEventRecord method) (eventsourcing.infrastructure.repositories.array.BigArrayRepository method) (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) (eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemySettings method) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) (eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord method) (eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord method) (eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord method) (eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord method) (eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord method) (eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord method) (eventsourcing.interface.notificationlog.NotificationLogView method) (eventsourcing.interface.notificationlog.RemoteNotificationLog method) (eventsourcing.system.actors.ActorModelRunner method) (eventsourcing.system.actors.PipelineActor method) (eventsourcing.system.actors.ProcessMaster method) (eventsourcing.system.actors.ProcessSlave method) (eventsourcing.system.actors.SystemActor method) (eventsourcing.system.definition.AbstractSystemRunner method) (eventsourcing.system.definition.System method) (eventsourcing.system.multiprocess.MultiprocessRunner method) (eventsourcing.system.multiprocess.OperatingSystemProcess method) (eventsourcing.system.runner.BarrierControlledApplicationThread method) (eventsourcing.system.runner.BarrierControllingClockThread method) (eventsourcing.system.runner.ClockThread method) (eventsourcing.system.runner.MultiThreadedRunner method) (eventsourcing.system.runner.ProcessRunningClockThread method) (eventsourcing.system.runner.PromptOutbox method) (eventsourcing.system.runner.PromptQueuedApplicationThread method) (eventsourcing.system.runner.SingleThreadedRunner method) (eventsourcing.system.runner.SteppingMultiThreadedRunner method) (eventsourcing.system.runner.SteppingRunner method) (eventsourcing.system.runner.SteppingSingleThreadedRunner method) (eventsourcing.utils.cipher.aes.AESCipher method) (eventsourcing.utils.transcoding.ObjectJSONDecoder method) (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.DomainEvent method) (eventsourcing.domain.model.events.EventWithHash method) __ne__() (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.events.DomainEvent method) __new__() (eventsourcing.infrastructure.sequenceditem.SequencedItem static method) (eventsourcing.infrastructure.sequenceditem.StoredEvent static method) __next__() (eventsourcing.infrastructure.integersequencegenerators.base.AbstractIntegerSequenceGenerator method) (eventsourcing.infrastructure.integersequencegenerators.base.SimpleIntegerSequenceGenerator method) (eventsourcing.infrastructure.integersequencegenerators.redisincr.RedisIncr method) __or__() (eventsourcing.application.pipeline.PipeableMetaclass method) __publish__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) (eventsourcing.domain.model.entity.DomainEntity method) __publish_to_subscribers__() (eventsourcing.domain.model.entity.DomainEntity method) __repr__() (eventsourcing.application.process.PromptToPull method) (eventsourcing.domain.model.events.DomainEvent method) (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) __save__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot method) __setattr__() (eventsourcing.domain.model.events.DomainEvent method) __setitem__() (eventsourcing.domain.model.array.BigArray method) __trigger_event__() (eventsourcing.domain.model.entity.DomainEntity method) (eventsourcing.domain.model.entity.EntityWithHashchain method) (eventsourcing.domain.model.entity.VersionedEntity method) _asdict() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method) _inc_page_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) _inc_query_counter() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method) _make() (eventsourcing.infrastructure.sequenceditem.SequencedItem class method) (eventsourcing.infrastructure.sequenceditem.StoredEvent class method) _prepare_insert() (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) _replace() (eventsourcing.infrastructure.sequenceditem.SequencedItem method) (eventsourcing.infrastructure.sequenceditem.StoredEvent method)

A

a (eventsourcing.example.domainmodel.Example attribute) AbstractArrayRepository (class in eventsourcing.domain.model.array) AbstractBigArrayRepository (class in eventsourcing.domain.model.array) AbstractCollectionRepository (class in eventsourcing.domain.model.collection) AbstractDatastore (class in eventsourcing.infrastructure.datastore) AbstractEntityRepository (class in eventsourcing.infrastructure.base) AbstractEventStore (class in eventsourcing.infrastructure.base) AbstractExampleRepository (class in eventsourcing.example.domainmodel) AbstractIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base) AbstractNotificationLog (class in eventsourcing.application.notificationlog) AbstractRecordManager (class in eventsourcing.infrastructure.base) AbstractSequencedItemIterator (class in eventsourcing.infrastructure.iterators) AbstractSequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper) AbstractSnapshop (class in eventsourcing.infrastructure.base) AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting) AbstractSystemRunner (class in eventsourcing.system.definition) ACIDRecordManager (class in eventsourcing.infrastructure.base) ActorModelRunner (class in eventsourcing.system.actors) ActualOccasion (class in eventsourcing.whitehead) AESCipher (class in eventsourcing.utils.cipher.aes) AggregateRoot (class in eventsourcing.domain.model.aggregate) AggregateRoot.AttributeChanged (class in eventsourcing.domain.model.aggregate)

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

B

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

BaseAggregateRoot.Discarded (class in eventsourcing.domain.model.aggregate) BaseAggregateRoot.Event (class in eventsourcing.domain.model.aggregate) BaseRecordManager (class in eventsourcing.infrastructure.base) BigArray (class in eventsourcing.domain.model.array) BigArrayNotificationLog (class in eventsourcing.application.notificationlog) BigArrayRepository (class in eventsourcing.infrastructure.repositories.array) bind() (eventsourcing.system.definition.System method)

C

calc_parent() (eventsourcing.domain.model.array.BigArray method) CassandraDatastore (class in eventsourcing.infrastructure.cassandra.datastore) CassandraInfrastructureFactory (class in eventsourcing.infrastructure.cassandra.factory) CassandraRecordManager (class in eventsourcing.infrastructure.cassandra.manager) CassandraSettings (class in eventsourcing.infrastructure.cassandra.datastore) CausalDependencyFailed change_pipeline() (eventsourcing.application.simple.SimpleApplication method) clear_event_handlers() (in module eventsourcing.domain.model.events) ClockThread (class in eventsourcing.system.runner) close() (eventsourcing.system.actors.ActorModelRunner method) (eventsourcing.system.definition.AbstractSystemRunner method) (eventsourcing.system.multiprocess.MultiprocessRunner method) (eventsourcing.system.runner.InProcessRunner method) (eventsourcing.system.runner.MultiThreadedRunner method) (eventsourcing.system.runner.SteppingMultiThreadedRunner method) (eventsourcing.system.runner.SteppingSingleThreadedRunner method) close_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method) close_example_application() (in module eventsourcing.example.application) Collection (class in eventsourcing.domain.model.collection) Collection.Created (class in eventsourcing.domain.model.collection) Collection.Discarded (class in eventsourcing.domain.model.collection) Collection.Event (class in eventsourcing.domain.model.collection) Collection.EventWithItem (class in eventsourcing.domain.model.collection) Collection.ItemAdded (class in eventsourcing.domain.model.collection) Collection.ItemRemoved (class in eventsourcing.domain.model.collection) CollectionRepository (class in eventsourcing.infrastructure.repositories.collection_repo) Command (class in eventsourcing.domain.model.command) Command.AttributeChanged (class in eventsourcing.domain.model.command) Command.Created (class in eventsourcing.domain.model.command) Command.Discarded (class in eventsourcing.domain.model.command) Command.Done (class in eventsourcing.domain.model.command) Command.Event (class in eventsourcing.domain.model.command)

CommandProcess (class in eventsourcing.application.command) ConcurrencyError ConsistencyError construct_app() (eventsourcing.system.definition.System method) construct_datastore() (eventsourcing.application.simple.SimpleApplication method) (eventsourcing.application.sqlalchemy.SQLAlchemyApplication method) (eventsourcing.infrastructure.factory.InfrastructureFactory method) (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory 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_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) entity_from_snapshot() (in module eventsourcing.infrastructure.snapshotting) EntityIsDiscarded EntitySnapshotRecord (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) EntitySnapshotRecord.DoesNotExist EntitySnapshotRecord.MultipleObjectsReturned EntityVersionNotFound EntityWithHashchain (class in eventsourcing.domain.model.entity) EntityWithHashchain.AttributeChanged (class in eventsourcing.domain.model.entity) EntityWithHashchain.Created (class in eventsourcing.domain.model.entity) EntityWithHashchain.Discarded (class in eventsourcing.domain.model.entity) EntityWithHashchain.Event (class in eventsourcing.domain.model.entity) Event (class in eventsourcing.whitehead) event_from_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) event_from_topic_and_state() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) event_store (eventsourcing.infrastructure.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.django (module) eventsourcing.application.notificationlog (module) eventsourcing.application.pipeline (module) eventsourcing.application.policies (module) eventsourcing.application.popo (module) eventsourcing.application.process (module) eventsourcing.application.simple (module) eventsourcing.application.snapshotting (module) eventsourcing.application.sqlalchemy (module) eventsourcing.domain.model.aggregate (module), [1] eventsourcing.domain.model.array (module), [1] eventsourcing.domain.model.collection (module), [1] eventsourcing.domain.model.command (module), [1] eventsourcing.domain.model.decorator (module) eventsourcing.domain.model.decorators (module) eventsourcing.domain.model.entity (module), [1] eventsourcing.domain.model.events (module), [1] eventsourcing.domain.model.snapshot (module), [1] eventsourcing.domain.model.timebucketedlog (module), [1] eventsourcing.example.application (module) eventsourcing.example.domainmodel (module) eventsourcing.example.infrastructure (module) eventsourcing.example.interface.flaskapp (module) eventsourcing.exceptions (module) eventsourcing.infrastructure.base (module), [1] eventsourcing.infrastructure.cassandra (module) eventsourcing.infrastructure.cassandra.datastore (module)

eventsourcing.infrastructure.cassandra.factory (module) eventsourcing.infrastructure.cassandra.manager (module) eventsourcing.infrastructure.cassandra.records (module) eventsourcing.infrastructure.datastore (module), [1] eventsourcing.infrastructure.django (module) eventsourcing.infrastructure.django.factory (module) eventsourcing.infrastructure.django.manager (module) eventsourcing.infrastructure.django.models (module) eventsourcing.infrastructure.django.utils (module) eventsourcing.infrastructure.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.actors (module) eventsourcing.system.definition (module) eventsourcing.system.multiprocess (module) eventsourcing.system.runner (module) eventsourcing.utils.cipher (module) eventsourcing.utils.cipher.aes (module) eventsourcing.utils.random (module), [1] eventsourcing.utils.times (module), [1] eventsourcing.utils.topic (module), [1] eventsourcing.utils.transcoding (module), [1] eventsourcing.whitehead (module), [1] EventSourcingError EventStore (class in eventsourcing.infrastructure.eventstore) EventWithHash (class in eventsourcing.domain.model.events) EventWithOriginatorID (class in eventsourcing.domain.model.events) EventWithOriginatorVersion (class in eventsourcing.domain.model.events) EventWithTimestamp (class in eventsourcing.domain.model.events) EventWithTimeuuid (class in eventsourcing.domain.model.events) Example (class in eventsourcing.example.domainmodel) Example.AttributeChanged (class in eventsourcing.example.domainmodel) Example.Created (class in eventsourcing.example.domainmodel) Example.Discarded (class in eventsourcing.example.domainmodel) Example.Event (class in eventsourcing.example.domainmodel) Example.Heartbeat (class in eventsourcing.example.domainmodel) ExampleApplication (class in eventsourcing.example.application) ExampleRepository (class in eventsourcing.example.infrastructure)

F

foo (eventsourcing.example.domainmodel.Example attribute)

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

G

get_and_project_events() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method) get_domain_events() (eventsourcing.infrastructure.base.AbstractEventStore method) get_entity() (eventsourcing.infrastructure.base.AbstractEntityRepository method) (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method) get_event() (eventsourcing.infrastructure.base.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) get_example_application() (in module eventsourcing.example.application) get_item() (eventsourcing.infrastructure.base.AbstractRecordManager method) (eventsourcing.infrastructure.base.BaseRecordManager method) get_items() (eventsourcing.application.notificationlog.BigArrayNotificationLog method) (eventsourcing.application.notificationlog.LocalNotificationLog method) (eventsourcing.application.notificationlog.RecordManagerNotificationLog method) (eventsourcing.infrastructure.base.AbstractRecordManager method) (eventsourcing.infrastructure.base.BaseRecordManager method) get_last_array() (eventsourcing.domain.model.array.BigArray method) get_max_notification_id() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.popo.manager.PopoRecordManager 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.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_notifications() (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_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository method) get_pipeline_and_notification_id() (eventsourcing.infrastructure.base.ACIDRecordManager method) get_record() (eventsourcing.infrastructure.base.AbstractRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.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)

H

handle_prompts() (eventsourcing.system.runner.InProcessRunner method) (eventsourcing.system.runner.MultiThreadedRunner method) (eventsourcing.system.runner.SingleThreadedRunner method) (eventsourcing.system.runner.SteppingMultiThreadedRunner method) (eventsourcing.system.runner.SteppingSingleThreadedRunner method)

has_tracking_record() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.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.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) IntegerSequencedItem (class in eventsourcing.example.interface.flaskapp)

IntegerSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) IntegerSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (in module eventsourcing.infrastructure.sqlalchemy.records) IntegerSequencedRecord.DoesNotExist, [1] IntegerSequencedRecord.MultipleObjectsReturned, [1] IntegerSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) item_from_event() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method) ItemAssigned (class in eventsourcing.domain.model.array) items_from_events() (eventsourcing.infrastructure.base.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) iter_events() (eventsourcing.infrastructure.base.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute)

J

json_dumps() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)

json_loads() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method) (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)

L

list_events() (eventsourcing.infrastructure.base.AbstractEventStore method) list_items() (eventsourcing.infrastructure.base.BaseRecordManager method)

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

M

make_placeholder() (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method) MessageLogged (class in eventsourcing.domain.model.timebucketedlog) MetaDomainEntity (class in eventsourcing.domain.model.entity) MismatchedOriginatorError 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)

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

O

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

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

P

persist_event_type (eventsourcing.application.command.CommandProcess attribute) PersistencePolicy (class in eventsourcing.application.policies) Pipeable (class in eventsourcing.application.pipeline) PipeableMetaclass (class in eventsourcing.application.pipeline) PipelineActor (class in eventsourcing.system.actors) PipelineExpression (class in eventsourcing.application.pipeline) policy() (eventsourcing.application.process.ProcessApplication method) PopoApplication (class in eventsourcing.application.popo) PopoInfrastructureFactory (class in eventsourcing.infrastructure.popo.factory) PopoRecordManager (class in eventsourcing.infrastructure.popo.manager) PopoStoredEventRecord (class in eventsourcing.infrastructure.popo.manager) position (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) present_resource() (eventsourcing.interface.notificationlog.NotificationLogView method) ProcessApplication (class in eventsourcing.application.process) ProcessApplicationWithSnapshotting (class in eventsourcing.application.process)

ProcessEvent (class in eventsourcing.application.process) ProcessMaster (class in eventsourcing.system.actors) ProcessRunningClockThread (class in eventsourcing.system.runner) ProcessSlave (class in eventsourcing.system.actors) ProgrammingError project_events() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method) Prompt (class in eventsourcing.application.process) PromptFailed PromptOutbox (class in eventsourcing.system.runner) PromptQueuedApplicationThread (class in eventsourcing.system.runner) PromptToPull (class in eventsourcing.application.process) PromptToQuit (class in eventsourcing.application.process) publish() (in module eventsourcing.domain.model.events) publish_prompt() (eventsourcing.application.process.ProcessApplication method) put() (eventsourcing.system.runner.PromptOutbox method)

R

random_bytes() (in module eventsourcing.utils.random) read_items() (eventsourcing.application.notificationlog.NotificationLogReader method) read_list() (eventsourcing.application.notificationlog.NotificationLogReader method) receiveMessage() (eventsourcing.system.actors.PipelineActor method) (eventsourcing.system.actors.ProcessMaster method) (eventsourcing.system.actors.ProcessSlave method) (eventsourcing.system.actors.SystemActor method) record_class (eventsourcing.infrastructure.base.AbstractRecordManager attribute) (eventsourcing.infrastructure.base.BaseRecordManager attribute) record_item() (eventsourcing.infrastructure.base.AbstractRecordManager method) record_items() (eventsourcing.infrastructure.base.AbstractRecordManager method) (eventsourcing.infrastructure.base.SQLRecordManager method) (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method) (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)

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

S

save_orm_obj() (eventsourcing.application.process.WrappedRepository method) Section (class in eventsourcing.application.notificationlog) section_size (eventsourcing.application.notificationlog.AbstractNotificationLog attribute) (eventsourcing.application.notificationlog.LocalNotificationLog attribute) (eventsourcing.interface.notificationlog.RemoteNotificationLog attribute) seek() (eventsourcing.application.notificationlog.NotificationLogReader method) sequence_id (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) sequenced_item_class (eventsourcing.infrastructure.factory.InfrastructureFactory attribute) sequenced_item_mapper_class (eventsourcing.application.popo.PopoApplication attribute) (eventsourcing.infrastructure.factory.InfrastructureFactory attribute) SequencedItem (class in eventsourcing.infrastructure.sequenceditem) SequencedItemIterator (class in eventsourcing.infrastructure.iterators) SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper) SequencedItemMapperForPopo (class in eventsourcing.infrastructure.popo.mapper) 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.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) SnapshotRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) SnapshotRecord.DoesNotExist, [1] SnapshotRecord.MultipleObjectsReturned, [1]

SnapshottingApplication (class in eventsourcing.application.snapshotting) SnapshottingPolicy (class in eventsourcing.application.policies) SQLAlchemyApplication (class in eventsourcing.application.sqlalchemy) SQLAlchemyDatastore (class in eventsourcing.infrastructure.sqlalchemy.datastore) SQLAlchemyInfrastructureFactory (class in eventsourcing.infrastructure.sqlalchemy.factory) SQLAlchemyRecordManager (class in eventsourcing.infrastructure.sqlalchemy.manager) SQLAlchemySettings (class in eventsourcing.infrastructure.sqlalchemy.datastore) SQLRecordManager (class in eventsourcing.infrastructure.base) start() (eventsourcing.system.actors.ActorModelRunner method) (eventsourcing.system.definition.AbstractSystemRunner method) (eventsourcing.system.multiprocess.MultiprocessRunner method) (eventsourcing.system.runner.InProcessRunner method) (eventsourcing.system.runner.MultiThreadedRunner method) (eventsourcing.system.runner.SteppingMultiThreadedRunner method) (eventsourcing.system.runner.SteppingSingleThreadedRunner method) state (eventsourcing.domain.model.snapshot.Snapshot attribute) (eventsourcing.infrastructure.base.AbstractSnapshop attribute) (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute) SteppingMultiThreadedRunner (class in eventsourcing.system.runner) SteppingRunner (class in eventsourcing.system.runner) SteppingSingleThreadedRunner (class in eventsourcing.system.runner) store_events() (eventsourcing.infrastructure.base.AbstractEventStore method) (eventsourcing.infrastructure.eventstore.EventStore method) stored_event_record_class (eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute) StoredEvent (class in eventsourcing.infrastructure.sequenceditem) StoredEventRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (class in eventsourcing.infrastructure.sqlalchemy.records) StoredEventRecord.DoesNotExist, [1] StoredEventRecord.MultipleObjectsReturned, [1] subclassevents() (in module eventsourcing.domain.model.decorators) subrepo (eventsourcing.domain.model.array.AbstractBigArrayRepository attribute) (eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute) subrepo_class (eventsourcing.infrastructure.repositories.array.BigArrayRepository attribute) subscribe() (in module eventsourcing.domain.model.events) subscribe_to() (in module eventsourcing.domain.model.decorators) System (class in eventsourcing.system.definition) SystemActor (class in eventsourcing.system.actors)

T

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

TimestampedVersionedEntity.Discarded (class in eventsourcing.domain.model.entity) TimestampedVersionedEntity.Event (class in eventsourcing.domain.model.entity) TimestampSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) TimestampSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) (class in eventsourcing.infrastructure.django.models) (in module eventsourcing.infrastructure.sqlalchemy.records) TimestampSequencedRecord.DoesNotExist, [1] TimestampSequencedRecord.MultipleObjectsReturned, [1] TimestampSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records) TimeuuidedEntity (class in eventsourcing.domain.model.entity) TimeuuidedVersionedEntity (class in eventsourcing.domain.model.entity) TimeuuidSequencedRecord (class in eventsourcing.infrastructure.cassandra.records) TimeuuidSequencedRecord.DoesNotExist TimeuuidSequencedRecord.MultipleObjectsReturned to_record() (eventsourcing.infrastructure.base.BaseRecordManager method) topic (eventsourcing.domain.model.snapshot.Snapshot attribute) (eventsourcing.infrastructure.base.AbstractSnapshop attribute) (eventsourcing.infrastructure.sequenceditem.SequencedItem attribute) (eventsourcing.infrastructure.sequenceditem.StoredEvent attribute) TopicResolutionError tracking_record_class (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute) TrackingRecordNotFound truncate_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method) (eventsourcing.infrastructure.datastore.AbstractDatastore method) (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)

U

unsubscribe() (in module eventsourcing.domain.model.events)

V

VersionedEntity (class in eventsourcing.domain.model.entity) VersionedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)

VersionedEntity.Created (class in eventsourcing.domain.model.entity) VersionedEntity.Discarded (class in eventsourcing.domain.model.entity) VersionedEntity.Event (class in eventsourcing.domain.model.entity)

W

WrappedRepository (class in eventsourcing.application.process) write_records() (eventsourcing.infrastructure.base.ACIDRecordManager method) (eventsourcing.infrastructure.django.manager.DjangoRecordManager method) (eventsourcing.infrastructure.popo.manager.PopoRecordManager method) (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)