eventsourcing
v6.0.0
Contents
Background
Quick start
Installation
Features
Design
Infrastructure
Domain model
Application
Snapshotting
Notifications
Projections
Process and system
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.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.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)
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)
AbstractTrackingRecordManager (class in eventsourcing.infrastructure.base)
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_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)
(eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager 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)
application_id (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
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)
causal_dependencies (eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
CausalDependencyFailed
change_pipeline() (eventsourcing.application.simple.SimpleApplication method)
clear_event_handlers() (in module eventsourcing.domain.model.events)
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)
(eventsourcing.application.simple.SimpleApplication 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_repository() (eventsourcing.application.simple.SimpleApplication 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.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)
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)
EventRecordNotFound
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)
filter_by() (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.AbstractSequencedItemRecordManager 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_end_position() (eventsourcing.interface.notificationlog.RecordManagerNotificationLog 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.AbstractSequencedItemRecordManager method)
get_item() (eventsourcing.domain.model.array.BigArray method)
(eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager 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.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.AbstractTrackingRecordManager method)
(eventsourcing.infrastructure.base.RelationalRecordManager method)
(eventsourcing.infrastructure.django.manager.DjangoRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
(eventsourcing.infrastructure.sqlalchemy.manager.TrackingRecordManager 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_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.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_record() (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
get_record_table_name() (eventsourcing.infrastructure.base.RelationalRecordManager 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
has_tracking_record() (eventsourcing.infrastructure.sqlalchemy.manager.TrackingRecordManager 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.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_tracking_record (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)
is_sqlite() (eventsourcing.infrastructure.sqlalchemy.datastore.SQLAlchemyDatastore 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.AbstractSequencedItemRecordManager method)
list_sequence_ids() (eventsourcing.infrastructure.base.AbstractSequencedItemRecordManager 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)
notification_id (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
NotificationLogReader (class in eventsourcing.interface.notificationlog)
NotificationLogView (class in eventsourcing.interface.notificationlog)
NotificationTrackingRecord (class in eventsourcing.infrastructure.sqlalchemy.records)
O
ObjectJSONDecoder (class in eventsourcing.utils.transcoding)
ObjectJSONEncoder (class in eventsourcing.utils.transcoding)
OperationalError
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
orm_query() (eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager method)
other_names (eventsourcing.infrastructure.sequenceditem.SequencedItemFieldNames attribute)
P
persist_event_type (eventsourcing.application.simple.SimpleApplication attribute)
PersistencePolicy (class in eventsourcing.application.policies)
pipeline_id (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord attribute)
(eventsourcing.infrastructure.sqlalchemy.records.StoredEventRecord attribute)
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
PromptFailed
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)
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)
reconstruct_object() (in module eventsourcing.infrastructure.sequenceditemmapper)
record_class (eventsourcing.infrastructure.base.AbstractTrackingRecordManager attribute)
(eventsourcing.infrastructure.sqlalchemy.manager.TrackingRecordManager attribute)
record_manager_class (eventsourcing.infrastructure.cassandra.factory.CassandraInfrastructureFactory attribute)
(eventsourcing.infrastructure.sqlalchemy.factory.SQLAlchemyInfrastructureFactory attribute)
RecordConflictError
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)
SequencedItemFieldNames (class in eventsourcing.infrastructure.sequenceditem)
SequencedItemIterator (class in eventsourcing.infrastructure.iterators)
SequencedItemMapper (class in eventsourcing.infrastructure.sequenceditemmapper)
session (eventsourcing.application.simple.SimpleApplication attribute)
(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.AbstractSequencedItemRecordManager method)
to_records() (eventsourcing.infrastructure.base.RelationalRecordManager 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
tracking_record_class (eventsourcing.infrastructure.base.RelationalRecordManager attribute)
(eventsourcing.infrastructure.sqlalchemy.manager.SQLAlchemyRecordManager attribute)
tracking_record_field_names (eventsourcing.infrastructure.base.RelationalRecordManager attribute)
TrackingRecordManager (class in eventsourcing.infrastructure.sqlalchemy.manager)
TrackingRecordNotFound
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)
upstream_application_id (eventsourcing.infrastructure.sqlalchemy.records.NotificationTrackingRecord 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.RelationalRecordManager method)
Read the Docs
v: v6.0.0
Versions
latest
stable
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
.