eventsourcing
latest
Installation
Support
Introduction
Tutorial
Modules
Examples
Release notes
eventsourcing
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
Z
_
__base_init__() (eventsourcing.domain.Aggregate method)
__contains__() (eventsourcing.application.Repository method)
__delattr__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
__eq__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
__getitem__() (eventsourcing.application.LocalNotificationLog method)
(eventsourcing.application.NotificationLog method)
(eventsourcing.interface.NotificationLogJSONClient method)
__hash__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
__init__() (eventsourcing.application.Application method)
(eventsourcing.application.Cache method)
(eventsourcing.application.EventSourcedLog method)
(eventsourcing.application.LocalNotificationLog method)
(eventsourcing.application.LRUCache method)
(eventsourcing.application.ProcessingEvent method)
(eventsourcing.application.Repository method)
(eventsourcing.application.Section method)
(eventsourcing.interface.NotificationLogJSONClient method)
(eventsourcing.interface.NotificationLogJSONService method)
(eventsourcing.persistence.Cipher method)
(eventsourcing.persistence.Connection method)
(eventsourcing.persistence.ConnectionPool method)
(eventsourcing.persistence.EventStore method)
(eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.persistence.JSONTranscoder method)
(eventsourcing.persistence.Mapper method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
(eventsourcing.persistence.Transcoder method)
(eventsourcing.popo.POPOAggregateRecorder method)
(eventsourcing.popo.POPOProcessRecorder method)
(eventsourcing.sqlite.Factory method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
(eventsourcing.sqlite.SQLiteConnection method)
(eventsourcing.sqlite.SQLiteConnectionPool method)
(eventsourcing.sqlite.SQLiteCursor method)
(eventsourcing.sqlite.SQLiteProcessRecorder method)
(eventsourcing.system.ConvertingThread method)
(eventsourcing.system.Follower method)
(eventsourcing.system.Leader method)
(eventsourcing.system.MultiThreadedRunner method)
(eventsourcing.system.MultiThreadedRunnerThread method)
(eventsourcing.system.NewMultiThreadedRunner method)
(eventsourcing.system.NewSingleThreadedRunner method)
(eventsourcing.system.NotificationLogReader method)
(eventsourcing.system.ProcessingThread method)
(eventsourcing.system.PullingThread method)
(eventsourcing.system.Runner method)
(eventsourcing.system.SingleThreadedRunner method)
(eventsourcing.system.System method)
__init_subclass__() (eventsourcing.application.Application class method)
__repr__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
__setattr__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
_create() (eventsourcing.domain.Aggregate class method)
A
Aggregate (class in eventsourcing.domain)
aggregate() (in module eventsourcing.domain)
Aggregate.Created (class in eventsourcing.domain)
Aggregate.Event (class in eventsourcing.domain)
aggregate_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.Factory method)
(eventsourcing.sqlite.Factory method)
aggregate_recorder_class (eventsourcing.sqlite.Factory attribute)
AggregateCreated (class in eventsourcing.domain)
AggregateEvent (class in eventsourcing.domain)
AggregateNotFoundError
AggregateRecorder (class in eventsourcing.persistence)
Application (class in eventsourcing.application)
application_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.Factory method)
(eventsourcing.sqlite.Factory method)
application_recorder_class (eventsourcing.sqlite.Factory attribute)
ApplicationRecorder (class in eventsourcing.persistence)
apply() (eventsourcing.domain.CanMutateAggregate method)
(eventsourcing.domain.MetaAggregate.DecoratedEvent method)
B
BoundCommandMethodDecorator (class in eventsourcing.domain)
C
Cache (class in eventsourcing.application)
CanCreateTimestamp (class in eventsourcing.domain)
CanInitAggregate (class in eventsourcing.domain)
CanMutateAggregate (class in eventsourcing.domain)
CanMutateProtocol (class in eventsourcing.domain)
CanSnapshotAggregate (class in eventsourcing.domain)
Cipher (class in eventsourcing.persistence)
cipher() (eventsourcing.persistence.InfrastructureFactory method)
close() (eventsourcing.persistence.ConnectionPool method)
(eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.sqlite.Factory method)
collect_events() (eventsourcing.application.ProcessingEvent method)
(eventsourcing.domain.Aggregate method)
(eventsourcing.domain.CollectEventsProtocol method)
CollectEventsProtocol (class in eventsourcing.domain)
commit() (eventsourcing.persistence.Connection method)
(eventsourcing.sqlite.SQLiteConnection method)
compress() (eventsourcing.compressor.ZlibCompressor method)
(eventsourcing.persistence.Compressor method)
Compressor (class in eventsourcing.persistence)
compressor() (eventsourcing.persistence.InfrastructureFactory method)
Connection (class in eventsourcing.persistence)
ConnectionNotFromPoolError
ConnectionPool (class in eventsourcing.persistence)
ConnectionPoolClosedError
ConnectionUnavailableError
construct() (eventsourcing.persistence.InfrastructureFactory class method)
construct_env() (eventsourcing.application.Application method)
construct_event_store() (eventsourcing.application.Application method)
construct_factory() (eventsourcing.application.Application method)
construct_mapper() (eventsourcing.application.Application method)
construct_notification_log() (eventsourcing.application.Application method)
construct_recorder() (eventsourcing.application.Application method)
(eventsourcing.system.Follower method)
construct_repository() (eventsourcing.application.Application method)
construct_snapshot_store() (eventsourcing.application.Application method)
construct_transcoder() (eventsourcing.application.Application method)
convert_notifications() (eventsourcing.system.Follower method)
ConvertingThread (class in eventsourcing.system)
create_id() (eventsourcing.domain.MetaAggregate static method)
create_timestamp() (eventsourcing.domain.CanCreateTimestamp static method)
create_utc_datetime_now() (in module eventsourcing.domain)
created_on (eventsourcing.domain.Aggregate property)
Cursor (class in eventsourcing.persistence)
cursor() (eventsourcing.persistence.Connection method)
(eventsourcing.sqlite.SQLiteConnection method)
D
DatabaseError
DataError
DatetimeAsISO (class in eventsourcing.persistence)
DecimalAsStr (class in eventsourcing.persistence)
decode() (eventsourcing.persistence.DatetimeAsISO method)
(eventsourcing.persistence.DecimalAsStr method)
(eventsourcing.persistence.JSONTranscoder method)
(eventsourcing.persistence.Transcoder method)
(eventsourcing.persistence.Transcoding method)
(eventsourcing.persistence.UUIDAsHex method)
decompress() (eventsourcing.compressor.ZlibCompressor method)
(eventsourcing.persistence.Compressor method)
decrypt() (eventsourcing.persistence.Cipher method)
DomainEvent (class in eventsourcing.domain)
DomainEventProtocol (class in eventsourcing.domain)
E
encode() (eventsourcing.persistence.DatetimeAsISO method)
(eventsourcing.persistence.DecimalAsStr method)
(eventsourcing.persistence.JSONTranscoder method)
(eventsourcing.persistence.Transcoder method)
(eventsourcing.persistence.Transcoding method)
(eventsourcing.persistence.UUIDAsHex method)
encrypt() (eventsourcing.persistence.Cipher method)
Environment (class in eventsourcing.utils)
event() (in module eventsourcing.domain)
event_store() (eventsourcing.persistence.InfrastructureFactory static method)
EventProcessingError
EventSourcedLog (class in eventsourcing.application)
eventsourcing.application
module
eventsourcing.compressor
module
eventsourcing.domain
module
eventsourcing.interface
module
eventsourcing.persistence
module
eventsourcing.popo
module
eventsourcing.sqlite
module
eventsourcing.system
module
eventsourcing.utils
module
EventSourcingError
EventStore (class in eventsourcing.persistence)
execute() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
F
Factory (class in eventsourcing.popo)
(class in eventsourcing.sqlite)
fetchall() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
fetchone() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
follow() (eventsourcing.system.Follower method)
Follower (class in eventsourcing.system)
G
get() (eventsourcing.application.EventSourcedLog method)
(eventsourcing.application.Repository method)
(eventsourcing.persistence.EventStore method)
(eventsourcing.system.MultiThreadedRunner method)
(eventsourcing.system.NewMultiThreadedRunner method)
(eventsourcing.system.NewSingleThreadedRunner method)
(eventsourcing.system.Runner method)
(eventsourcing.system.SingleThreadedRunner method)
(eventsourcing.utils.Environment method)
get_connection() (eventsourcing.persistence.ConnectionPool method)
get_first() (eventsourcing.application.EventSourcedLog method)
get_last() (eventsourcing.application.EventSourcedLog method)
get_log_section() (eventsourcing.interface.NotificationLogInterface method)
(eventsourcing.interface.NotificationLogJSONService method)
get_notifications() (eventsourcing.interface.NotificationLogInterface method)
(eventsourcing.interface.NotificationLogJSONService method)
get_topic() (in module eventsourcing.utils)
H
has_tracking_id() (eventsourcing.persistence.ProcessRecorder method)
(eventsourcing.popo.POPOProcessRecorder method)
(eventsourcing.sqlite.SQLiteProcessRecorder method)
HasOriginatorIDVersion (class in eventsourcing.domain)
I
id (eventsourcing.domain.Aggregate property)
(eventsourcing.domain.ImmutableAggregateProtocol property)
(eventsourcing.domain.MutableAggregateProtocol property)
ImmutableAggregateProtocol (class in eventsourcing.domain)
InfrastructureFactory (class in eventsourcing.persistence)
insert_events() (eventsourcing.persistence.AggregateRecorder method)
(eventsourcing.popo.POPOAggregateRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
IntegrityError
InterfaceError
InternalError
is_snapshotting_enabled() (eventsourcing.persistence.InfrastructureFactory method)
J
JSONTranscoder (class in eventsourcing.persistence)
L
lead() (eventsourcing.system.Leader method)
Leader (class in eventsourcing.system)
LocalNotificationLog (class in eventsourcing.application)
LogEvent (class in eventsourcing.domain)
LRUCache (class in eventsourcing.application)
M
Mapper (class in eventsourcing.persistence)
mapper() (eventsourcing.persistence.InfrastructureFactory method)
max_notification_id() (eventsourcing.persistence.ApplicationRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
max_tracking_id() (eventsourcing.persistence.ProcessRecorder method)
(eventsourcing.popo.POPOProcessRecorder method)
(eventsourcing.sqlite.SQLiteProcessRecorder method)
MetaAggregate (class in eventsourcing.domain)
MetaAggregate.Created (class in eventsourcing.domain)
MetaAggregate.DecoratedEvent (class in eventsourcing.domain)
MetaAggregate.Event (class in eventsourcing.domain)
MetaDomainEvent (class in eventsourcing.domain)
modified_on (eventsourcing.domain.Aggregate property)
module
eventsourcing.application
eventsourcing.compressor
eventsourcing.domain
eventsourcing.interface
eventsourcing.persistence
eventsourcing.popo
eventsourcing.sqlite
eventsourcing.system
eventsourcing.utils
MultiThreadedRunner (class in eventsourcing.system)
MultiThreadedRunnerThread (class in eventsourcing.system)
MutableAggregateProtocol (class in eventsourcing.domain)
MutableOrImmutableAggregate (in module eventsourcing.domain)
mutate() (eventsourcing.domain.CanInitAggregate method)
(eventsourcing.domain.CanMutateAggregate method)
(eventsourcing.domain.CanMutateProtocol method)
(eventsourcing.domain.CanSnapshotAggregate method)
N
NewMultiThreadedRunner (class in eventsourcing.system)
NewSingleThreadedRunner (class in eventsourcing.system)
Notification (class in eventsourcing.persistence)
notification_log (eventsourcing.application.Application property)
NotificationConvertingError
NotificationLog (class in eventsourcing.application)
NotificationLogInterface (class in eventsourcing.interface)
NotificationLogJSONClient (class in eventsourcing.interface)
NotificationLogJSONService (class in eventsourcing.interface)
NotificationLogReader (class in eventsourcing.system)
NotificationPullingError
notify() (eventsourcing.application.Application method)
NotSupportedError
num_in_pool (eventsourcing.persistence.ConnectionPool property)
num_in_use (eventsourcing.persistence.ConnectionPool property)
O
OperationalError
originator_id (eventsourcing.domain.Aggregate.Created attribute)
(eventsourcing.domain.Aggregate.Event attribute)
(eventsourcing.domain.AggregateEvent attribute)
(eventsourcing.domain.DomainEvent attribute)
(eventsourcing.domain.DomainEventProtocol property)
(eventsourcing.domain.HasOriginatorIDVersion attribute)
(eventsourcing.domain.LogEvent attribute)
(eventsourcing.domain.MetaAggregate.Created attribute)
(eventsourcing.domain.MetaAggregate.Event attribute)
originator_topic (eventsourcing.domain.AggregateCreated attribute)
(eventsourcing.domain.CanInitAggregate attribute)
originator_version (eventsourcing.domain.Aggregate.Created attribute)
(eventsourcing.domain.Aggregate.Event attribute)
(eventsourcing.domain.AggregateEvent attribute)
(eventsourcing.domain.DomainEvent attribute)
(eventsourcing.domain.DomainEventProtocol property)
(eventsourcing.domain.HasOriginatorIDVersion attribute)
(eventsourcing.domain.LogEvent attribute)
(eventsourcing.domain.MetaAggregate.Created attribute)
(eventsourcing.domain.MetaAggregate.Event attribute)
OriginatorIDError
OriginatorVersionError
P
pending_events (eventsourcing.domain.Aggregate property)
PersistenceError
policy() (eventsourcing.system.Follower method)
POPOAggregateRecorder (class in eventsourcing.popo)
POPOApplicationRecorder (class in eventsourcing.popo)
POPOProcessRecorder (class in eventsourcing.popo)
process_event() (eventsourcing.system.Follower method)
process_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.Factory method)
(eventsourcing.sqlite.Factory method)
process_recorder_class (eventsourcing.sqlite.Factory attribute)
ProcessApplication (class in eventsourcing.system)
ProcessingEvent (class in eventsourcing.application)
ProcessingThread (class in eventsourcing.system)
ProcessRecorder (class in eventsourcing.persistence)
ProgrammingError
,
[1]
project_aggregate() (in module eventsourcing.application)
pull_and_process() (eventsourcing.system.Follower method)
pull_notifications() (eventsourcing.system.Follower method)
PullingThread (class in eventsourcing.system)
put() (eventsourcing.persistence.EventStore method)
put_connection() (eventsourcing.persistence.ConnectionPool method)
R
random() (in module eventsourcing.utils)
read() (eventsourcing.system.NotificationLogReader method)
receive_recording_event() (eventsourcing.system.MultiThreadedRunnerThread method)
(eventsourcing.system.NewMultiThreadedRunner method)
(eventsourcing.system.NewSingleThreadedRunner method)
(eventsourcing.system.RecordingEventReceiver method)
(eventsourcing.system.SingleThreadedRunner method)
RecordConflictError
Recording (class in eventsourcing.persistence)
RecordingEventReceiver (class in eventsourcing.system)
register() (eventsourcing.persistence.Transcoder method)
register_topic() (in module eventsourcing.utils)
register_transcodings() (eventsourcing.application.Application method)
Repository (class in eventsourcing.application)
repository (eventsourcing.application.Application property)
resolve_topic() (in module eventsourcing.utils)
retry() (in module eventsourcing.utils)
rollback() (eventsourcing.persistence.Connection method)
(eventsourcing.sqlite.SQLiteConnection method)
run() (eventsourcing.system.ConvertingThread method)
(eventsourcing.system.MultiThreadedRunnerThread method)
(eventsourcing.system.ProcessingThread method)
(eventsourcing.system.PullingThread method)
Runner (class in eventsourcing.system)
RunnerAlreadyStartedError
S
save() (eventsourcing.application.Application method)
Section (class in eventsourcing.application)
select() (eventsourcing.application.LocalNotificationLog method)
(eventsourcing.application.NotificationLog method)
(eventsourcing.interface.NotificationLogJSONClient method)
(eventsourcing.system.NotificationLogReader method)
select_events() (eventsourcing.persistence.AggregateRecorder method)
(eventsourcing.popo.POPOAggregateRecorder method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
select_notifications() (eventsourcing.persistence.ApplicationRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
SingleThreadedRunner (class in eventsourcing.system)
Snapshot (class in eventsourcing.domain)
snapshot_class (eventsourcing.application.Application attribute)
SnapshotProtocol (class in eventsourcing.domain)
SQLiteAggregateRecorder (class in eventsourcing.sqlite)
SQLiteApplicationRecorder (class in eventsourcing.sqlite)
SQLiteConnection (class in eventsourcing.sqlite)
SQLiteConnectionPool (class in eventsourcing.sqlite)
SQLiteCursor (class in eventsourcing.sqlite)
SQLiteProcessRecorder (class in eventsourcing.sqlite)
start() (eventsourcing.system.MultiThreadedRunner method)
(eventsourcing.system.NewMultiThreadedRunner method)
(eventsourcing.system.NewSingleThreadedRunner method)
(eventsourcing.system.Runner method)
(eventsourcing.system.SingleThreadedRunner method)
state (eventsourcing.domain.SnapshotProtocol property)
stop() (eventsourcing.system.MultiThreadedRunner method)
(eventsourcing.system.NewMultiThreadedRunner method)
(eventsourcing.system.NewSingleThreadedRunner method)
(eventsourcing.system.Runner method)
(eventsourcing.system.SingleThreadedRunner method)
StoredEvent (class in eventsourcing.persistence)
strtobool() (in module eventsourcing.utils)
System (class in eventsourcing.system)
T
take() (eventsourcing.domain.CanSnapshotAggregate class method)
(eventsourcing.domain.SnapshotProtocol class method)
take_snapshot() (eventsourcing.application.Application method)
timestamp (eventsourcing.domain.Aggregate.Created attribute)
(eventsourcing.domain.Aggregate.Event attribute)
(eventsourcing.domain.AggregateEvent attribute)
(eventsourcing.domain.CanMutateAggregate attribute)
(eventsourcing.domain.DomainEvent attribute)
(eventsourcing.domain.LogEvent attribute)
(eventsourcing.domain.MetaAggregate.Created attribute)
(eventsourcing.domain.MetaAggregate.Event attribute)
TMutableOrImmutableAggregate (class in eventsourcing.domain)
to_domain_event() (eventsourcing.persistence.Mapper method)
to_stored_event() (eventsourcing.persistence.Mapper method)
topic (eventsourcing.domain.SnapshotProtocol property)
(eventsourcing.system.System property)
TopicError
Tracking (class in eventsourcing.persistence)
Transcoder (class in eventsourcing.persistence)
transcoder() (eventsourcing.persistence.InfrastructureFactory method)
Transcoding (class in eventsourcing.persistence)
trigger_event() (eventsourcing.application.EventSourcedLog method)
(eventsourcing.domain.Aggregate method)
triggers() (in module eventsourcing.domain)
type (eventsourcing.persistence.DatetimeAsISO attribute)
(eventsourcing.persistence.DecimalAsStr attribute)
(eventsourcing.persistence.UUIDAsHex attribute)
U
UnboundCommandMethodDecorator (class in eventsourcing.domain)
UUIDAsHex (class in eventsourcing.persistence)
V
version (eventsourcing.domain.Aggregate property)
(eventsourcing.domain.ImmutableAggregateProtocol property)
(eventsourcing.domain.MutableAggregateProtocol property)
VersionError
Z
ZlibCompressor (class in eventsourcing.compressor)
Read the Docs
v: latest
Versions
latest
stable
v9.2.22
v9.2.21
v9.2.20
v9.2.19
v9.2.18
v9.2.17
v9.2.16
v9.2.15
v9.2.14
v9.2.13
v9.2.12
v9.2.11
v9.2.10
v9.2.9
v9.2.8
v9.2.7
v9.2.6
v9.2.5
v9.2.4
v9.2.3
v9.2.2
v9.2.1
v9.2.0
v9.1.9
v9.1.8
v9.1.7
v9.1.6
v9.1.5
v9.1.4
v9.1.3
v9.1.2
v9.1.1
v9.1.0
v9.0.3
v9.0.2
v9.0.1
v9.0.0
v8.3.0
v8.2.5
v8.2.4
v8.2.3
v8.2.2
v8.2.1
v8.2.0
v8.1.0
v8.0.0
v7.2.4
v7.2.3
v7.2.2
v7.2.1
v7.2.0
v7.1.6
v7.1.5
v7.1.4
v7.1.3
v7.1.2
v7.1.1
v7.1.0
v7.0.0
v6.3.0
v6.2.0
v6.1.0
v6.0.0
v5.1.1
v5.1.0
v5.0.0
v4.0.0
v3.1.0
v3.0.0
Downloads
On Read the Docs
Project Home
Builds