eventsourcing
Installation
Support
Introduction
Tutorial
Modules
Examples
Release notes
eventsourcing
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
_
__base_init__() (eventsourcing.domain.BaseAggregate 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)
__enter__() (eventsourcing.projection.ApplicationSubscription method)
(eventsourcing.projection.BaseProjectionRunner method)
__eq__() (eventsourcing.application.Section method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Tracking method)
__exit__() (eventsourcing.projection.ApplicationSubscription method)
(eventsourcing.projection.BaseProjectionRunner 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.cipher.AESCipher method)
(eventsourcing.cryptography.AESCipher 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.ListenNotifySubscription method)
(eventsourcing.persistence.Mapper method)
(eventsourcing.persistence.Notification method)
(eventsourcing.persistence.Recording method)
(eventsourcing.persistence.StoredEvent method)
(eventsourcing.persistence.Subscription method)
(eventsourcing.persistence.Tracking method)
(eventsourcing.popo.POPOAggregateRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.popo.POPOSubscription method)
(eventsourcing.popo.POPOTrackingRecorder method)
(eventsourcing.postgres.ConnectionPool method)
(eventsourcing.postgres.PostgresAggregateRecorder method)
(eventsourcing.postgres.PostgresApplicationRecorder method)
(eventsourcing.postgres.PostgresDatastore method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.postgres.PostgresProcessRecorder method)
(eventsourcing.postgres.PostgresRecorder method)
(eventsourcing.postgres.PostgresSubscription method)
(eventsourcing.postgres.PostgresTrackingRecorder method)
(eventsourcing.projection.ApplicationSubscription method)
(eventsourcing.projection.BaseProjectionRunner method)
(eventsourcing.projection.EventSourcedProjection method)
(eventsourcing.projection.EventSourcedProjectionRunner method)
(eventsourcing.projection.Projection method)
(eventsourcing.projection.ProjectionRunner method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
(eventsourcing.sqlite.SQLiteConnection method)
(eventsourcing.sqlite.SQLiteConnectionPool method)
(eventsourcing.sqlite.SQLiteCursor method)
(eventsourcing.sqlite.SQLiteFactory method)
(eventsourcing.sqlite.SQLiteProcessRecorder method)
(eventsourcing.sqlite.SQLiteTrackingRecorder 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.RecordingEvent method)
(eventsourcing.system.Runner method)
(eventsourcing.system.SingleThreadedRunner method)
(eventsourcing.system.System method)
(examples.aggregate1.domainmodel.Dog method)
(examples.aggregate1.domainmodel.Dog.Created method)
(examples.aggregate1.domainmodel.Dog.Event method)
(examples.aggregate1.domainmodel.Dog.Registered method)
(examples.aggregate1.domainmodel.Dog.TrickAdded method)
(examples.aggregate11.domainmodel.Aggregate.Created method)
(examples.aggregate11.domainmodel.Aggregate.Event method)
(examples.aggregate11.domainmodel.Dog method)
(examples.aggregate11.domainmodel.Dog.Created method)
(examples.aggregate11.domainmodel.Dog.Event method)
(examples.aggregate11.domainmodel.Dog.Registered method)
(examples.aggregate11.domainmodel.Dog.TrickAdded method)
(examples.aggregate11.domainmodel.DomainEvent method)
(examples.aggregate11.domainmodel.Snapshot method)
(examples.shopstandard.domain.Cart method)
(examples.shopstandard.domain.Product method)
__init_subclass__() (eventsourcing.application.Application class method)
(eventsourcing.system.Follower class method)
__iter__() (eventsourcing.projection.ApplicationSubscription method)
__next__() (eventsourcing.persistence.ListenNotifySubscription method)
(eventsourcing.persistence.Subscription method)
(eventsourcing.projection.ApplicationSubscription 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)
_insert_pages() (examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)
_insert_tracking() (eventsourcing.postgres.PostgresTrackingRecorder method)
_update_body (examples.contentmanagement.domainmodel.Page attribute)
_update_pages() (examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)
A
AccountClosedError
AccountNotFoundError
add_item (examples.shopstandard.domain.Cart attribute)
add_item_to_cart() (examples.shopstandard.application.Shop method)
add_product_to_shop() (examples.shopstandard.application.Shop method)
add_trick (examples.aggregate1.domainmodel.Dog attribute)
(examples.aggregate10.domainmodel.Dog attribute)
(examples.aggregate11.domainmodel.Dog attribute)
(examples.aggregate2.domainmodel.Dog attribute)
(examples.aggregate8.domainmodel.Dog attribute)
add_trick() (examples.aggregate1.application.DogSchool method)
(examples.aggregate10.application.DogSchool method)
(examples.aggregate11.application.DogSchool method)
(examples.aggregate2.application.DogSchool method)
(examples.aggregate3.application.DogSchool method)
(examples.aggregate3.domainmodel.Dog method)
(examples.aggregate4.application.DogSchool method)
(examples.aggregate4.domainmodel.Dog method)
(examples.aggregate5.application.DogSchool method)
(examples.aggregate5.domainmodel.Dog method)
(examples.aggregate6.application.DogSchool method)
(examples.aggregate7.application.DogSchool method)
(examples.aggregate8.application.DogSchool method)
(examples.aggregate9.application.DogSchool method)
(in module examples.aggregate6.domainmodel)
(in module examples.aggregate7.domainmodel)
(in module examples.aggregate9.domainmodel)
AddedItemToCart (class in examples.shopvertical.events)
AddedProductToShop (class in examples.shopvertical.events)
AddItemToCart (class in examples.shopvertical.slices.add_item_to_cart.cmd)
AddProductToShop (class in examples.shopvertical.slices.add_product_to_shop.cmd)
adjust_inventory (examples.shopstandard.domain.Product attribute)
adjust_product_inventory() (examples.shopstandard.application.Shop method)
AdjustedProductInventory (class in examples.shopvertical.events)
adjustment (examples.shopvertical.events.AdjustedProductInventory attribute)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory attribute)
AdjustProductInventory (class in examples.shopvertical.slices.adjust_product_inventory.cmd)
AESCipher (class in eventsourcing.cipher)
(class in eventsourcing.cryptography)
after_connect_func() (eventsourcing.postgres.PostgresDatastore method)
Aggregate (class in eventsourcing.domain)
(class in examples.aggregate10.mutablemodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate4.baseclasses)
(class in examples.aggregate5.baseclasses)
(class in examples.aggregate6.baseclasses)
(class in examples.aggregate7.immutablemodel)
(class in examples.aggregate8.mutablemodel)
(class in examples.aggregate9.immutablemodel)
aggregate() (in module eventsourcing.domain)
Aggregate.Created (class in eventsourcing.domain)
(class in examples.aggregate10.mutablemodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate8.mutablemodel)
Aggregate.Event (class in eventsourcing.domain)
(class in examples.aggregate10.mutablemodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate8.mutablemodel)
Aggregate.Snapshot (class in eventsourcing.domain)
(class in examples.aggregate4.baseclasses)
(class in examples.aggregate5.baseclasses)
aggregate_projector() (in module examples.aggregate6.baseclasses)
(in module examples.aggregate7.immutablemodel)
(in module examples.aggregate9.immutablemodel)
aggregate_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.POPOFactory method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.sqlite.SQLiteFactory method)
aggregate_recorder_class (eventsourcing.postgres.PostgresFactory attribute)
(eventsourcing.sqlite.SQLiteFactory attribute)
AggregateCreated (class in eventsourcing.domain)
AggregateEvent (class in eventsourcing.domain)
(class in examples.aggregate10.mutablemodel)
AggregateNotFoundError
AggregateRecorder (class in eventsourcing.persistence)
AggregateSnapshot (class in examples.aggregate10.mutablemodel)
(class in examples.aggregate8.mutablemodel)
amount (examples.bankaccounts.domainmodel.BankAccount.Credited attribute)
(examples.bankaccounts.domainmodel.BankAccount.Debited attribute)
append_event() (examples.aggregate4.baseclasses.Aggregate method)
Application (class in eventsourcing.application)
application_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.POPOFactory method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.sqlite.SQLiteFactory method)
application_recorder_class (eventsourcing.postgres.PostgresFactory attribute)
(eventsourcing.sqlite.SQLiteFactory attribute)
ApplicationRecorder (class in eventsourcing.persistence)
ApplicationSubscription (class in eventsourcing.projection)
apply() (eventsourcing.domain.CanMutateAggregate method)
(eventsourcing.domain.DecoratorEvent method)
(examples.aggregate3.domainmodel.Dog method)
(examples.aggregate3.domainmodel.Dog.Event method)
(examples.cargoshipping.domainmodel.Cargo.Event method)
(examples.contentmanagement.domainmodel.Page.Event method)
apply_diff() (in module examples.contentmanagement.utils)
apply_event() (examples.aggregate4.baseclasses.Aggregate method)
(examples.aggregate4.domainmodel.Dog method)
arrival_deadline (examples.cargoshipping.domainmodel.Cargo property)
assign_route() (examples.cargoshipping.application.BookingApplication method)
(examples.cargoshipping.domainmodel.Cargo method)
(examples.cargoshipping.interface.BookingService method)
AUMEL (examples.cargoshipping.domainmodel.Location attribute)
B
BankAccount (class in examples.bankaccounts.domainmodel)
BankAccount.Closed (class in examples.bankaccounts.domainmodel)
BankAccount.Created (class in examples.bankaccounts.domainmodel)
BankAccount.Credited (class in examples.bankaccounts.domainmodel)
BankAccount.Debited (class in examples.bankaccounts.domainmodel)
BankAccount.Event (class in examples.bankaccounts.domainmodel)
BankAccount.Opened (class in examples.bankaccounts.domainmodel)
BankAccount.OverdraftLimitSet (class in examples.bankaccounts.domainmodel)
BankAccounts (class in examples.bankaccounts.application)
BaseAggregate (class in eventsourcing.domain)
BaseProjectionRunner (class in eventsourcing.projection)
body (examples.contentmanagement.domainmodel.Page attribute)
(examples.contentmanagement.domainmodel.Page.Created attribute)
(examples.ftscontentmanagement.persistence.PageInfo attribute)
body_updated() (examples.ftsprojection.projection.FtsProjection method)
book_new_cargo() (examples.cargoshipping.application.BookingApplication method)
(examples.cargoshipping.interface.BookingService method)
BookingApplication (class in examples.cargoshipping.application)
BookingService (class in examples.cargoshipping.interface)
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)
Cargo (class in examples.cargoshipping.domainmodel)
Cargo.BookingStarted (class in examples.cargoshipping.domainmodel)
Cargo.Created (class in examples.cargoshipping.domainmodel)
Cargo.DestinationChanged (class in examples.cargoshipping.domainmodel)
Cargo.Event (class in examples.cargoshipping.domainmodel)
Cargo.HandlingEventRegistered (class in examples.cargoshipping.domainmodel)
Cargo.RouteAssigned (class in examples.cargoshipping.domainmodel)
Cart (class in examples.shopstandard.domain)
Cart.Cleared (class in examples.shopstandard.domain)
Cart.Created (class in examples.shopstandard.domain)
Cart.Event (class in examples.shopstandard.domain)
Cart.ItemAdded (class in examples.shopstandard.domain)
Cart.ItemRemoved (class in examples.shopstandard.domain)
Cart.Submitted (class in examples.shopstandard.domain)
cart_id (examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart attribute)
(examples.shopvertical.slices.get_cart_items.query.GetCartItems attribute)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart attribute)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart attribute)
CartAlreadySubmittedError
,
[1]
CartFullError
,
[1]
CartItem (class in examples.shopstandard.domain)
(class in examples.shopvertical.slices.get_cart_items.query)
change_destination() (examples.cargoshipping.application.BookingApplication method)
(examples.cargoshipping.domainmodel.Cargo method)
(examples.cargoshipping.interface.BookingService method)
check_account_is_not_closed() (examples.bankaccounts.domainmodel.BankAccount method)
check_has_sufficient_funds() (examples.bankaccounts.domainmodel.BankAccount method)
check_table_name_length() (eventsourcing.postgres.PostgresRecorder static method)
Cipher (class in eventsourcing.persistence)
cipher() (eventsourcing.persistence.InfrastructureFactory method)
CLAIM (examples.cargoshipping.domainmodel.HandlingActivity attribute)
clear (examples.shopstandard.domain.Cart attribute)
clear_cart() (examples.shopstandard.application.Shop method)
ClearCart (class in examples.shopvertical.slices.clear_cart.cmd)
ClearedCart (class in examples.shopvertical.events)
close (examples.bankaccounts.domainmodel.BankAccount attribute)
close() (eventsourcing.persistence.ConnectionPool method)
(eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.postgres.PostgresDatastore method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.sqlite.SQLiteFactory method)
close_account() (examples.bankaccounts.application.BankAccounts method)
collect_events() (eventsourcing.application.ProcessingEvent method)
(eventsourcing.domain.BaseAggregate method)
(eventsourcing.domain.CollectEventsProtocol method)
(examples.aggregate4.baseclasses.Aggregate method)
CollectEventsProtocol (class in eventsourcing.domain)
Command (class in examples.shopvertical.common)
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)
(class in eventsourcing.postgres)
ConnectionPoolClosedError
ConnectionUnavailableError
construct() (eventsourcing.persistence.InfrastructureFactory class method)
construct_create_table_statements() (eventsourcing.postgres.PostgresRecorder 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.projection.EventSourcedProjection method)
construct_repository() (eventsourcing.application.Application method)
construct_snapshot_store() (eventsourcing.application.Application method)
construct_transcoder() (eventsourcing.application.Application method)
ContentManagement (class in examples.contentmanagement.application)
convert_notifications() (eventsourcing.system.Follower method)
ConvertingThread (class in eventsourcing.system)
create_diff() (in module examples.contentmanagement.utils)
create_id() (eventsourcing.domain.Aggregate static method)
(eventsourcing.domain.BaseAggregate static method)
(examples.aggregate10.mutablemodel.Aggregate class method)
(examples.aggregate11.domainmodel.Dog static method)
(examples.aggregate8.mutablemodel.Aggregate static method)
(examples.contentmanagement.domainmodel.Slug static method)
create_key() (eventsourcing.cipher.AESCipher static method)
(eventsourcing.cryptography.AESCipher static method)
create_page() (examples.contentmanagement.application.ContentManagement method)
CREATE_TABLE (eventsourcing.postgres.PostgresFactory attribute)
create_table() (eventsourcing.postgres.PostgresRecorder method)
(eventsourcing.postgres.PostgresTrackingRecorder method)
create_timestamp() (eventsourcing.domain.CanCreateTimestamp static method)
(examples.aggregate5.baseclasses.DomainEvent static method)
create_utc_datetime_now() (in module eventsourcing.domain)
created_on (eventsourcing.domain.BaseAggregate property)
(examples.aggregate10.mutablemodel.SnapshotState attribute)
(examples.aggregate4.baseclasses.Aggregate attribute)
(examples.aggregate5.baseclasses.Aggregate attribute)
(examples.aggregate6.baseclasses.Aggregate attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate9.immutablemodel.Aggregate attribute)
credit (examples.bankaccounts.domainmodel.BankAccount attribute)
current_voyage_number (examples.cargoshipping.domainmodel.Cargo property)
Cursor (class in eventsourcing.persistence)
cursor() (eventsourcing.persistence.Connection method)
(eventsourcing.sqlite.SQLiteConnection method)
D
DatabaseError
DataError
datetime_now_with_tzinfo() (in module eventsourcing.domain)
DatetimeAsISO (class in eventsourcing.persistence)
debit (examples.bankaccounts.domainmodel.BankAccount attribute)
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)
(examples.aggregate7.orjsonpydantic.OrjsonTranscoder method)
(examples.aggregate9.msgspecstructs.NullTranscoder method)
(examples.cargoshipping.application.HandlingActivityAsName method)
(examples.cargoshipping.application.ItineraryAsDict method)
(examples.cargoshipping.application.LegAsDict method)
(examples.cargoshipping.application.LocationAsName method)
decompress() (eventsourcing.compressor.ZlibCompressor method)
(eventsourcing.persistence.Compressor method)
DecoratorEvent (class in eventsourcing.domain)
decrypt() (eventsourcing.cipher.AESCipher method)
(eventsourcing.cryptography.AESCipher method)
(eventsourcing.persistence.Cipher method)
deposit_funds() (examples.bankaccounts.application.BankAccounts method)
description (examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
destination (examples.cargoshipping.domainmodel.Cargo property)
(examples.cargoshipping.domainmodel.Cargo.DestinationChanged attribute)
dict_from_itinerary() (examples.cargoshipping.interface.BookingService method)
Dog (class in examples.aggregate1.domainmodel)
(class in examples.aggregate10.domainmodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate2.domainmodel)
(class in examples.aggregate3.domainmodel)
(class in examples.aggregate4.domainmodel)
(class in examples.aggregate5.domainmodel)
(class in examples.aggregate6.domainmodel)
(class in examples.aggregate7.domainmodel)
(class in examples.aggregate8.domainmodel)
(class in examples.aggregate9.domainmodel)
Dog.Created (class in examples.aggregate1.domainmodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate2.domainmodel)
(class in examples.aggregate3.domainmodel)
(class in examples.aggregate8.domainmodel)
Dog.Event (class in examples.aggregate1.domainmodel)
(class in examples.aggregate10.domainmodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate2.domainmodel)
(class in examples.aggregate3.domainmodel)
(class in examples.aggregate8.domainmodel)
Dog.Registered (class in examples.aggregate1.domainmodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate2.domainmodel)
(class in examples.aggregate3.domainmodel)
(class in examples.aggregate4.domainmodel)
(class in examples.aggregate5.domainmodel)
(class in examples.aggregate8.domainmodel)
Dog.Snapshot (class in examples.aggregate8.domainmodel)
Dog.TrickAdded (class in examples.aggregate1.domainmodel)
(class in examples.aggregate10.domainmodel)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate2.domainmodel)
(class in examples.aggregate3.domainmodel)
(class in examples.aggregate4.domainmodel)
(class in examples.aggregate5.domainmodel)
(class in examples.aggregate8.domainmodel)
DogRegistered (class in examples.aggregate6.domainmodel)
(class in examples.aggregate7.domainmodel)
(class in examples.aggregate9.domainmodel)
DogSchool (class in examples.aggregate1.application)
(class in examples.aggregate10.application)
(class in examples.aggregate11.application)
(class in examples.aggregate2.application)
(class in examples.aggregate3.application)
(class in examples.aggregate4.application)
(class in examples.aggregate5.application)
(class in examples.aggregate6.application)
(class in examples.aggregate7.application)
(class in examples.aggregate8.application)
(class in examples.aggregate9.application)
DogSnapshotState (class in examples.aggregate10.domainmodel)
(class in examples.aggregate8.domainmodel)
domain_event (eventsourcing.persistence.Recording attribute)
DomainEvent (class in eventsourcing.domain)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate4.baseclasses)
(class in examples.aggregate5.baseclasses)
(class in examples.aggregate6.baseclasses)
(class in examples.aggregate7.immutablemodel)
(class in examples.aggregate9.immutablemodel)
(class in examples.shopvertical.events)
DomainEventProtocol (class in eventsourcing.domain)
E
email_address (examples.bankaccounts.domainmodel.BankAccount.Opened attribute)
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)
(examples.aggregate7.orjsonpydantic.OrjsonTranscoder method)
(examples.aggregate9.msgspecstructs.NullTranscoder method)
(examples.cargoshipping.application.HandlingActivityAsName method)
(examples.cargoshipping.application.ItineraryAsDict method)
(examples.cargoshipping.application.LegAsDict method)
(examples.cargoshipping.application.LocationAsName method)
encrypt() (eventsourcing.cipher.AESCipher method)
(eventsourcing.cryptography.AESCipher method)
(eventsourcing.persistence.Cipher method)
env (examples.aggregate7.orjsonpydantic.PydanticApplication attribute)
(examples.aggregate9.msgspecstructs.MsgspecApplication attribute)
(examples.contentmanagement.application.ContentManagement attribute)
(examples.ftscontentmanagement.test_application.TestWithPostgres attribute)
(examples.ftscontentmanagement.test_application.TestWithSQLite attribute)
(examples.ftsprocess.application.FtsProcess attribute)
(examples.ftsprocess.test_system.TestWithPostgres attribute)
(examples.ftsprocess.test_system.TestWithSQLite attribute)
(examples.ftsprojection.test_projection.TestFtsProjection attribute)
env_create_table() (eventsourcing.postgres.PostgresFactory method)
Environment (class in eventsourcing.utils)
estimated_time_of_arrival (examples.cargoshipping.domainmodel.Cargo property)
event() (in module eventsourcing.domain)
event_store() (eventsourcing.persistence.InfrastructureFactory method)
EventProcessingError
EventSourcedLog (class in eventsourcing.application)
EventSourcedProjection (class in eventsourcing.projection)
EventSourcedProjectionRunner (class in eventsourcing.projection)
eventsourcing.application
module
eventsourcing.cipher
module
eventsourcing.compressor
module
eventsourcing.cryptography
module
eventsourcing.dispatch
module
eventsourcing.domain
module
eventsourcing.interface
module
eventsourcing.persistence
module
eventsourcing.popo
module
eventsourcing.postgres
module
eventsourcing.projection
module
eventsourcing.sqlite
module
eventsourcing.system
module
eventsourcing.utils
module
EventSourcingError
EventsourcingType (class in eventsourcing.domain)
EventStore (class in eventsourcing.persistence)
examples.aggregate1.application
module
examples.aggregate1.domainmodel
module
examples.aggregate1.test_application
module
examples.aggregate10.application
module
examples.aggregate10.domainmodel
module
examples.aggregate10.mutablemodel
module
examples.aggregate10.test_application
module
examples.aggregate11.application
module
examples.aggregate11.domainmodel
module
examples.aggregate11.test_application
module
examples.aggregate2.application
module
examples.aggregate2.domainmodel
module
examples.aggregate2.test_application
module
examples.aggregate3.application
module
examples.aggregate3.domainmodel
module
examples.aggregate3.test_application
module
examples.aggregate4.application
module
examples.aggregate4.baseclasses
module
examples.aggregate4.domainmodel
module
examples.aggregate4.test_application
module
examples.aggregate5.application
module
examples.aggregate5.baseclasses
module
examples.aggregate5.domainmodel
module
examples.aggregate5.test_application
module
examples.aggregate6.application
module
examples.aggregate6.baseclasses
module
examples.aggregate6.domainmodel
module
examples.aggregate6.test_application
module
examples.aggregate7.application
module
examples.aggregate7.domainmodel
module
examples.aggregate7.immutablemodel
module
examples.aggregate7.orjsonpydantic
module
examples.aggregate7.test_application
module
examples.aggregate8.application
module
examples.aggregate8.domainmodel
module
examples.aggregate8.mutablemodel
module
examples.aggregate8.test_application
module
examples.aggregate9.application
module
examples.aggregate9.domainmodel
module
examples.aggregate9.immutablemodel
module
examples.aggregate9.msgspecstructs
module
examples.aggregate9.test_application
module
examples.bankaccounts.application
module
examples.bankaccounts.domainmodel
module
examples.bankaccounts.test
module
examples.cargoshipping.application
module
examples.cargoshipping.domainmodel
module
examples.cargoshipping.interface
module
examples.cargoshipping.test
module
examples.contentmanagement.application
module
examples.contentmanagement.domainmodel
module
examples.contentmanagement.test
module
examples.contentmanagement.utils
module
examples.ftscontentmanagement.application
module
examples.ftscontentmanagement.persistence
module
examples.ftscontentmanagement.postgres
module
examples.ftscontentmanagement.sqlite
module
examples.ftscontentmanagement.test_application
module
examples.ftsprocess.application
module
examples.ftsprocess.test_system
module
examples.ftsprojection.projection
module
examples.ftsprojection.test_projection
module
examples.shopstandard.application
module
examples.shopstandard.domain
module
examples.shopstandard.exceptions
module
examples.shopvertical.common
module
examples.shopvertical.events
module
examples.shopvertical.exceptions
module
examples.shopvertical.slices.add_item_to_cart.cmd
module
examples.shopvertical.slices.add_product_to_shop.cmd
module
examples.shopvertical.slices.adjust_product_inventory.cmd
module
examples.shopvertical.slices.clear_cart.cmd
module
examples.shopvertical.slices.get_cart_items.query
module
examples.shopvertical.slices.list_products_in_shop.query
module
examples.shopvertical.slices.remove_item_from_cart.cmd
module
examples.shopvertical.slices.submit_cart.cmd
module
execute() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
(examples.shopvertical.common.Command method)
(examples.shopvertical.common.Query method)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart method)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop method)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory method)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart method)
(examples.shopvertical.slices.get_cart_items.query.GetCartItems method)
(examples.shopvertical.slices.list_products_in_shop.query.ListProductsInShop method)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart method)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart method)
F
Factory (in module eventsourcing.popo)
(in module eventsourcing.postgres)
(in module eventsourcing.sqlite)
fetchall() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
fetchone() (eventsourcing.persistence.Cursor method)
(eventsourcing.sqlite.SQLiteCursor method)
find_originator_id_type() (eventsourcing.domain.HasOriginatorIDVersion class method)
follow() (eventsourcing.system.Follower method)
Follower (class in eventsourcing.system)
FtsContentManagement (class in examples.ftscontentmanagement.application)
FtsProcess (class in examples.ftsprocess.application)
FtsProjection (class in examples.ftsprojection.projection)
FtsRecorder (class in examples.ftscontentmanagement.persistence)
FtsViewInterface (class in examples.ftsprojection.projection)
full_name (examples.bankaccounts.domainmodel.BankAccount.Opened attribute)
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_account() (examples.bankaccounts.application.BankAccounts method)
get_all_events() (in module examples.shopvertical.common)
get_balance() (examples.bankaccounts.application.BankAccounts method)
get_cargo() (examples.cargoshipping.application.BookingApplication method)
get_cargo_details() (examples.cargoshipping.interface.BookingService method)
get_cart_items() (examples.shopstandard.application.Shop method)
get_connection() (eventsourcing.persistence.ConnectionPool method)
(eventsourcing.postgres.PostgresDatastore method)
get_dog() (examples.aggregate1.application.DogSchool method)
(examples.aggregate10.application.DogSchool method)
(examples.aggregate11.application.DogSchool method)
(examples.aggregate2.application.DogSchool method)
(examples.aggregate3.application.DogSchool method)
(examples.aggregate4.application.DogSchool method)
(examples.aggregate5.application.DogSchool method)
(examples.aggregate6.application.DogSchool method)
(examples.aggregate7.application.DogSchool method)
(examples.aggregate8.application.DogSchool method)
(examples.aggregate9.application.DogSchool method)
get_events() (in module examples.shopvertical.common)
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_overdraft_limit() (examples.bankaccounts.application.BankAccounts method)
get_page_by_id() (examples.contentmanagement.application.ContentManagement method)
get_page_by_slug() (examples.contentmanagement.application.ContentManagement method)
get_pages() (examples.contentmanagement.application.ContentManagement method)
get_topic() (in module eventsourcing.utils)
GetCartItems (class in examples.shopvertical.slices.get_cart_items.query)
H
HAMBURG (examples.cargoshipping.domainmodel.Location attribute)
handle() (examples.shopvertical.common.Command method)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart method)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop method)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory method)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart method)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart method)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart method)
handling_activity (examples.cargoshipping.domainmodel.Cargo.HandlingEventRegistered attribute)
HandlingActivity (class in examples.cargoshipping.domainmodel)
HandlingActivityAsName (class in examples.cargoshipping.application)
has_tracking_id() (eventsourcing.persistence.TrackingRecorder method)
(eventsourcing.postgres.PostgresTrackingRecorder method)
HasOriginatorIDVersion (class in eventsourcing.domain)
HONGKONG (examples.cargoshipping.domainmodel.Location attribute)
I
id (eventsourcing.domain.BaseAggregate property)
(eventsourcing.domain.ImmutableAggregateProtocol property)
(eventsourcing.domain.MutableAggregateProtocol property)
(eventsourcing.persistence.Notification attribute)
(examples.aggregate4.baseclasses.Aggregate attribute)
(examples.aggregate5.baseclasses.Aggregate attribute)
(examples.aggregate6.baseclasses.Aggregate attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate9.immutablemodel.Aggregate attribute)
(examples.ftscontentmanagement.persistence.PageInfo attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
Immutable (class in examples.aggregate7.immutablemodel)
(class in examples.aggregate9.immutablemodel)
ImmutableAggregateProtocol (class in eventsourcing.domain)
InfrastructureFactory (class in eventsourcing.persistence)
InfrastructureFactoryError
INITIAL_VERSION (examples.aggregate11.domainmodel.Dog attribute)
insert_events() (eventsourcing.persistence.AggregateRecorder method)
(eventsourcing.popo.POPOAggregateRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.postgres.PostgresAggregateRecorder method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
insert_pages() (examples.ftscontentmanagement.persistence.FtsRecorder method)
(examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)
insert_pages_with_tracking() (examples.ftsprojection.projection.FtsViewInterface method)
(examples.ftsprojection.projection.PostgresFtsView method)
insert_tracking() (eventsourcing.persistence.TrackingRecorder method)
(eventsourcing.popo.POPOTrackingRecorder method)
(eventsourcing.postgres.PostgresTrackingRecorder method)
(eventsourcing.sqlite.SQLiteTrackingRecorder method)
InsufficientFundsError
InsufficientInventoryError
,
[1]
IntegrityError
InterfaceError
InternalError
inventory (examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
is_interrupted (eventsourcing.projection.BaseProjectionRunner property)
is_misdirected (examples.cargoshipping.domainmodel.Cargo property)
is_snapshotting_enabled (examples.aggregate1.application.DogSchool attribute)
(examples.aggregate10.application.DogSchool attribute)
(examples.aggregate11.application.DogSchool attribute)
(examples.aggregate2.application.DogSchool attribute)
(examples.aggregate3.application.DogSchool attribute)
(examples.aggregate4.application.DogSchool attribute)
(examples.aggregate5.application.DogSchool attribute)
(examples.aggregate6.application.DogSchool attribute)
(examples.aggregate7.application.DogSchool attribute)
(examples.aggregate8.application.DogSchool attribute)
(examples.aggregate9.application.DogSchool attribute)
is_snapshotting_enabled() (eventsourcing.persistence.InfrastructureFactory method)
Itinerary (class in examples.cargoshipping.domainmodel)
ItineraryAsDict (class in examples.cargoshipping.application)
J
JSONTranscoder (class in eventsourcing.persistence)
L
last_known_location (examples.cargoshipping.domainmodel.Cargo property)
lead() (eventsourcing.system.Leader method)
Leader (class in eventsourcing.system)
Leg (class in examples.cargoshipping.domainmodel)
LegAsDict (class in examples.cargoshipping.application)
list_products_in_shop() (examples.shopstandard.application.Shop method)
ListenNotifySubscription (class in eventsourcing.persistence)
ListProductsInShop (class in examples.shopvertical.slices.list_products_in_shop.query)
LOAD (examples.cargoshipping.domainmodel.HandlingActivity attribute)
LocalNotificationLog (class in eventsourcing.application)
Location (class in examples.cargoshipping.domainmodel)
location (examples.cargoshipping.domainmodel.Cargo.HandlingEventRegistered attribute)
LocationAsName (class in examples.cargoshipping.application)
LogEvent (class in eventsourcing.domain)
LRUCache (class in eventsourcing.application)
M
Mapper (class in eventsourcing.persistence)
mapper() (eventsourcing.persistence.InfrastructureFactory method)
MapperDeserialisationError
MAX_IDENTIFIER_LEN (eventsourcing.postgres.PostgresRecorder attribute)
max_notification_id() (eventsourcing.persistence.ApplicationRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.postgres.PostgresApplicationRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
max_tracking_id() (eventsourcing.persistence.TrackingRecorder method)
(eventsourcing.popo.POPOTrackingRecorder method)
(eventsourcing.postgres.PostgresTrackingRecorder method)
(eventsourcing.sqlite.SQLiteTrackingRecorder method)
MetaAggregate (class in eventsourcing.domain)
MetaDomainEvent (class in eventsourcing.domain)
model_computed_fields (examples.aggregate7.domainmodel.Dog attribute)
(examples.aggregate7.domainmodel.DogRegistered attribute)
(examples.aggregate7.domainmodel.Trick attribute)
(examples.aggregate7.domainmodel.TrickAdded attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate7.immutablemodel.Immutable attribute)
(examples.aggregate7.immutablemodel.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.Created attribute)
(examples.aggregate8.domainmodel.Dog.Event attribute)
(examples.aggregate8.domainmodel.Dog.Registered attribute)
(examples.aggregate8.domainmodel.Dog.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate8.domainmodel.DogSnapshotState attribute)
(examples.aggregate8.domainmodel.Trick attribute)
(examples.aggregate8.mutablemodel.Aggregate.Created attribute)
(examples.aggregate8.mutablemodel.Aggregate.Event attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate8.mutablemodel.SnapshotState attribute)
(examples.shopstandard.domain.Cart.Cleared attribute)
(examples.shopstandard.domain.Cart.Created attribute)
(examples.shopstandard.domain.Cart.Event attribute)
(examples.shopstandard.domain.Cart.ItemAdded attribute)
(examples.shopstandard.domain.Cart.ItemRemoved attribute)
(examples.shopstandard.domain.Cart.Submitted attribute)
(examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.Product.Event attribute)
(examples.shopstandard.domain.Product.InventoryAdjusted attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.common.Command attribute)
(examples.shopvertical.common.Query attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.events.AdjustedProductInventory attribute)
(examples.shopvertical.events.ClearedCart attribute)
(examples.shopvertical.events.DomainEvent attribute)
(examples.shopvertical.events.RemovedItemFromCart attribute)
(examples.shopvertical.events.SubmittedCart attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory attribute)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.get_cart_items.query.GetCartItems attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ListProductsInShop attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart attribute)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart attribute)
model_config (examples.aggregate7.domainmodel.Dog attribute)
(examples.aggregate7.domainmodel.DogRegistered attribute)
(examples.aggregate7.domainmodel.Trick attribute)
(examples.aggregate7.domainmodel.TrickAdded attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate7.immutablemodel.Immutable attribute)
(examples.aggregate7.immutablemodel.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.Created attribute)
(examples.aggregate8.domainmodel.Dog.Event attribute)
(examples.aggregate8.domainmodel.Dog.Registered attribute)
(examples.aggregate8.domainmodel.Dog.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate8.domainmodel.DogSnapshotState attribute)
(examples.aggregate8.domainmodel.Trick attribute)
(examples.aggregate8.mutablemodel.Aggregate.Created attribute)
(examples.aggregate8.mutablemodel.Aggregate.Event attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate8.mutablemodel.SnapshotState attribute)
(examples.shopstandard.domain.Cart.Cleared attribute)
(examples.shopstandard.domain.Cart.Created attribute)
(examples.shopstandard.domain.Cart.Event attribute)
(examples.shopstandard.domain.Cart.ItemAdded attribute)
(examples.shopstandard.domain.Cart.ItemRemoved attribute)
(examples.shopstandard.domain.Cart.Submitted attribute)
(examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.Product.Event attribute)
(examples.shopstandard.domain.Product.InventoryAdjusted attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.common.Command attribute)
(examples.shopvertical.common.Query attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.events.AdjustedProductInventory attribute)
(examples.shopvertical.events.ClearedCart attribute)
(examples.shopvertical.events.DomainEvent attribute)
(examples.shopvertical.events.RemovedItemFromCart attribute)
(examples.shopvertical.events.SubmittedCart attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory attribute)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.get_cart_items.query.GetCartItems attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ListProductsInShop attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart attribute)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart attribute)
model_fields (examples.aggregate7.domainmodel.Dog attribute)
(examples.aggregate7.domainmodel.DogRegistered attribute)
(examples.aggregate7.domainmodel.Trick attribute)
(examples.aggregate7.domainmodel.TrickAdded attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate7.immutablemodel.Immutable attribute)
(examples.aggregate7.immutablemodel.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.Created attribute)
(examples.aggregate8.domainmodel.Dog.Event attribute)
(examples.aggregate8.domainmodel.Dog.Registered attribute)
(examples.aggregate8.domainmodel.Dog.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate8.domainmodel.DogSnapshotState attribute)
(examples.aggregate8.domainmodel.Trick attribute)
(examples.aggregate8.mutablemodel.Aggregate.Created attribute)
(examples.aggregate8.mutablemodel.Aggregate.Event attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate8.mutablemodel.SnapshotState attribute)
(examples.shopstandard.domain.Cart.Cleared attribute)
(examples.shopstandard.domain.Cart.Created attribute)
(examples.shopstandard.domain.Cart.Event attribute)
(examples.shopstandard.domain.Cart.ItemAdded attribute)
(examples.shopstandard.domain.Cart.ItemRemoved attribute)
(examples.shopstandard.domain.Cart.Submitted attribute)
(examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.Product.Event attribute)
(examples.shopstandard.domain.Product.InventoryAdjusted attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.common.Command attribute)
(examples.shopvertical.common.Query attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.events.AdjustedProductInventory attribute)
(examples.shopvertical.events.ClearedCart attribute)
(examples.shopvertical.events.DomainEvent attribute)
(examples.shopvertical.events.RemovedItemFromCart attribute)
(examples.shopvertical.events.SubmittedCart attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory attribute)
(examples.shopvertical.slices.clear_cart.cmd.ClearCart attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.get_cart_items.query.GetCartItems attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ListProductsInShop attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart attribute)
(examples.shopvertical.slices.submit_cart.cmd.SubmitCart attribute)
modified_by (examples.contentmanagement.domainmodel.Page attribute)
modified_on (eventsourcing.domain.BaseAggregate property)
(examples.aggregate10.mutablemodel.SnapshotState attribute)
(examples.aggregate4.baseclasses.Aggregate attribute)
(examples.aggregate5.baseclasses.Aggregate attribute)
(examples.aggregate6.baseclasses.Aggregate attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate9.immutablemodel.Aggregate attribute)
module
eventsourcing.application
eventsourcing.cipher
eventsourcing.compressor
eventsourcing.cryptography
eventsourcing.dispatch
eventsourcing.domain
eventsourcing.interface
eventsourcing.persistence
eventsourcing.popo
eventsourcing.postgres
eventsourcing.projection
eventsourcing.sqlite
eventsourcing.system
eventsourcing.utils
examples.aggregate1.application
examples.aggregate1.domainmodel
examples.aggregate1.test_application
examples.aggregate10.application
examples.aggregate10.domainmodel
examples.aggregate10.mutablemodel
examples.aggregate10.test_application
examples.aggregate11.application
examples.aggregate11.domainmodel
examples.aggregate11.test_application
examples.aggregate2.application
examples.aggregate2.domainmodel
examples.aggregate2.test_application
examples.aggregate3.application
examples.aggregate3.domainmodel
examples.aggregate3.test_application
examples.aggregate4.application
examples.aggregate4.baseclasses
examples.aggregate4.domainmodel
examples.aggregate4.test_application
examples.aggregate5.application
examples.aggregate5.baseclasses
examples.aggregate5.domainmodel
examples.aggregate5.test_application
examples.aggregate6.application
examples.aggregate6.baseclasses
examples.aggregate6.domainmodel
examples.aggregate6.test_application
examples.aggregate7.application
examples.aggregate7.domainmodel
examples.aggregate7.immutablemodel
examples.aggregate7.orjsonpydantic
examples.aggregate7.test_application
examples.aggregate8.application
examples.aggregate8.domainmodel
examples.aggregate8.mutablemodel
examples.aggregate8.test_application
examples.aggregate9.application
examples.aggregate9.domainmodel
examples.aggregate9.immutablemodel
examples.aggregate9.msgspecstructs
examples.aggregate9.test_application
examples.bankaccounts.application
examples.bankaccounts.domainmodel
examples.bankaccounts.test
examples.cargoshipping.application
examples.cargoshipping.domainmodel
examples.cargoshipping.interface
examples.cargoshipping.test
examples.contentmanagement.application
examples.contentmanagement.domainmodel
examples.contentmanagement.test
examples.contentmanagement.utils
examples.ftscontentmanagement.application
examples.ftscontentmanagement.persistence
examples.ftscontentmanagement.postgres
examples.ftscontentmanagement.sqlite
examples.ftscontentmanagement.test_application
examples.ftsprocess.application
examples.ftsprocess.test_system
examples.ftsprojection.projection
examples.ftsprojection.test_projection
examples.shopstandard.application
examples.shopstandard.domain
examples.shopstandard.exceptions
examples.shopvertical.common
examples.shopvertical.events
examples.shopvertical.exceptions
examples.shopvertical.slices.add_item_to_cart.cmd
examples.shopvertical.slices.add_product_to_shop.cmd
examples.shopvertical.slices.adjust_product_inventory.cmd
examples.shopvertical.slices.clear_cart.cmd
examples.shopvertical.slices.get_cart_items.query
examples.shopvertical.slices.list_products_in_shop.query
examples.shopvertical.slices.remove_item_from_cart.cmd
examples.shopvertical.slices.submit_cart.cmd
MsgspecApplication (class in examples.aggregate9.msgspecstructs)
MsgspecMapper (class in examples.aggregate9.msgspecstructs)
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)
(examples.aggregate10.mutablemodel.AggregateSnapshot method)
(examples.aggregate5.baseclasses.Aggregate method)
(examples.aggregate5.domainmodel.Dog method)
mutate_dog() (in module examples.aggregate6.domainmodel)
(in module examples.aggregate7.domainmodel)
(in module examples.aggregate9.domainmodel)
N
name (eventsourcing.projection.EventSourcedProjection attribute)
(eventsourcing.projection.Projection attribute)
(examples.aggregate1.application.DogSchool attribute)
(examples.aggregate1.domainmodel.Dog.Registered attribute)
(examples.aggregate10.application.DogSchool attribute)
(examples.aggregate10.domainmodel.DogSnapshotState attribute)
(examples.aggregate10.domainmodel.Trick attribute)
(examples.aggregate11.application.DogSchool attribute)
(examples.aggregate11.domainmodel.Dog.Registered attribute)
(examples.aggregate2.application.DogSchool attribute)
(examples.aggregate3.application.DogSchool attribute)
(examples.aggregate3.domainmodel.Dog.Registered attribute)
(examples.aggregate4.application.DogSchool attribute)
(examples.aggregate4.domainmodel.Dog attribute)
(examples.aggregate4.domainmodel.Dog.Registered attribute)
(examples.aggregate5.application.DogSchool attribute)
(examples.aggregate5.domainmodel.Dog attribute)
(examples.aggregate5.domainmodel.Dog.Registered attribute)
(examples.aggregate6.application.DogSchool attribute)
(examples.aggregate6.domainmodel.Dog attribute)
(examples.aggregate6.domainmodel.DogRegistered attribute)
(examples.aggregate7.application.DogSchool attribute)
(examples.aggregate7.domainmodel.Dog attribute)
(examples.aggregate7.domainmodel.DogRegistered attribute)
(examples.aggregate7.domainmodel.Trick attribute)
(examples.aggregate7.orjsonpydantic.PydanticApplication attribute)
(examples.aggregate8.application.DogSchool attribute)
(examples.aggregate8.domainmodel.Dog.Registered attribute)
(examples.aggregate8.domainmodel.DogSnapshotState attribute)
(examples.aggregate8.domainmodel.Trick attribute)
(examples.aggregate9.application.DogSchool attribute)
(examples.aggregate9.domainmodel.Dog attribute)
(examples.aggregate9.domainmodel.DogRegistered attribute)
(examples.aggregate9.domainmodel.Trick attribute)
(examples.aggregate9.msgspecstructs.MsgspecApplication attribute)
(examples.bankaccounts.application.BankAccounts attribute)
(examples.cargoshipping.application.BookingApplication attribute)
(examples.cargoshipping.application.HandlingActivityAsName attribute)
(examples.cargoshipping.application.ItineraryAsDict attribute)
(examples.cargoshipping.application.LegAsDict attribute)
(examples.cargoshipping.application.LocationAsName attribute)
(examples.contentmanagement.application.ContentManagement attribute)
(examples.contentmanagement.domainmodel.Slug attribute)
(examples.contentmanagement.domainmodel.Slug.Created attribute)
(examples.ftscontentmanagement.application.FtsContentManagement attribute)
(examples.ftsprocess.application.FtsProcess attribute)
(examples.ftsprojection.projection.FtsProjection attribute)
(examples.shopstandard.application.Shop attribute)
(examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
new_booking() (examples.cargoshipping.domainmodel.Cargo class method)
NewMultiThreadedRunner (class in eventsourcing.system)
NewSingleThreadedRunner (class in eventsourcing.system)
NEWYORK (examples.cargoshipping.domainmodel.Location attribute)
next_expected_activity (examples.cargoshipping.domainmodel.Cargo property)
NLRTM (examples.cargoshipping.domainmodel.Location attribute)
Notification (class in eventsourcing.persistence)
notification (eventsourcing.persistence.Recording attribute)
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
NullTranscoder (class in examples.aggregate9.msgspecstructs)
num_in_pool (eventsourcing.persistence.ConnectionPool property)
num_in_use (eventsourcing.persistence.ConnectionPool property)
O
open_account() (examples.bankaccounts.application.BankAccounts method)
OperationalError
origin (examples.cargoshipping.domainmodel.Cargo property)
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.persistence.StoredEvent attribute)
(examples.aggregate11.domainmodel.Aggregate.Event attribute)
(examples.aggregate11.domainmodel.DomainEvent attribute)
(examples.aggregate3.domainmodel.Dog.Event attribute)
(examples.aggregate4.baseclasses.DomainEvent attribute)
(examples.aggregate5.baseclasses.DomainEvent attribute)
(examples.aggregate6.baseclasses.DomainEvent attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate9.immutablemodel.DomainEvent attribute)
(examples.cargoshipping.domainmodel.Cargo.Event attribute)
(examples.contentmanagement.domainmodel.Slug.Event attribute)
(examples.shopvertical.events.ClearedCart attribute)
(examples.shopvertical.events.DomainEvent attribute)
(examples.shopvertical.events.SubmittedCart attribute)
originator_id_type (eventsourcing.domain.Aggregate.Created attribute)
(eventsourcing.domain.Aggregate.Event attribute)
(eventsourcing.domain.Aggregate.Snapshot attribute)
(eventsourcing.domain.AggregateCreated attribute)
(eventsourcing.domain.AggregateEvent attribute)
(eventsourcing.domain.Snapshot attribute)
(examples.aggregate1.domainmodel.Dog.Created attribute)
(examples.aggregate1.domainmodel.Dog.Event attribute)
(examples.aggregate1.domainmodel.Dog.Registered attribute)
(examples.aggregate10.domainmodel.Dog.Event attribute)
(examples.aggregate10.mutablemodel.Aggregate.Created attribute)
(examples.aggregate10.mutablemodel.Aggregate.Event attribute)
(examples.aggregate10.mutablemodel.AggregateEvent attribute)
(examples.aggregate10.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate11.domainmodel.Aggregate.Created attribute)
(examples.aggregate11.domainmodel.Aggregate.Event attribute)
(examples.aggregate11.domainmodel.Dog.Created attribute)
(examples.aggregate11.domainmodel.Dog.Event attribute)
(examples.aggregate11.domainmodel.Dog.Registered attribute)
(examples.aggregate11.domainmodel.Snapshot attribute)
(examples.aggregate2.domainmodel.Dog.Created attribute)
(examples.aggregate2.domainmodel.Dog.Event attribute)
(examples.aggregate2.domainmodel.Dog.Registered attribute)
(examples.aggregate3.domainmodel.Dog.Created attribute)
(examples.aggregate3.domainmodel.Dog.Event attribute)
(examples.aggregate3.domainmodel.Dog.Registered attribute)
(examples.aggregate3.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate8.domainmodel.Dog.Created attribute)
(examples.aggregate8.domainmodel.Dog.Event attribute)
(examples.aggregate8.domainmodel.Dog.Registered attribute)
(examples.aggregate8.domainmodel.Dog.Snapshot attribute)
(examples.aggregate8.mutablemodel.Aggregate.Created attribute)
(examples.aggregate8.mutablemodel.Aggregate.Event attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.bankaccounts.domainmodel.BankAccount.Created attribute)
(examples.bankaccounts.domainmodel.BankAccount.Event attribute)
(examples.bankaccounts.domainmodel.BankAccount.Opened attribute)
(examples.cargoshipping.domainmodel.Cargo.BookingStarted attribute)
(examples.cargoshipping.domainmodel.Cargo.Created attribute)
(examples.cargoshipping.domainmodel.Cargo.DestinationChanged attribute)
(examples.cargoshipping.domainmodel.Cargo.Event attribute)
(examples.cargoshipping.domainmodel.Cargo.HandlingEventRegistered attribute)
(examples.cargoshipping.domainmodel.Cargo.RouteAssigned attribute)
(examples.contentmanagement.domainmodel.Page.Created attribute)
(examples.contentmanagement.domainmodel.Page.Event attribute)
(examples.contentmanagement.domainmodel.Slug.Created attribute)
(examples.contentmanagement.domainmodel.Slug.Event attribute)
(examples.shopstandard.domain.Cart.Created attribute)
(examples.shopstandard.domain.Cart.Event attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.Product.Event attribute)
originator_topic (eventsourcing.domain.AggregateCreated attribute)
(eventsourcing.domain.CanInitAggregate attribute)
(examples.aggregate10.mutablemodel.Aggregate.Created attribute)
(examples.aggregate11.domainmodel.Aggregate.Created attribute)
(examples.aggregate8.mutablemodel.Aggregate.Created 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.persistence.StoredEvent attribute)
(examples.aggregate11.domainmodel.Aggregate.Event attribute)
(examples.aggregate11.domainmodel.DomainEvent attribute)
(examples.aggregate3.domainmodel.Dog.Event attribute)
(examples.aggregate4.baseclasses.DomainEvent attribute)
(examples.aggregate5.baseclasses.DomainEvent attribute)
(examples.aggregate6.baseclasses.DomainEvent attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate9.immutablemodel.DomainEvent attribute)
(examples.cargoshipping.domainmodel.Cargo.Event attribute)
(examples.contentmanagement.domainmodel.Slug.Event attribute)
(examples.shopvertical.events.ClearedCart attribute)
(examples.shopvertical.events.DomainEvent attribute)
(examples.shopvertical.events.SubmittedCart attribute)
OriginatorIDError
OriginatorVersionError
OrjsonTranscoder (class in examples.aggregate7.orjsonpydantic)
overdraft_limit (examples.bankaccounts.domainmodel.BankAccount.OverdraftLimitSet attribute)
P
Page (class in examples.contentmanagement.domainmodel)
Page.BodyUpdated (class in examples.contentmanagement.domainmodel)
Page.Created (class in examples.contentmanagement.domainmodel)
Page.Event (class in examples.contentmanagement.domainmodel)
Page.SlugUpdated (class in examples.contentmanagement.domainmodel)
Page.TitleUpdated (class in examples.contentmanagement.domainmodel)
page_created() (examples.ftsprojection.projection.FtsProjection method)
page_id (examples.contentmanagement.domainmodel.PageLogged attribute)
(examples.contentmanagement.domainmodel.Slug attribute)
(examples.contentmanagement.domainmodel.Slug.Created attribute)
(examples.contentmanagement.domainmodel.Slug.PageUpdated attribute)
PageInfo (class in examples.ftscontentmanagement.persistence)
PageLogged (class in examples.contentmanagement.domainmodel)
PageNotFoundError
pending_events (eventsourcing.domain.BaseAggregate property)
PersistenceError
policy() (eventsourcing.projection.EventSourcedProjection method)
(examples.ftsprocess.application.FtsProcess method)
POPOAggregateRecorder (class in eventsourcing.popo)
POPOApplicationRecorder (class in eventsourcing.popo)
POPOFactory (class in eventsourcing.popo)
POPOProcessRecorder (class in eventsourcing.popo)
POPOSubscription (class in eventsourcing.popo)
POPOTrackingRecorder (class in eventsourcing.popo)
POSTGRES_CONN_MAX_AGE (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_CONNECT_TIMEOUT (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_DBNAME (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_GET_PASSWORD_TOPIC (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_HOST (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_IDLE_IN_TRANSACTION_SESSION_TIMEOUT (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_LOCK_TIMEOUT (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_MAX_OVERFLOW (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_MAX_WAITING (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_PASSWORD (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_POOL_SIZE (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_PORT (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_PRE_PING (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_SCHEMA (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_SINGLE_ROW_TRACKING (eventsourcing.postgres.PostgresFactory attribute)
POSTGRES_USER (eventsourcing.postgres.PostgresFactory attribute)
PostgresAggregateRecorder (class in eventsourcing.postgres)
PostgresApplicationRecorder (class in eventsourcing.postgres)
PostgresDatastore (class in eventsourcing.postgres)
PostgresFactory (class in eventsourcing.postgres)
PostgresFtsApplicationRecorder (class in examples.ftscontentmanagement.postgres)
PostgresFtsRecorder (class in examples.ftscontentmanagement.postgres)
PostgresFtsView (class in examples.ftsprojection.projection)
PostgresProcessRecorder (class in eventsourcing.postgres)
PostgresRecorder (class in eventsourcing.postgres)
PostgresSubscription (class in eventsourcing.postgres)
PostgresTrackingRecorder (class in eventsourcing.postgres)
price (examples.shopstandard.domain.CartItem attribute)
(examples.shopstandard.domain.Product.Created attribute)
(examples.shopstandard.domain.ProductDetails attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.AddedProductToShop attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute)
process_event() (eventsourcing.projection.EventSourcedProjection method)
(eventsourcing.projection.Projection method)
(eventsourcing.system.Follower method)
(examples.ftsprojection.projection.FtsProjection method)
process_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.POPOFactory method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.sqlite.SQLiteFactory method)
process_recorder_class (eventsourcing.postgres.PostgresFactory attribute)
(eventsourcing.sqlite.SQLiteFactory attribute)
ProcessApplication (class in eventsourcing.system)
ProcessingEvent (class in eventsourcing.application)
ProcessingThread (class in eventsourcing.system)
ProcessRecorder (class in eventsourcing.persistence)
Product (class in examples.shopstandard.domain)
Product.Created (class in examples.shopstandard.domain)
Product.Event (class in examples.shopstandard.domain)
Product.InventoryAdjusted (class in examples.shopstandard.domain)
product_id (examples.shopstandard.domain.CartItem attribute)
(examples.shopvertical.events.AddedItemToCart attribute)
(examples.shopvertical.events.RemovedItemFromCart attribute)
(examples.shopvertical.slices.add_item_to_cart.cmd.AddItemToCart attribute)
(examples.shopvertical.slices.add_product_to_shop.cmd.AddProductToShop attribute)
(examples.shopvertical.slices.adjust_product_inventory.cmd.AdjustProductInventory attribute)
(examples.shopvertical.slices.get_cart_items.query.CartItem attribute)
(examples.shopvertical.slices.remove_item_from_cart.cmd.RemoveItemFromCart attribute)
ProductAlreadyInShopError
,
[1]
ProductDetails (class in examples.shopstandard.domain)
(class in examples.shopvertical.slices.list_products_in_shop.query)
ProductNotFoundInShopError
,
[1]
ProductNotInCartError
,
[1]
ProgrammingError
,
[1]
,
[2]
project_aggregate() (in module eventsourcing.application)
project_events() (examples.aggregate4.baseclasses.Aggregate class method)
Projection (class in eventsourcing.projection)
projection() (examples.shopvertical.slices.get_cart_items.query.GetCartItems static method)
(examples.shopvertical.slices.list_products_in_shop.query.ListProductsInShop static method)
ProjectionRunner (class in eventsourcing.projection)
projector() (examples.aggregate5.baseclasses.Aggregate class method)
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)
put_events() (in module examples.shopvertical.common)
PydanticApplication (class in examples.aggregate7.orjsonpydantic)
PydanticMapper (class in examples.aggregate7.orjsonpydantic)
Q
Query (class in examples.shopvertical.common)
R
random() (in module eventsourcing.utils)
read() (eventsourcing.system.NotificationLogReader method)
RECEIVE (examples.cargoshipping.domainmodel.HandlingActivity attribute)
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)
RecordingEvent (class in eventsourcing.system)
RecordingEventReceiver (class in eventsourcing.system)
register() (eventsourcing.dispatch.singledispatchmethod method)
(eventsourcing.persistence.JSONTranscoder method)
(examples.aggregate3.domainmodel.Dog class method)
(examples.aggregate4.domainmodel.Dog class method)
(examples.aggregate5.domainmodel.Dog static method)
register_dog() (examples.aggregate1.application.DogSchool method)
(examples.aggregate10.application.DogSchool method)
(examples.aggregate11.application.DogSchool method)
(examples.aggregate2.application.DogSchool method)
(examples.aggregate3.application.DogSchool method)
(examples.aggregate4.application.DogSchool method)
(examples.aggregate5.application.DogSchool method)
(examples.aggregate6.application.DogSchool method)
(examples.aggregate7.application.DogSchool method)
(examples.aggregate8.application.DogSchool method)
(examples.aggregate9.application.DogSchool method)
(in module examples.aggregate6.domainmodel)
(in module examples.aggregate7.domainmodel)
(in module examples.aggregate9.domainmodel)
register_handling_event() (examples.cargoshipping.application.BookingApplication method)
(examples.cargoshipping.domainmodel.Cargo method)
(examples.cargoshipping.interface.BookingService method)
register_topic() (in module eventsourcing.utils)
register_transcodings() (eventsourcing.application.Application method)
(examples.cargoshipping.application.BookingApplication method)
remove_item (examples.shopstandard.domain.Cart attribute)
remove_item_from_cart() (examples.shopstandard.application.Shop method)
RemovedItemFromCart (class in examples.shopvertical.events)
RemoveItemFromCart (class in examples.shopvertical.slices.remove_item_from_cart.cmd)
Repository (class in eventsourcing.application)
repository (eventsourcing.application.Application property)
request_possible_routes_for_cargo() (examples.cargoshipping.application.BookingApplication method)
(examples.cargoshipping.interface.BookingService method)
reset_application() (in module examples.shopvertical.common)
resolve_topic() (in module eventsourcing.utils)
retry() (in module eventsourcing.utils)
rollback() (eventsourcing.persistence.Connection method)
(eventsourcing.sqlite.SQLiteConnection method)
route (examples.cargoshipping.domainmodel.Cargo property)
(examples.cargoshipping.domainmodel.Cargo.RouteAssigned attribute)
routing_status (examples.cargoshipping.domainmodel.Cargo property)
run() (eventsourcing.system.ConvertingThread method)
(eventsourcing.system.MultiThreadedRunnerThread method)
(eventsourcing.system.ProcessingThread method)
(eventsourcing.system.PullingThread method)
(in module examples.contentmanagement.utils)
run_forever() (eventsourcing.projection.BaseProjectionRunner method)
Runner (class in eventsourcing.system)
RunnerAlreadyStartedError
S
save() (eventsourcing.application.Application method)
(eventsourcing.system.Leader method)
(examples.ftscontentmanagement.application.FtsContentManagement method)
search() (examples.ftscontentmanagement.application.FtsContentManagement method)
(examples.ftscontentmanagement.persistence.FtsRecorder method)
(examples.ftsprocess.application.FtsProcess method)
search_pages() (examples.ftscontentmanagement.persistence.FtsRecorder method)
(examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder 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.postgres.PostgresAggregateRecorder method)
(eventsourcing.sqlite.SQLiteAggregateRecorder method)
select_notifications() (eventsourcing.persistence.ApplicationRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.postgres.PostgresApplicationRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
select_page() (examples.ftscontentmanagement.persistence.FtsRecorder method)
(examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)
select_preferred_itinerary() (in module examples.cargoshipping.interface)
set_overdraft_limit (examples.bankaccounts.domainmodel.BankAccount attribute)
set_overdraft_limit() (examples.bankaccounts.application.BankAccounts method)
setUp() (examples.aggregate11.test_application.TestDogSchool method)
(examples.cargoshipping.test.TestBookingService method)
(examples.ftscontentmanagement.test_application.TestWithPostgres method)
(examples.ftsprocess.test_system.TestWithPostgres method)
(examples.ftsprojection.test_projection.TestFtsProjection method)
Shop (class in examples.shopstandard.application)
singledispatchmethod (class in eventsourcing.dispatch)
SingleThreadedRunner (class in eventsourcing.system)
Slug (class in examples.contentmanagement.domainmodel)
slug (examples.contentmanagement.domainmodel.Page attribute)
(examples.contentmanagement.domainmodel.Page.Created attribute)
(examples.contentmanagement.domainmodel.Page.SlugUpdated attribute)
(examples.ftscontentmanagement.persistence.PageInfo attribute)
Slug.Created (class in examples.contentmanagement.domainmodel)
Slug.Event (class in examples.contentmanagement.domainmodel)
Slug.PageUpdated (class in examples.contentmanagement.domainmodel)
SlugConflictError
Snapshot (class in eventsourcing.domain)
(class in examples.aggregate11.domainmodel)
(class in examples.aggregate6.baseclasses)
(class in examples.aggregate7.immutablemodel)
(class in examples.aggregate9.immutablemodel)
snapshot_class (examples.aggregate11.application.DogSchool attribute)
(examples.aggregate6.application.DogSchool attribute)
(examples.aggregate7.application.DogSchool attribute)
(examples.aggregate9.application.DogSchool attribute)
SnapshotProtocol (class in eventsourcing.domain)
SnapshotState (class in examples.aggregate10.mutablemodel)
(class in examples.aggregate8.mutablemodel)
snapshotting_intervals (examples.contentmanagement.application.ContentManagement attribute)
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)
SQLiteFactory (class in eventsourcing.sqlite)
SQLiteFtsApplicationRecorder (class in examples.ftscontentmanagement.sqlite)
SQLiteFtsRecorder (class in examples.ftscontentmanagement.sqlite)
SQLiteProcessRecorder (class in eventsourcing.sqlite)
SQLiteTrackingRecorder (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)
(eventsourcing.persistence.StoredEvent attribute)
(examples.aggregate10.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate11.domainmodel.Snapshot attribute)
(examples.aggregate4.baseclasses.Aggregate.Snapshot attribute)
(examples.aggregate5.baseclasses.Aggregate.Snapshot attribute)
(examples.aggregate6.baseclasses.Snapshot attribute)
(examples.aggregate7.immutablemodel.Snapshot attribute)
(examples.aggregate8.domainmodel.Dog.Snapshot attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate9.immutablemodel.Snapshot attribute)
STOCKHOLM (examples.cargoshipping.domainmodel.Location attribute)
stop() (eventsourcing.persistence.ListenNotifySubscription method)
(eventsourcing.persistence.Subscription method)
(eventsourcing.popo.POPOSubscription method)
(eventsourcing.projection.ApplicationSubscription method)
(eventsourcing.projection.BaseProjectionRunner method)
(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)
submit (examples.shopstandard.domain.Cart attribute)
submit_cart() (examples.shopstandard.application.Shop method)
SubmitCart (class in examples.shopvertical.slices.submit_cart.cmd)
SubmittedCart (class in examples.shopvertical.events)
subscribe() (eventsourcing.persistence.ApplicationRecorder method)
(eventsourcing.popo.POPOApplicationRecorder method)
(eventsourcing.postgres.PostgresApplicationRecorder method)
(eventsourcing.sqlite.SQLiteApplicationRecorder method)
Subscription (class in eventsourcing.persistence)
System (class in eventsourcing.system)
T
take() (eventsourcing.domain.CanSnapshotAggregate class method)
(eventsourcing.domain.SnapshotProtocol class method)
(examples.aggregate10.mutablemodel.AggregateSnapshot class method)
(examples.aggregate4.baseclasses.Aggregate.Snapshot class method)
(examples.aggregate5.baseclasses.Aggregate.Snapshot class method)
(examples.aggregate6.baseclasses.Snapshot class method)
(examples.aggregate7.immutablemodel.Snapshot class method)
(examples.aggregate9.immutablemodel.Snapshot class method)
take_snapshot() (eventsourcing.application.Application method)
tearDown() (examples.ftscontentmanagement.test_application.TestWithPostgres method)
(examples.ftsprocess.test_system.TestWithPostgres method)
(examples.ftsprojection.test_projection.TestFtsProjection method)
test() (examples.bankaccounts.test.TestBankAccounts method)
(examples.contentmanagement.test.TestContentManagement method)
(examples.ftsprojection.test_projection.TestFtsProjection method)
test_admin_can_book_new_cargo() (examples.cargoshipping.test.TestBookingService method)
test_dog_school() (examples.aggregate1.test_application.TestDogSchool method)
(examples.aggregate10.test_application.TestDogSchool method)
(examples.aggregate11.test_application.TestDogSchool method)
(examples.aggregate2.test_application.TestDogSchool method)
(examples.aggregate3.test_application.TestDogSchool method)
(examples.aggregate4.test_application.TestDogSchool method)
(examples.aggregate5.test_application.TestDogSchool method)
(examples.aggregate6.test_application.TestDogSchool method)
(examples.aggregate7.test_application.TestDogSchool method)
(examples.aggregate8.test_application.TestDogSchool method)
(examples.aggregate9.test_application.TestDogSchool method)
test_dog_school_with_kurrentdb() (examples.aggregate11.test_application.TestDogSchool method)
test_dog_school_with_sqlite() (examples.aggregate11.test_application.TestDogSchool method)
test_scenario_cargo_from_hongkong_to_stockholm() (examples.cargoshipping.test.TestBookingService method)
test_system() (examples.ftsprocess.test_system.TestWithPostgres method)
TestBankAccounts (class in examples.bankaccounts.test)
TestBookingService (class in examples.cargoshipping.test)
TestContentManagement (class in examples.contentmanagement.test)
TestDogSchool (class in examples.aggregate1.test_application)
(class in examples.aggregate10.test_application)
(class in examples.aggregate11.test_application)
(class in examples.aggregate2.test_application)
(class in examples.aggregate3.test_application)
(class in examples.aggregate4.test_application)
(class in examples.aggregate5.test_application)
(class in examples.aggregate6.test_application)
(class in examples.aggregate7.test_application)
(class in examples.aggregate8.test_application)
(class in examples.aggregate9.test_application)
TestFtsProjection (class in examples.ftsprojection.test_projection)
TestWithPostgres (class in examples.ftscontentmanagement.test_application)
(class in examples.ftsprocess.test_system)
TestWithSQLite (class in examples.ftscontentmanagement.test_application)
(class in examples.ftsprocess.test_system)
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)
(examples.aggregate11.domainmodel.Aggregate.Event attribute)
(examples.aggregate11.domainmodel.DomainEvent attribute)
(examples.aggregate3.domainmodel.Dog.Event attribute)
(examples.aggregate4.baseclasses.DomainEvent attribute)
(examples.aggregate5.baseclasses.DomainEvent attribute)
(examples.aggregate6.baseclasses.DomainEvent attribute)
(examples.aggregate7.immutablemodel.DomainEvent attribute)
(examples.aggregate9.immutablemodel.DomainEvent attribute)
(examples.cargoshipping.domainmodel.Cargo.Event attribute)
(examples.contentmanagement.domainmodel.Slug.Event attribute)
title (examples.contentmanagement.domainmodel.Page attribute)
(examples.contentmanagement.domainmodel.Page.Created attribute)
(examples.contentmanagement.domainmodel.Page.TitleUpdated attribute)
(examples.ftscontentmanagement.persistence.PageInfo attribute)
TMutableOrImmutableAggregate (class in eventsourcing.domain)
to_domain_event() (eventsourcing.persistence.Mapper method)
(examples.aggregate7.orjsonpydantic.PydanticMapper method)
(examples.aggregate9.msgspecstructs.MsgspecMapper method)
to_stored_event() (eventsourcing.persistence.Mapper method)
(examples.aggregate7.orjsonpydantic.PydanticMapper method)
(examples.aggregate9.msgspecstructs.MsgspecMapper method)
TOKYO (examples.cargoshipping.domainmodel.Location attribute)
topic (eventsourcing.persistence.StoredEvent attribute)
(eventsourcing.system.System property)
(examples.aggregate10.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate11.domainmodel.Snapshot attribute)
(examples.aggregate4.baseclasses.Aggregate.Snapshot attribute)
(examples.aggregate7.immutablemodel.Snapshot attribute)
(examples.aggregate8.mutablemodel.AggregateSnapshot attribute)
(examples.aggregate9.immutablemodel.Snapshot attribute)
TopicError
topics (eventsourcing.projection.EventSourcedProjection attribute)
(eventsourcing.projection.Projection attribute)
(examples.ftsprocess.application.FtsProcess attribute)
Tracking (class in eventsourcing.persistence)
tracking_id (examples.cargoshipping.domainmodel.Cargo.HandlingEventRegistered attribute)
tracking_recorder() (eventsourcing.persistence.InfrastructureFactory method)
(eventsourcing.popo.POPOFactory method)
(eventsourcing.postgres.PostgresFactory method)
(eventsourcing.sqlite.SQLiteFactory method)
tracking_recorder_class (eventsourcing.postgres.PostgresFactory attribute)
(eventsourcing.sqlite.SQLiteFactory attribute)
TrackingRecorder (class in eventsourcing.persistence)
transaction() (eventsourcing.postgres.PostgresDatastore method)
TransactionError
Transcoder (class in eventsourcing.persistence)
transcoder() (eventsourcing.persistence.InfrastructureFactory method)
Transcoding (class in eventsourcing.persistence)
TranscodingNotRegisteredError
transfer_funds() (examples.bankaccounts.application.BankAccounts method)
transport_status (examples.cargoshipping.domainmodel.Cargo property)
Trick (class in examples.aggregate10.domainmodel)
(class in examples.aggregate7.domainmodel)
(class in examples.aggregate8.domainmodel)
(class in examples.aggregate9.domainmodel)
trick (examples.aggregate1.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate10.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate11.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate3.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate4.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate5.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate6.domainmodel.TrickAdded attribute)
(examples.aggregate7.domainmodel.TrickAdded attribute)
(examples.aggregate8.domainmodel.Dog.TrickAdded attribute)
(examples.aggregate9.domainmodel.TrickAdded attribute)
TrickAdded (class in examples.aggregate6.domainmodel)
(class in examples.aggregate7.domainmodel)
(class in examples.aggregate9.domainmodel)
tricks (examples.aggregate10.domainmodel.DogSnapshotState attribute)
(examples.aggregate4.domainmodel.Dog attribute)
(examples.aggregate5.domainmodel.Dog attribute)
(examples.aggregate6.domainmodel.Dog attribute)
(examples.aggregate7.domainmodel.Dog attribute)
(examples.aggregate8.domainmodel.DogSnapshotState attribute)
(examples.aggregate9.domainmodel.Dog attribute)
trigger_event() (eventsourcing.application.EventSourcedLog method)
(eventsourcing.domain.BaseAggregate method)
(examples.aggregate4.baseclasses.Aggregate method)
(examples.aggregate5.baseclasses.Aggregate method)
triggers() (in module eventsourcing.domain)
type (eventsourcing.persistence.DatetimeAsISO attribute)
(eventsourcing.persistence.DecimalAsStr attribute)
(eventsourcing.persistence.UUIDAsHex attribute)
(examples.cargoshipping.application.HandlingActivityAsName attribute)
(examples.cargoshipping.application.ItineraryAsDict attribute)
(examples.cargoshipping.application.LegAsDict attribute)
(examples.cargoshipping.application.LocationAsName attribute)
TZINFO (in module eventsourcing.domain)
U
UnboundCommandMethodDecorator (class in eventsourcing.domain)
UNLOAD (examples.cargoshipping.domainmodel.HandlingActivity attribute)
update_body() (examples.contentmanagement.application.ContentManagement method)
(examples.contentmanagement.domainmodel.Page method)
update_page (examples.contentmanagement.domainmodel.Slug attribute)
update_pages() (examples.ftscontentmanagement.persistence.FtsRecorder method)
(examples.ftscontentmanagement.postgres.PostgresFtsRecorder method)
(examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)
update_pages_with_tracking() (examples.ftsprojection.projection.FtsViewInterface method)
(examples.ftsprojection.projection.PostgresFtsView method)
update_slug (examples.contentmanagement.domainmodel.Page attribute)
update_slug() (examples.contentmanagement.application.ContentManagement method)
update_title (examples.contentmanagement.domainmodel.Page attribute)
update_title() (examples.contentmanagement.application.ContentManagement method)
USDAL (examples.cargoshipping.domainmodel.Location attribute)
user_id (examples.contentmanagement.domainmodel.Page.Event attribute)
user_id_cvar (in module examples.contentmanagement.domainmodel)
UUIDAsHex (class in eventsourcing.persistence)
V
version (eventsourcing.domain.BaseAggregate property)
(eventsourcing.domain.ImmutableAggregateProtocol property)
(eventsourcing.domain.MutableAggregateProtocol property)
(examples.aggregate4.baseclasses.Aggregate attribute)
(examples.aggregate5.baseclasses.Aggregate attribute)
(examples.aggregate6.baseclasses.Aggregate attribute)
(examples.aggregate7.immutablemodel.Aggregate attribute)
(examples.aggregate9.immutablemodel.Aggregate attribute)
view (eventsourcing.projection.Projection property)
voyage_number (examples.cargoshipping.domainmodel.Cargo.HandlingEventRegistered attribute)
W
wait() (eventsourcing.persistence.TrackingRecorder method)
(eventsourcing.projection.BaseProjectionRunner method)
WaitInterruptedError
when() (examples.cargoshipping.domainmodel.Cargo method)
withdraw_funds() (examples.bankaccounts.application.BankAccounts method)
Z
ZlibCompressor (class in eventsourcing.compressor)