Index

_

__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)