eventsourcing
v4.0.0
Contents
Background
Quick start
Installation
Features
Design
Infrastructure
Domain model
Application
Snapshotting
Stand-alone example
Projections and notifications
Deployment
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
|
Q
|
R
|
S
|
T
|
U
|
V
_
__assert_not_discarded__() (eventsourcing.domain.model.entity.DomainEntity method)
__change_attribute__() (eventsourcing.domain.model.entity.DomainEntity method)
__check_obj__() (eventsourcing.domain.model.entity.DomainEntity.Event method)
(eventsourcing.domain.model.entity.VersionedEntity.Event method)
__contains__() (eventsourcing.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
__discard__() (eventsourcing.domain.model.entity.DomainEntity method)
__eq__() (eventsourcing.domain.model.events.DomainEvent method)
__getitem__() (eventsourcing.domain.model.array.AbstractArrayRepository method)
(eventsourcing.domain.model.array.AbstractBigArrayRepository method)
(eventsourcing.domain.model.array.Array 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.events.DomainEvent method)
__init__() (eventsourcing.domain.model.events.DomainEvent method)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem method)
(eventsourcing.infrastructure.eventstore.EventStore method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.IntegerSequencedItemRecord method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SnapshotRecord method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.StoredEventRecord method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord method)
(eventsourcing.utils.cipher.aes.AESCipher method)
__iter__() (eventsourcing.infrastructure.iterators.AbstractSequencedItemIterator method)
(eventsourcing.infrastructure.iterators.SequencedItemIterator method)
__len__() (eventsourcing.domain.model.array.Array method)
(eventsourcing.domain.model.array.BigArray method)
__mutate__() (eventsourcing.domain.model.entity.TimestampedEntity.Event method)
(eventsourcing.domain.model.events.DomainEvent method)
__ne__() (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)
__publish__() (eventsourcing.domain.model.aggregate.AggregateRoot 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.AggregateRoot method)
__setattr__() (eventsourcing.domain.model.events.DomainEvent method)
__setitem__() (eventsourcing.domain.model.array.Array method)
__trigger_event__() (eventsourcing.domain.model.entity.DomainEntity 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)
_replace() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
A
a (eventsourcing.example.domainmodel.Example attribute)
AbstractActiveRecordStrategy (class in eventsourcing.infrastructure.activerecord)
AbstractArrayRepository (class in eventsourcing.domain.model.array)
AbstractBigArrayRepository (class in eventsourcing.domain.model.array)
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)
AbstractSnapshop (class in eventsourcing.domain.model.snapshot)
AbstractSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
ActiveRecord (class in eventsourcing.infrastructure.cassandra.datastore)
ActiveRecord.DoesNotExist
ActiveRecord.MultipleObjectsReturned
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)
all_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
all_items() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
all_records() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
all_sequence_ids() (eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
append() (eventsourcing.domain.model.array.Array method)
(eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
append_message() (eventsourcing.domain.model.timebucketedlog.Timebucketedlog method)
ApplicationWithEventStores (class in eventsourcing.application.base)
ApplicationWithPersistencePolicies (class in eventsourcing.application.base)
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)
beat_heart() (eventsourcing.example.domainmodel.Example method)
BigArray (class in eventsourcing.domain.model.array)
BigArrayRepository (class in eventsourcing.infrastructure.repositories.array)
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)
CassandraActiveRecordStrategy (class in eventsourcing.infrastructure.cassandra.activerecords)
CassandraDatastore (class in eventsourcing.infrastructure.cassandra.datastore)
CassandraSettings (class in eventsourcing.infrastructure.cassandra.datastore)
close() (eventsourcing.application.base.ApplicationWithEventStores method)
(eventsourcing.application.base.ApplicationWithPersistencePolicies method)
(eventsourcing.application.policies.PersistencePolicy method)
(eventsourcing.application.policies.SnapshottingPolicy method)
(eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.simple.SnapshottingApplication method)
close_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
close_example_application() (in module eventsourcing.example.application)
CollectionRepository (class in eventsourcing.infrastructure.repositories.collection_repo)
ConcurrencyError
condition() (eventsourcing.application.policies.SnapshottingPolicy method)
CONSISTENCY_LEVEL (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
ConsistencyError
construct_entity_persistence_policy() (eventsourcing.application.base.ApplicationWithPersistencePolicies method)
construct_event_store() (eventsourcing.application.base.ApplicationWithEventStores method)
construct_example_application() (in module eventsourcing.example.application)
construct_item_args() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
construct_log_persistence_policy() (eventsourcing.application.base.ApplicationWithPersistencePolicies method)
construct_sequenced_item() (eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
construct_sequenced_item_mapper() (eventsourcing.application.base.ApplicationWithEventStores method)
construct_snapshot_persistence_policy() (eventsourcing.application.base.ApplicationWithPersistencePolicies method)
count_heartbeats() (eventsourcing.example.domainmodel.Example method)
CqlTimeuuidSequencedItem (class in eventsourcing.infrastructure.cassandra.activerecords)
CqlTimeuuidSequencedItem.DoesNotExist
CqlTimeuuidSequencedItem.MultipleObjectsReturned
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
data (eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.CqlTimeuuidSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.TimestampSequencedItemRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord attribute)
DataIntegrityError
DatasourceSettingsError
Datastore (class in eventsourcing.infrastructure.datastore)
DatastoreConnectionError
DatastoreError
DatastoreSettings (class in eventsourcing.infrastructure.datastore)
DatastoreTableError
datetime_from_timestamp() (in module eventsourcing.utils.times)
DB_URI (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemySettings attribute)
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)
delete_record() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
deserialize_section() (in module eventsourcing.interface.notificationlog)
Discarded (class in eventsourcing.domain.model.events)
DomainEntity (class in eventsourcing.domain.model.entity)
DomainEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
DomainEntity.Created (class in eventsourcing.domain.model.entity)
DomainEntity.Discarded (class in eventsourcing.domain.model.entity)
DomainEntity.Event (class in eventsourcing.domain.model.entity)
DomainEvent (class in eventsourcing.domain.model.events)
drop_table() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.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
EntityVersionNotFound
event_id (eventsourcing.domain.model.events.EventWithTimeuuid attribute)
event_store (eventsourcing.domain.model.entity.AbstractEntityRepository attribute)
(eventsourcing.infrastructure.eventplayer.EventPlayer attribute)
event_type (eventsourcing.infrastructure.cassandra.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.StoredEventRecord attribute)
EventHandlersNotEmptyError
EventHashError
EventPlayer (class in eventsourcing.infrastructure.eventplayer)
EventSourcedRepository (class in eventsourcing.infrastructure.eventsourcedrepository)
EventSourcedSnapshotStrategy (class in eventsourcing.infrastructure.snapshotting)
eventsourcing.application.base (module)
eventsourcing.application.policies (module)
eventsourcing.application.simple (module)
eventsourcing.domain.model.aggregate (module)
eventsourcing.domain.model.array (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.activerecord (module)
eventsourcing.infrastructure.cassandra.activerecords (module)
eventsourcing.infrastructure.cassandra.datastore (module)
eventsourcing.infrastructure.datastore (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.activerecords (module)
eventsourcing.infrastructure.sqlalchemy.datastore (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)
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.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
foo (eventsourcing.example.domainmodel.Example attribute)
format_section_id() (eventsourcing.interface.notificationlog.NotificationLog static method)
from_active_record() (eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
from_jsonable() (eventsourcing.utils.transcoding.ObjectJSONDecoder class method)
from_sequenced_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
G
get_domain_event() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_domain_events() (eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore method)
get_entity() (eventsourcing.domain.model.entity.AbstractEntityRepository method)
(eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
get_events() (eventsourcing.infrastructure.timebucketedlog_reader.TimebucketedlogReader method)
get_example_application() (in module eventsourcing.example.application)
get_field_kwargs() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
get_item() (eventsourcing.domain.model.array.BigArray method)
(eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
get_item_assigned() (eventsourcing.domain.model.array.Array method)
get_items() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
(eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
(eventsourcing.interface.notificationlog.NotificationLogReader 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_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)
get_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository 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
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.sqlalchemy.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord attribute)
index (eventsourcing.domain.model.array.ItemAssigned attribute)
init_example_application() (in module eventsourcing.example.application)
init_example_application_with_sqlalchemy() (in module eventsourcing.example.interface.flaskapp)
IntegerSequencedItem (class in eventsourcing.example.interface.flaskapp)
IntegerSequencedItemRecord (class in eventsourcing.infrastructure.cassandra.activerecords)
(class in eventsourcing.infrastructure.sqlalchemy.activerecords)
IntegerSequencedItemRecord.DoesNotExist
IntegerSequencedItemRecord.MultipleObjectsReturned
is_event() (eventsourcing.application.policies.PersistencePolicy method)
item (eventsourcing.domain.model.array.ItemAssigned attribute)
ItemAssigned (class in eventsourcing.domain.model.array)
iterator_class (eventsourcing.infrastructure.eventstore.EventStore attribute)
J
json_dumps() (in module eventsourcing.utils.transcoding)
json_loads() (in module eventsourcing.utils.transcoding)
L
list_items() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
Logged (class in eventsourcing.domain.model.events)
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
mutate() (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() (eventsourcing.infrastructure.integersequencegenerators.base.AbstractIntegerSequenceGenerator method)
next_bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
NotificationLog (class in eventsourcing.interface.notificationlog)
NotificationLogReader (class in eventsourcing.interface.notificationlog)
O
ObjectJSONDecoder (class in eventsourcing.utils.transcoding)
ObjectJSONEncoder (class in eventsourcing.utils.transcoding)
originator_id (eventsourcing.domain.model.events.EventWithOriginatorID attribute)
(eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.infrastructure.cassandra.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.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.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.StoredEventRecord attribute)
OriginatorIDError
OriginatorVersionError
other_names (eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
P
PersistencePolicy (class in eventsourcing.application.policies)
pk (eventsourcing.infrastructure.cassandra.activerecords.CqlTimeuuidSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.TimestampSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.datastore.ActiveRecord attribute)
PORT (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
position (eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.CqlTimeuuidSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.TimestampSequencedItemRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord attribute)
present_section() (in module eventsourcing.interface.notificationlog)
previous_bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
ProgrammingError
PROTOCOL_VERSION (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
publish() (in module eventsourcing.domain.model.events)
Q
QualnameABC (class in eventsourcing.domain.model.events)
QualnameABCMeta (class in eventsourcing.domain.model.events)
query (eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy attribute)
R
raise_index_error() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
raise_sequenced_item_error() (eventsourcing.infrastructure.activerecord.AbstractActiveRecordStrategy method)
random() (in module eventsourcing.domain.model.decorators)
reconstruct_object() (in module eventsourcing.infrastructure.sequenceditemmapper)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
RemoteNotificationLog (class in eventsourcing.interface.notificationlog)
replay_entity() (eventsourcing.infrastructure.eventsourcedrepository.EventSourcedRepository method)
replay_events() (eventsourcing.infrastructure.eventplayer.EventPlayer method)
REPLICATION_FACTOR (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
RepositoryKeyError
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)
S
Section (class in eventsourcing.interface.notificationlog)
seek() (eventsourcing.interface.notificationlog.NotificationLogReader method)
sequence_id (eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.CqlTimeuuidSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.TimestampSequencedItemRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord attribute)
SequencedItem (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemConflict
SequencedItemFieldNames (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemIterator (class in eventsourcing.infrastructure.iterators)
SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
serialize_section() (in module eventsourcing.interface.notificationlog)
session (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore attribute)
setup_cipher() (eventsourcing.application.simple.SimpleApplication method)
setup_connection() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
setup_datastore() (eventsourcing.application.simple.SimpleApplication method)
setup_event_store() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.simple.SnapshottingApplication method)
setup_persistence_policy() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.simple.SnapshottingApplication method)
setup_repository() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.simple.SnapshottingApplication method)
setup_table() (eventsourcing.application.simple.SimpleApplication method)
(eventsourcing.application.simple.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)
SimpleApplication (class in eventsourcing.application.simple)
SimpleIntegerSequenceGenerator (class in eventsourcing.infrastructure.integersequencegenerators.base)
Snapshot (class in eventsourcing.domain.model.snapshot)
SnapshotRecord (class in eventsourcing.infrastructure.cassandra.activerecords)
(class in eventsourcing.infrastructure.sqlalchemy.activerecords)
SnapshotRecord.DoesNotExist
SnapshotRecord.MultipleObjectsReturned
SnapshottingApplication (class in eventsourcing.application.simple)
SnapshottingPolicy (class in eventsourcing.application.policies)
SQLAlchemyActiveRecordStrategy (class in eventsourcing.infrastructure.sqlalchemy.activerecords)
SQLAlchemyDatastore (class in eventsourcing.infrastructure.sqlalchemy.datastore)
SQLAlchemySettings (class in eventsourcing.infrastructure.sqlalchemy.datastore)
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.infrastructure.cassandra.activerecords.StoredEventRecord attribute)
(eventsourcing.infrastructure.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.StoredEventRecord attribute)
store_event() (eventsourcing.application.policies.PersistencePolicy method)
StoredEvent (class in eventsourcing.infrastructure.sequenceditem)
StoredEventRecord (class in eventsourcing.infrastructure.cassandra.activerecords)
(class in eventsourcing.infrastructure.sqlalchemy.activerecords)
StoredEventRecord.DoesNotExist
StoredEventRecord.MultipleObjectsReturned
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)
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)
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)
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)
TimestampSequencedItemRecord (class in eventsourcing.infrastructure.cassandra.activerecords)
(class in eventsourcing.infrastructure.sqlalchemy.activerecords)
TimestampSequencedItemRecord.DoesNotExist
TimestampSequencedItemRecord.MultipleObjectsReturned
TimeuuidedEntity (class in eventsourcing.domain.model.entity)
TimeuuidedVersionedEntity (class in eventsourcing.domain.model.entity)
to_active_record() (eventsourcing.infrastructure.cassandra.activerecords.CassandraActiveRecordStrategy method)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SQLAlchemyActiveRecordStrategy method)
to_sequenced_item() (eventsourcing.infrastructure.eventstore.EventStore method)
(eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
topic (eventsourcing.domain.model.snapshot.AbstractSnapshop attribute)
(eventsourcing.domain.model.snapshot.Snapshot attribute)
(eventsourcing.example.interface.flaskapp.IntegerSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.CqlTimeuuidSequencedItem attribute)
(eventsourcing.infrastructure.cassandra.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.cassandra.activerecords.TimestampSequencedItemRecord attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItem attribute)
(eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.IntegerSequencedItemRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.SnapshotRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.activerecords.TimestampSequencedItemRecord attribute)
TopicResolutionError
truncate_tables() (eventsourcing.infrastructure.cassandra.datastore.CassandraDatastore method)
(eventsourcing.infrastructure.datastore.Datastore method)
(eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore method)
U
unsubscribe() (in module eventsourcing.domain.model.events)
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)
Read the Docs
v: v4.0.0
Versions
latest
stable
v5.0.0
v4.0.0
v3.1.0
v3.0.0
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.