eventsourcing
v7.1.0
Introduction
Quick start
Design
Features
Installation
Infrastructure layer
Domain model layer
Application layer
Notifications
Projections
Distributed systems
Snapshotting
Deployment
Stand-alone example
Background
Release notes
Module docs
eventsourcing
Docs
»
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__abstractmethods__ (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
__assert_not_discarded__() (eventsourcing.domain.model.entity.DomainEntity method)
__batch_pending_events__() (eventsourcing.domain.model.aggregate.BaseAggregateRoot 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.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
__create__() (eventsourcing.domain.model.entity.DomainEntity class method)
(eventsourcing.domain.model.entity.EntityWithHashchain class method)
__created_on__ (eventsourcing.domain.model.entity.TimestampedEntity attribute)
(eventsourcing.domain.model.entity.TimeuuidedEntity attribute)
__dict__ (eventsourcing.domain.model.array.Array attribute)
(eventsourcing.domain.model.entity.AbstractEventPlayer attribute)
(eventsourcing.domain.model.entity.DomainEntity attribute)
(eventsourcing.domain.model.events.DomainEvent attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
__discard__() (eventsourcing.domain.model.entity.DomainEntity method)
__entity_kwargs__ (eventsourcing.domain.model.entity.DomainEntity.Created attribute)
(eventsourcing.domain.model.entity.EntityWithHashchain.Created attribute)
(eventsourcing.domain.model.entity.TimestampedEntity.Created attribute)
(eventsourcing.domain.model.entity.VersionedEntity.Created attribute)
__eq__() (eventsourcing.domain.model.array.Array method)
(eventsourcing.domain.model.entity.DomainEntity method)
(eventsourcing.domain.model.events.DomainEvent method)
__event_hash__ (eventsourcing.domain.model.events.EventWithHash attribute)
__genesis_hash__ (eventsourcing.domain.model.entity.EntityWithHashchain attribute)
__getitem__() (eventsourcing.domain.model.array.AbstractArrayRepository method)
(eventsourcing.domain.model.array.AbstractBigArrayRepository method)
(eventsourcing.domain.model.array.Array method)
(eventsourcing.domain.model.array.BigArray method)
(eventsourcing.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
(eventsourcing.interface.notificationlog.AbstractNotificationLog method)
__getnewargs__() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
__hash__ (eventsourcing.domain.model.array.Array attribute)
(eventsourcing.domain.model.entity.DomainEntity attribute)
__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.system.System method)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot method)
(eventsourcing.domain.model.array.AbstractArrayRepository method)
(eventsourcing.domain.model.array.Array 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.entity.DomainEntity method)
(eventsourcing.domain.model.entity.DomainEntity.Created method)
(eventsourcing.domain.model.entity.EntityWithHashchain method)
(eventsourcing.domain.model.entity.TimestampedEntity method)
(eventsourcing.domain.model.entity.TimeuuidedEntity method)
(eventsourcing.domain.model.entity.VersionedEntity method)
(eventsourcing.domain.model.entity.VersionedEntity.Created 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.interface.flaskapp.IntegerSequencedItem method)
(eventsourcing.infrastructure.eventstore.EventStore 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.utils.cipher.aes.AESCipher method)
__iter__() (eventsourcing.domain.model.collection.Collection method)
(eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
(eventsourcing.infrastructure.iterators.SequencedItemIterator method)
__json_encoder_class__ (eventsourcing.domain.model.events.DomainEvent attribute)
__last_modified__ (eventsourcing.domain.model.entity.TimestampedEntity attribute)
(eventsourcing.domain.model.entity.TimeuuidedEntity attribute)
__len__() (eventsourcing.domain.model.array.Array method)
(eventsourcing.domain.model.array.BigArray method)
__module__ (eventsourcing.domain.model.aggregate.AggregateRoot attribute)
(eventsourcing.domain.model.aggregate.AggregateRoot.AttributeChanged attribute)
(eventsourcing.domain.model.aggregate.AggregateRoot.Created attribute)
(eventsourcing.domain.model.aggregate.AggregateRoot.Discarded attribute)
(eventsourcing.domain.model.aggregate.AggregateRoot.Event attribute)
(eventsourcing.domain.model.aggregate.AggregateRootWithHashchainedEvents attribute)
(eventsourcing.domain.model.aggregate.AggregateRootWithHashchainedEvents.AttributeChanged attribute)
(eventsourcing.domain.model.aggregate.AggregateRootWithHashchainedEvents.Created attribute)
(eventsourcing.domain.model.aggregate.AggregateRootWithHashchainedEvents.Discarded attribute)
(eventsourcing.domain.model.aggregate.AggregateRootWithHashchainedEvents.Event attribute)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot attribute)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot.AttributeChanged attribute)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot.Created attribute)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot.Discarded attribute)
(eventsourcing.domain.model.aggregate.BaseAggregateRoot.Event attribute)
(eventsourcing.domain.model.array.AbstractArrayRepository attribute)
(eventsourcing.domain.model.array.AbstractBigArrayRepository attribute)
(eventsourcing.domain.model.array.Array attribute)
(eventsourcing.domain.model.array.BigArray attribute)
(eventsourcing.domain.model.array.ItemAssigned attribute)
(eventsourcing.domain.model.collection.AbstractCollectionRepository attribute)
(eventsourcing.domain.model.collection.Collection attribute)
(eventsourcing.domain.model.collection.Collection.Created attribute)
(eventsourcing.domain.model.collection.Collection.Discarded attribute)
(eventsourcing.domain.model.collection.Collection.Event attribute)
(eventsourcing.domain.model.collection.Collection.EventWithItem attribute)
(eventsourcing.domain.model.collection.Collection.ItemAdded attribute)
(eventsourcing.domain.model.collection.Collection.ItemRemoved attribute)
(eventsourcing.domain.model.command.Command attribute)
(eventsourcing.domain.model.command.Command.AttributeChanged attribute)
(eventsourcing.domain.model.command.Command.Created attribute)
(eventsourcing.domain.model.command.Command.Discarded attribute)
(eventsourcing.domain.model.command.Command.Done attribute)
(eventsourcing.domain.model.command.Command.Event attribute)
(eventsourcing.domain.model.entity.AbstractEntityRepository attribute)
(eventsourcing.domain.model.entity.AbstractEventPlayer attribute)
(eventsourcing.domain.model.entity.DomainEntity attribute)
(eventsourcing.domain.model.entity.DomainEntity.AttributeChanged attribute)
(eventsourcing.domain.model.entity.DomainEntity.Created attribute)
(eventsourcing.domain.model.entity.DomainEntity.Discarded attribute)
(eventsourcing.domain.model.entity.DomainEntity.Event attribute)
(eventsourcing.domain.model.entity.EntityWithHashchain attribute)
(eventsourcing.domain.model.entity.EntityWithHashchain.Created attribute)
(eventsourcing.domain.model.entity.EntityWithHashchain.Discarded attribute)
(eventsourcing.domain.model.entity.EntityWithHashchain.Event attribute)
(eventsourcing.domain.model.entity.TimestampedEntity attribute)
(eventsourcing.domain.model.entity.TimestampedEntity.AttributeChanged attribute)
(eventsourcing.domain.model.entity.TimestampedEntity.Created attribute)
(eventsourcing.domain.model.entity.TimestampedEntity.Discarded attribute)
(eventsourcing.domain.model.entity.TimestampedEntity.Event attribute)
(eventsourcing.domain.model.entity.TimestampedVersionedEntity attribute)
(eventsourcing.domain.model.entity.TimestampedVersionedEntity.AttributeChanged attribute)
(eventsourcing.domain.model.entity.TimestampedVersionedEntity.Created attribute)
(eventsourcing.domain.model.entity.TimestampedVersionedEntity.Discarded attribute)
(eventsourcing.domain.model.entity.TimestampedVersionedEntity.Event attribute)
(eventsourcing.domain.model.entity.TimeuuidedEntity attribute)
(eventsourcing.domain.model.entity.TimeuuidedVersionedEntity attribute)
(eventsourcing.domain.model.entity.VersionedEntity attribute)
(eventsourcing.domain.model.entity.VersionedEntity.AttributeChanged attribute)
(eventsourcing.domain.model.entity.VersionedEntity.Created attribute)
(eventsourcing.domain.model.entity.VersionedEntity.Discarded attribute)
(eventsourcing.domain.model.entity.VersionedEntity.Event attribute)
(eventsourcing.domain.model.events.AttributeChanged attribute)
(eventsourcing.domain.model.events.Created attribute)
(eventsourcing.domain.model.events.Discarded attribute)
(eventsourcing.domain.model.events.DomainEvent attribute)
(eventsourcing.domain.model.events.EventHandlersNotEmptyError attribute)
(eventsourcing.domain.model.events.EventWithHash attribute)
(eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.domain.model.events.EventWithOriginatorVersion attribute)
(eventsourcing.domain.model.events.EventWithTimestamp attribute)
(eventsourcing.domain.model.events.EventWithTimeuuid attribute)
(eventsourcing.domain.model.events.Logged attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.domain.model.timebucketedlog.MessageLogged attribute)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog attribute)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog.BucketSizeChanged attribute)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog.Event attribute)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog.Started attribute)
(eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository attribute)
__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.DomainEntity.Event 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.array.Array method)
(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)
__notifiable__ (eventsourcing.domain.model.events.DomainEvent attribute)
__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.Array method)
(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)
__version__ (eventsourcing.domain.model.entity.VersionedEntity attribute)
__weakref__ (eventsourcing.domain.model.array.Array attribute)
(eventsourcing.domain.model.entity.AbstractEventPlayer attribute)
(eventsourcing.domain.model.entity.DomainEntity attribute)
(eventsourcing.domain.model.events.DomainEvent attribute)
(eventsourcing.domain.model.events.EventHandlersNotEmptyError attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
_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)
abort() (eventsourcing.application.system.BarrierControlledApplicationThread method)
AbstractArrayRepository (class in eventsourcing.domain.model.array)
AbstractBigArrayRepository (class in eventsourcing.domain.model.array)
AbstractCollectionRepository (class in eventsourcing.domain.model.collection)
AbstractEntityRepository (class in eventsourcing.domain.model.entity)
AbstractEventPlayer (class in eventsourcing.domain.model.entity)
AbstractEventStore (class in eventsourcing.infrastructure.eventstore)
AbstractExampleRepository (class in eventsourcing.example.domainmodel)
AbstractIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base)
AbstractNotificationLog (class in eventsourcing.interface.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)
actor_system (eventsourcing.application.actors.ActorModelRunner attribute)
ActorModelRunner (class in eventsourcing.application.actors)
actual_clock_speed (eventsourcing.application.system.BarrierControllingClockThread attribute)
(eventsourcing.application.system.ProcessRunningClockThread attribute)
add_item() (eventsourcing.domain.model.collection.Collection method)
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)
append() (eventsourcing.domain.model.array.Array method)
application_name (eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
ApplicationWithConcreteInfrastructure (class in eventsourcing.application.simple)
ApplicationWithEventStores (class in eventsourcing.example.application)
ApplicationWithPersistencePolicies (class in eventsourcing.example.application)
Array (class in eventsourcing.domain.model.array)
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)
beat_heart() (eventsourcing.example.domainmodel.Example method)
BigArray (class in eventsourcing.domain.model.array)
BigArrayNotificationLog (class in eventsourcing.interface.notificationlog)
BigArrayRepository (class in eventsourcing.infrastructure.repositories.array)
bind() (eventsourcing.application.simple.SimpleApplication class method)
broadcast_prompt() (eventsourcing.application.multiprocess.MultiprocessRunner method)
(eventsourcing.application.multiprocess.OperatingSystemProcess method)
(eventsourcing.application.system.MultiThreadedRunner method)
bucket_duration() (in module eventsourcing.domain.model.timebucketedlog)
bucket_size (eventsourcing.domain.model.timebucketedlog.Timebucketedlog attribute)
bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
C
calc_parent() (eventsourcing.domain.model.array.BigArray method)
calc_required_height() (eventsourcing.domain.model.array.BigArray method)
call_commands() (eventsourcing.application.system.ClockThread method)
call_in_future() (eventsourcing.application.system.ClockThread method)
(eventsourcing.application.system.SteppingRunner method)
call_policy() (eventsourcing.application.process.ProcessApplication 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)
causal_dependencies (eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
CausalDependencyFailed
change_pipeline() (eventsourcing.application.simple.SimpleApplication method)
clear_event_handlers() (in module eventsourcing.domain.model.events)
ClockThread (class in eventsourcing.application.system)
clone() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
close() (eventsourcing.application.actors.ActorModelRunner method)
(eventsourcing.application.actors.ProcessSlave method)
(eventsourcing.application.multiprocess.MultiprocessRunner method)
(eventsourcing.application.policies.PersistencePolicy method)
(eventsourcing.application.policies.SnapshottingPolicy method)
(eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication 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)
(eventsourcing.example.application.ApplicationWithEventStores method)
(eventsourcing.example.application.ApplicationWithPersistencePolicies method)
close_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
close_django_connection() (in module eventsourcing.infrastructure.django.utils)
close_example_application() (in module eventsourcing.example.application)
collect_pending_events() (eventsourcing.application.process.ProcessApplication method)
Collection (class in eventsourcing.domain.model.collection)
Collection.Created (class in eventsourcing.domain.model.collection)
Collection.Discarded (class in eventsourcing.domain.model.collection)
Collection.Event (class in eventsourcing.domain.model.collection)
Collection.EventWithItem (class in eventsourcing.domain.model.collection)
Collection.ItemAdded (class in eventsourcing.domain.model.collection)
Collection.ItemRemoved (class in eventsourcing.domain.model.collection)
CollectionRepository (class in eventsourcing.infrastructure.repositories.collection_repo)
Command (class in eventsourcing.domain.model.command)
Command.AttributeChanged (class in eventsourcing.domain.model.command)
Command.Created (class in eventsourcing.domain.model.command)
Command.Discarded (class in eventsourcing.domain.model.command)
Command.Done (class in eventsourcing.domain.model.command)
Command.Event (class in eventsourcing.domain.model.command)
CommandProcess (class in eventsourcing.application.command)
ConcurrencyError
condition() (eventsourcing.application.policies.SnapshottingPolicy method)
CONSISTENCY_LEVEL (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
ConsistencyError
construct_app() (eventsourcing.application.system.System method)
construct_cipher() (eventsourcing.application.simple.SimpleApplication method)
construct_datastore() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_entity_persistence_policy() (eventsourcing.example.application.ApplicationWithPersistencePolicies method)
construct_event_records() (eventsourcing.application.process.ProcessApplication method)
construct_event_store() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(eventsourcing.example.application.ApplicationWithEventStores method)
construct_example_application() (in module eventsourcing.example.application)
construct_infrastructure() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication method)
construct_infrastructure_factory() (eventsourcing.application.simple.SimpleApplication method)
construct_item_args() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
construct_log_persistence_policy() (eventsourcing.example.application.ApplicationWithPersistencePolicies 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.sqlalchemy.factory.SQLAlchemyInfrastructureFactory method)
construct_repository() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
construct_sequenced_item() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
construct_sequenced_item_mapper() (eventsourcing.example.application.ApplicationWithEventStores method)
construct_snapshot_persistence_policy() (eventsourcing.example.application.ApplicationWithPersistencePolicies method)
construct_sqlalchemy_eventstore() (in module eventsourcing.infrastructure.sqlalchemy.factory)
construct_tracking_kwargs() (eventsourcing.application.process.ProcessApplication method)
consume_prompt() (eventsourcing.application.actors.ProcessMaster method)
count_heartbeats() (eventsourcing.example.domainmodel.Example method)
create_array_id() (eventsourcing.domain.model.array.BigArray method)
create_new_example() (eventsourcing.example.application.ExampleApplication method)
(in module eventsourcing.example.domainmodel)
create_timesequenced_event_id() (in module eventsourcing.domain.model.events)
Created (class in eventsourcing.domain.model.events)
D
DataIntegrityError
DatasourceSettingsError
Datastore (class in eventsourcing.infrastructure.datastore)
datastore (eventsourcing.application.simple.SimpleApplication attribute)
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)
decrypt() (eventsourcing.utils.cipher.aes.AESCipher method)
default() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
DEFAULT_KEYSPACE (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
DEFAULT_PAGE_SIZE (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator attribute)
del_notification_generator() (eventsourcing.application.process.ProcessApplication 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)
deserialize_section() (eventsourcing.interface.notificationlog.RemoteNotificationLog 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)
done() (eventsourcing.domain.model.command.Command method)
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.sqlalchemy.datastore.SQLAlchemyDatastore method)
drop_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
E
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.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_from_topic_and_state() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
event_id (eventsourcing.domain.model.events.EventWithTimeuuid attribute)
event_store (eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.domain.model.entity.AbstractEntityRepository attribute)
(eventsourcing.infrastructure.eventplayer.EventPlayer attribute)
event_store_class (eventsourcing.application.simple.SimpleApplication attribute)
EventHandlersNotEmptyError
EventHashError
EventPlayer (class in eventsourcing.infrastructure.eventplayer)
EventRecordNotFound
EventSourcedRepository (class in eventsourcing.infrastructure.eventsourcedrepository)
EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
eventsourcing.application.actors (module)
eventsourcing.application.command (module)
eventsourcing.application.django (module)
eventsourcing.application.multiprocess (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)
eventsourcing.domain.model.array (module)
eventsourcing.domain.model.collection (module)
eventsourcing.domain.model.command (module)
eventsourcing.domain.model.decorators (module)
eventsourcing.domain.model.entity (module)
eventsourcing.domain.model.events (module)
eventsourcing.domain.model.snapshot (module)
eventsourcing.domain.model.timebucketedlog (module)
eventsourcing.example.application (module)
eventsourcing.example.domainmodel (module)
eventsourcing.example.infrastructure (module)
eventsourcing.example.interface.flaskapp (module)
eventsourcing.exceptions (module)
eventsourcing.infrastructure.base (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)
eventsourcing.infrastructure.django.factory (module)
eventsourcing.infrastructure.django.manager (module)
eventsourcing.infrastructure.django.models (module)
eventsourcing.infrastructure.django.utils (module)
eventsourcing.infrastructure.eventplayer (module)
eventsourcing.infrastructure.eventsourcedrepository (module)
eventsourcing.infrastructure.eventstore (module)
eventsourcing.infrastructure.integersequencegenerators.base (module)
eventsourcing.infrastructure.integersequencegenerators.redisincr (module)
eventsourcing.infrastructure.iterators (module)
eventsourcing.infrastructure.repositories.array (module)
eventsourcing.infrastructure.repositories.collection_repo (module)
eventsourcing.infrastructure.repositories.timebucketedlog_repo (module)
eventsourcing.infrastructure.sequenceditem (module)
eventsourcing.infrastructure.sequenceditemmapper (module)
eventsourcing.infrastructure.snapshotting (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)
eventsourcing.interface.notificationlog (module)
eventsourcing.utils.cipher.aes (module)
eventsourcing.utils.times (module)
eventsourcing.utils.topic (module)
eventsourcing.utils.transcoding (module)
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
filter() (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
filter_by() (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
follow() (eventsourcing.application.process.ProcessApplication method)
foo (eventsourcing.example.domainmodel.Example attribute)
format_section_id() (eventsourcing.interface.notificationlog.LocalNotificationLog static method)
forward_prompt() (eventsourcing.application.actors.ActorModelRunner method)
(eventsourcing.application.actors.PipelineActor method)
from_jsonable() (eventsourcing.utils.transcoding.ObjectJSONDecoder class method)
from_record() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
G
get_and_project_events() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
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_entity() (eventsourcing.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
get_event_class_and_attrs() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
get_event_from_notification() (eventsourcing.application.process.ProcessApplication method)
get_events() (eventsourcing.infrastructure.timebucketedlog_reader.TimebucketedlogReader method)
get_example_application() (in module eventsourcing.example.application)
get_field_kwargs() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
get_item() (eventsourcing.domain.model.array.BigArray method)
(eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
get_item_assigned() (eventsourcing.domain.model.array.Array method)
get_item_topic_and_state() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
get_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
(eventsourcing.interface.notificationlog.BigArrayNotificationLog method)
(eventsourcing.interface.notificationlog.LocalNotificationLog method)
(eventsourcing.interface.notificationlog.RecordManagerNotificationLog method)
get_items_assigned() (eventsourcing.domain.model.array.Array method)
get_json() (eventsourcing.interface.notificationlog.RemoteNotificationLog method)
get_last_array() (eventsourcing.domain.model.array.BigArray method)
get_last_item_and_next_position() (eventsourcing.domain.model.array.Array method)
(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_messages() (eventsourcing.infrastructure.timebucketedlog_reader.TimebucketedlogReader method)
get_most_recent_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_next_position() (eventsourcing.domain.model.array.Array method)
(eventsourcing.interface.notificationlog.BigArrayNotificationLog method)
(eventsourcing.interface.notificationlog.LocalNotificationLog method)
(eventsourcing.interface.notificationlog.RecordManagerNotificationLog method)
get_notification_generator() (eventsourcing.application.process.ProcessApplication 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_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository 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_resource() (eventsourcing.interface.notificationlog.RemoteNotificationLog method)
get_slice() (eventsourcing.domain.model.array.BigArray 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)
handle_slave_run_response() (eventsourcing.application.actors.ProcessMaster method)
has_tracking_record() (eventsourcing.infrastructure.base.ACIDRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
HeadHashError
hello() (in module eventsourcing.example.interface.flaskapp)
HOSTS (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
I
id (eventsourcing.domain.model.entity.DomainEntity attribute)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord attribute)
index (eventsourcing.domain.model.array.ItemAssigned attribute)
infrastructure_factory_class (eventsourcing.application.popo.PopoApplication attribute)
(eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute)
init_example_application() (in module eventsourcing.example.application)
init_example_application_with_sqlalchemy() (in module eventsourcing.example.interface.flaskapp)
init_pipeline() (eventsourcing.application.actors.PipelineActor method)
init_pipelines() (eventsourcing.application.actors.SystemActor method)
init_process() (eventsourcing.application.actors.ProcessMaster method)
(eventsourcing.application.actors.ProcessSlave method)
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_constructed_with_session (eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.application.sqlalchemy.SQLAlchemyApplication attribute)
is_done (eventsourcing.domain.model.command.Command attribute)
is_event() (eventsourcing.application.policies.PersistencePolicy method)
is_my_prompt() (eventsourcing.application.actors.ProcessSlave method)
is_prompt() (eventsourcing.application.actors.ActorModelRunner static method)
(eventsourcing.application.multiprocess.MultiprocessRunner static method)
(eventsourcing.application.multiprocess.OperatingSystemProcess static method)
(eventsourcing.application.system.System method)
is_sqlite() (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
item (eventsourcing.domain.model.array.ItemAssigned attribute)
(eventsourcing.domain.model.collection.Collection.EventWithItem attribute)
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)
items (eventsourcing.domain.model.collection.Collection attribute)
iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute)
iterencode() (eventsourcing.utils.transcoding.ObjectJSONEncoder method)
J
json_decoder_class (eventsourcing.application.simple.SimpleApplication attribute)
json_dumps() (in module eventsourcing.utils.transcoding)
json_encoder_class (eventsourcing.application.simple.SimpleApplication attribute)
json_loads() (in module eventsourcing.utils.transcoding)
L
list_items() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
list_sequence_ids() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
LocalNotificationLog (class in eventsourcing.interface.notificationlog)
log_message() (eventsourcing.domain.model.timebucketedlog.Timebucketedlog method)
Logged (class in eventsourcing.domain.model.events)
loop_on_prompts() (eventsourcing.application.multiprocess.OperatingSystemProcess method)
(eventsourcing.application.system.PromptQueuedApplicationThread method)
M
make_notification_log_url() (eventsourcing.interface.notificationlog.RemoteNotificationLog method)
make_timebucket_id() (in module eventsourcing.domain.model.timebucketedlog)
message (eventsourcing.domain.model.timebucketedlog.MessageLogged attribute)
MessageLogged (class in eventsourcing.domain.model.timebucketedlog)
MismatchedOriginatorError
mixin() (eventsourcing.application.simple.SimpleApplication class method)
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)
(eventsourcing.infrastructure.eventplayer.EventPlayer static method)
mutator() (in module eventsourcing.domain.model.decorators)
MutatorRequiresTypeNotInstance
N
name (eventsourcing.domain.model.events.AttributeChanged attribute)
(eventsourcing.domain.model.timebucketedlog.Timebucketedlog attribute)
next_bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
notification_id (eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
notification_log_section_size (eventsourcing.application.simple.SimpleApplication attribute)
NotificationLogReader (class in eventsourcing.interface.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)
objects (eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
OperatingSystemProcess (class in eventsourcing.application.multiprocess)
OperationalError
originator_id (eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.infrastructure.cassandra.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord 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.cassandra.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
OriginatorIDError
OriginatorVersionError
orm_query() (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
other_names (eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
P
persist_event_type (eventsourcing.application.command.CommandProcess attribute)
(eventsourcing.application.simple.SimpleApplication attribute)
PersistencePolicy (class in eventsourcing.application.policies)
Pipeable (class in eventsourcing.application.pipeline)
PipeableMetaclass (class in eventsourcing.application.pipeline)
pipeline_id (eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
PipelineActor (class in eventsourcing.application.actors)
PipelineExpression (class in eventsourcing.application.pipeline)
PipelineInitRequest (class in eventsourcing.application.actors)
pk (eventsourcing.infrastructure.cassandra.records.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimeuuidSequencedRecord attribute)
policy() (eventsourcing.application.process.ProcessApplication static method)
PopoApplication (class in eventsourcing.application.popo)
PORT (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
position (eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.records.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimeuuidSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord attribute)
present_section() (eventsourcing.interface.notificationlog.NotificationLogView method)
previous_bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
process_upstream_event() (eventsourcing.application.process.ProcessApplication method)
ProcessApplication (class in eventsourcing.application.process)
ProcessApplicationWithSnapshotting (class in eventsourcing.application.process)
ProcessEvent (class in eventsourcing.application.process)
ProcessInitRequest (class in eventsourcing.application.actors)
ProcessMaster (class in eventsourcing.application.actors)
ProcessRunningClockThread (class in eventsourcing.application.system)
ProcessSlave (class in eventsourcing.application.actors)
ProgrammingError
project_events() (eventsourcing.infrastructure.eventplayer.EventPlayer method)
Prompt (class in eventsourcing.application.process)
PromptFailed
PromptOutbox (class in eventsourcing.application.system)
PromptQueuedApplicationThread (class in eventsourcing.application.system)
PROTOCOL_VERSION (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
publish() (in module eventsourcing.domain.model.events)
publish_prompt() (eventsourcing.application.process.ProcessApplication method)
put() (eventsourcing.application.system.PromptOutbox method)
R
raise_index_error() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
raise_operational_error() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
raise_record_integrity_error() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
raise_sequenced_item_conflict() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager method)
random() (in module eventsourcing.domain.model.decorators)
read() (eventsourcing.interface.notificationlog.NotificationLogReader method)
read_items() (eventsourcing.interface.notificationlog.NotificationLogReader method)
read_list() (eventsourcing.interface.notificationlog.NotificationLogReader method)
read_reader() (eventsourcing.application.process.ProcessApplication method)
receiveMessage() (eventsourcing.application.actors.PipelineActor method)
(eventsourcing.application.actors.ProcessMaster method)
(eventsourcing.application.actors.ProcessSlave method)
(eventsourcing.application.actors.SystemActor method)
reconstruct_object() (in module eventsourcing.infrastructure.sequenceditemmapper)
record_manager_class (eventsourcing.application.django.DjangoApplication attribute)
(eventsourcing.application.simple.SimpleApplication attribute)
(eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.django.factory.DjangoInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
record_process_event() (eventsourcing.application.process.ProcessApplication method)
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.interface.notificationlog)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
register_new_collection() (in module eventsourcing.domain.model.collection)
RemoteNotificationLog (class in eventsourcing.interface.notificationlog)
remove_item() (eventsourcing.domain.model.collection.Collection method)
REPLICATION_FACTOR (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
repository (eventsourcing.application.simple.SimpleApplication attribute)
repository_class (eventsourcing.application.simple.SimpleApplication attribute)
RepositoryKeyError
RepositoryWrapper (class in eventsourcing.application.process)
reset_connection_after_forking() (eventsourcing.application.django.DjangoApplication class method)
(eventsourcing.application.simple.SimpleApplication 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.process.ProcessApplication 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)
run_process() (eventsourcing.application.actors.ProcessSlave method)
(eventsourcing.application.multiprocess.OperatingSystemProcess method)
(eventsourcing.application.system.PromptQueuedApplicationThread method)
run_slave() (eventsourcing.application.actors.ProcessMaster method)
S
Section (class in eventsourcing.interface.notificationlog)
seek() (eventsourcing.interface.notificationlog.NotificationLogReader method)
send_prompt() (eventsourcing.application.actors.ProcessSlave method)
sequence_id (eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.records.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimeuuidSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord attribute)
sequenced_item_class (eventsourcing.application.simple.SimpleApplication attribute)
sequenced_item_mapper_class (eventsourcing.application.popo.PopoApplication attribute)
(eventsourcing.application.simple.SimpleApplication attribute)
SequencedItem (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemFieldNames (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemIterator (class in eventsourcing.infrastructure.iterators)
SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
session (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore attribute)
set_notification_ids (eventsourcing.application.process.ProcessApplication attribute)
set_reader_position_from_tracking_records() (eventsourcing.application.process.ProcessApplication method)
setup_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
setup_django() (in module eventsourcing.infrastructure.django.utils)
setup_table() (eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.snapshotting.SnapshottingApplication method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
setup_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
shutdown() (eventsourcing.application.actors.ActorModelRunner method)
shutdown_actor_system() (in module eventsourcing.application.actors)
SimpleApplication (class in eventsourcing.application.simple)
SimpleIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base)
SingleThreadedRunner (class in eventsourcing.application.system)
SlaveRunRequest (class in eventsourcing.application.actors)
SlaveRunResponse (class in eventsourcing.application.actors)
Snapshot (class in eventsourcing.domain.model.snapshot)
snapshot_period (eventsourcing.application.snapshotting.SnapshottingApplication attribute)
snapshot_record_class (eventsourcing.application.django.DjangoApplication attribute)
(eventsourcing.application.simple.SimpleApplication 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)
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.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)
start_actor_system() (in module eventsourcing.application.actors)
start_clock() (eventsourcing.application.system.MultiThreadedRunner method)
start_multiproc_tcp_base_system() (in module eventsourcing.application.actors)
start_new_timebucketedlog() (in module eventsourcing.domain.model.timebucketedlog)
start_thread() (eventsourcing.infrastructure.iterators.ThreadedSequencedItemIterator method)
started_on (eventsourcing.domain.model.timebucketedlog.Timebucketedlog attribute)
state (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.records.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimeuuidSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord 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)
store_event() (eventsourcing.application.policies.PersistencePolicy method)
stored_event_record_class (eventsourcing.application.django.DjangoApplication attribute)
(eventsourcing.application.popo.PopoApplication attribute)
(eventsourcing.application.simple.SimpleApplication 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)
SystemInitRequest (class in eventsourcing.application.actors)
SystemInitResponse (class in eventsourcing.application.actors)
SystemRunner (class in eventsourcing.application.system)
T
take_snapshot() (eventsourcing.application.policies.SnapshottingPolicy method)
(eventsourcing.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
(eventsourcing.infrastructure.snapshotting.AbstractSnapshotStrategy method)
(eventsourcing.infrastructure.snapshotting.EventSourcedSnapshotStrategy method)
take_snapshots() (eventsourcing.application.process.ProcessApplication method)
(eventsourcing.application.process.ProcessApplicationWithSnapshotting 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)
TimebucketedlogReader (class in eventsourcing.infrastructure.timebucketedlog_reader)
TimebucketedlogRepo (class in eventsourcing.infrastructure.repositories.timebucketedlog_repo)
TimebucketedlogRepository (class in eventsourcing.domain.model.timebucketedlog)
TimeSequenceError
timestamp (eventsourcing.domain.model.events.EventWithTimestamp attribute)
timestamp_from_datetime() (in module eventsourcing.domain.model.timebucketedlog)
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)
to_records() (eventsourcing.infrastructure.base.SQLRecordManager method)
topic (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.records.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.cassandra.records.TimeuuidSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.IntegerSequencedRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
(eventsourcing.infrastructure.django.models.TimestampSequencedRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedNoIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord attribute)
TopicResolutionError
tracking_record_class (eventsourcing.infrastructure.base.ACIDRecordManager attribute)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager attribute)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager attribute)
tracking_record_field_names (eventsourcing.infrastructure.base.ACIDRecordManager attribute)
TrackingRecordNotFound
truncate_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
U
uid (eventsourcing.infrastructure.django.models.EntitySnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.django.models.SnapshotRecord attribute)
(eventsourcing.infrastructure.django.models.StoredEventRecord attribute)
unsubscribe() (in module eventsourcing.domain.model.events)
upstream_application_name (eventsourcing.infrastructure.django.models.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
use_cache (eventsourcing.application.simple.SimpleApplication attribute)
use_causal_dependencies (eventsourcing.application.process.ProcessApplication attribute)
V
value (eventsourcing.domain.model.events.AttributeChanged attribute)
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)
Read the Docs
v: v7.1.0
Versions
latest
stable
v7.1.0
v7.0.0
v6.3.0
v6.2.0
v6.1.0
v6.0.0
v5.1.1
v5.1.0
v5.0.0
v4.0.0
v3.1.0
v3.0.0
Downloads
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.