eventsourcing
v5.1.1
Contents
Background
Quick start
Installation
Features
Design
Infrastructure
Domain model
Application
Snapshotting
Stand-alone example
Notifications
Projections
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
|
W
_
__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.records.IntegerSequencedNoIDRecord method)
(eventsourcing.infrastructure.sqlalchemy.records.IntegerSequencedWithIDRecord 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.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)
_prepare_insert() (eventsourcing.infrastructure.base.RelationalRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
_replace() (eventsourcing.infrastructure.sequenceditem.SequencedItem method)
(eventsourcing.infrastructure.sequenceditem.StoredEvent method)
_write_records() (eventsourcing.infrastructure.base.RelationalRecordManager method)
A
a (eventsourcing.example.domainmodel.Example attribute)
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)
AbstractRecordManager (class in eventsourcing.infrastructure.base)
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)
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.base.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
all_records() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
all_sequence_ids() (eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
append() (eventsourcing.domain.model.array.Array method)
(eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.RelationalRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.eventstore.AbstractEventStore method)
(eventsourcing.infrastructure.eventstore.EventStore 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)
BigArrayNotificationLog (class in eventsourcing.interface.notificationlog)
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)
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)
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_record_manager() (eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory 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)
construct_sqlalchemy_eventstore() (in module eventsourcing.infrastructure.sqlalchemy.factory)
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
data (eventsourcing.example.interface.flaskapp.IntegerSequencedItem 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)
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)
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.base.AbstractRecordManager 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)
DjangoRecordManager (class in eventsourcing.infrastructure.django.manager)
DomainEntity (class in eventsourcing.domain.model.entity)
DomainEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
DomainEntity.Created (class in eventsourcing.domain.model.entity)
DomainEntity.Discarded (class in eventsourcing.domain.model.entity)
DomainEntity.Event (class in eventsourcing.domain.model.entity)
DomainEvent (class in eventsourcing.domain.model.events)
drop_table() (eventsourcing.application.simple.SimpleApplication 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
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.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.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.base (module)
eventsourcing.infrastructure.cassandra.datastore (module)
eventsourcing.infrastructure.cassandra.factory (module)
eventsourcing.infrastructure.cassandra.manager (module)
eventsourcing.infrastructure.datastore (module)
eventsourcing.infrastructure.django.manager (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)
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)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
foo (eventsourcing.example.domainmodel.Example attribute)
format_section_id() (eventsourcing.interface.notificationlog.LocalNotificationLog static method)
from_jsonable() (eventsourcing.utils.transcoding.ObjectJSONDecoder class method)
from_record() (eventsourcing.infrastructure.base.AbstractRecordManager method)
from_sequenced_item() (eventsourcing.infrastructure.sequenceditemmapper.AbstractSequencedItemMapper method)
(eventsourcing.infrastructure.sequenceditemmapper.SequencedItemMapper method)
from_topic_and_data() (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.base.AbstractRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
get_item() (eventsourcing.domain.model.array.BigArray method)
(eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_item_assigned() (eventsourcing.domain.model.array.Array method)
get_items() (eventsourcing.infrastructure.base.AbstractRecordManager method)
(eventsourcing.infrastructure.base.RelationalRecordManager method)
(eventsourcing.infrastructure.cassandra.manager.CassandraRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
(eventsourcing.interface.notificationlog.BigArrayNotificationLog method)
(eventsourcing.interface.notificationlog.LocalNotificationLog method)
(eventsourcing.interface.notificationlog.NotificationLogReader 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.RelationalRecordManager 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_or_create() (eventsourcing.domain.model.timebucketedlog.TimebucketedlogRepository method)
get_records() (eventsourcing.infrastructure.base.RelationalRecordManager 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
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.records.IntegerSequencedWithIDRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.TimestampSequencedWithIDRecord 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)
insert_select_max (eventsourcing.infrastructure.base.RelationalRecordManager attribute)
insert_values (eventsourcing.infrastructure.base.RelationalRecordManager attribute)
integer_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
IntegerSequencedItem (class in eventsourcing.example.interface.flaskapp)
IntegerSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
IntegerSequencedRecord (in module eventsourcing.infrastructure.sqlalchemy.records)
IntegerSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
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.base.AbstractRecordManager method)
LocalNotificationLog (class in eventsourcing.interface.notificationlog)
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)
(eventsourcing.interface.notificationlog.NotificationLogReader method)
next_bucket_starts() (in module eventsourcing.domain.model.timebucketedlog)
NotificationLogReader (class in eventsourcing.interface.notificationlog)
NotificationLogView (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.sequenceditem.StoredEvent 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.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
OriginatorIDError
OriginatorVersionError
other_names (eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
P
PersistencePolicy (class in eventsourcing.application.policies)
PORT (eventsourcing.infrastructure.cassandra.datastore.CassandraSettings attribute)
position (eventsourcing.example.interface.flaskapp.IntegerSequencedItem 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)
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.manager.SQLAlchemyRecordManager attribute)
R
raise_after_integrity_error() (eventsourcing.infrastructure.base.RelationalRecordManager method)
raise_index_error() (eventsourcing.infrastructure.base.AbstractRecordManager method)
raise_record_id_conflict() (eventsourcing.infrastructure.base.RelationalRecordManager static method)
raise_sequenced_item_conflict() (eventsourcing.infrastructure.base.AbstractRecordManager method)
random() (in module eventsourcing.domain.model.decorators)
read() (eventsourcing.interface.notificationlog.NotificationLogReader method)
reconstruct_object() (in module eventsourcing.infrastructure.sequenceditemmapper)
record_manager_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
record_table_name (eventsourcing.infrastructure.base.RelationalRecordManager attribute)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager attribute)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager attribute)
RecordIDConflict
RecordManagerNotificationLog (class in eventsourcing.interface.notificationlog)
RedisIncr (class in eventsourcing.infrastructure.integersequencegenerators.redisincr)
RelationalRecordManager (class in eventsourcing.infrastructure.base)
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.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)
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)
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)
snapshot_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
SnapshotRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
SnapshottingApplication (class in eventsourcing.application.simple)
SnapshottingPolicy (class in eventsourcing.application.policies)
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)
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.sequenceditem.StoredEvent attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
store_event() (eventsourcing.application.policies.PersistencePolicy method)
StoredEvent (class in eventsourcing.infrastructure.sequenceditem)
StoredEventRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
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)
timestamp_sequenced_record_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
TimestampedEntity (class in eventsourcing.domain.model.entity)
TimestampedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
TimestampedEntity.Created (class in eventsourcing.domain.model.entity)
TimestampedEntity.Discarded (class in eventsourcing.domain.model.entity)
TimestampedEntity.Event (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.AttributeChanged (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Created (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Discarded (class in eventsourcing.domain.model.entity)
TimestampedVersionedEntity.Event (class in eventsourcing.domain.model.entity)
TimestampSequencedNoIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
TimestampSequencedRecord (in module eventsourcing.infrastructure.sqlalchemy.records)
TimestampSequencedWithIDRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
TimeuuidedEntity (class in eventsourcing.domain.model.entity)
TimeuuidedVersionedEntity (class in eventsourcing.domain.model.entity)
to_record() (eventsourcing.infrastructure.base.AbstractRecordManager 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.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)
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)
W
write_records() (eventsourcing.infrastructure.base.RelationalRecordManager method)
Read the Docs
v: v5.1.1
Versions
latest
stable
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
.