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) (eventsourcing.projection.DCBApplicationSubscription method) (eventsourcing.projection.EventSourcedProjectionRunner 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) (eventsourcing.projection.DCBApplicationSubscription method) (eventsourcing.projection.EventSourcedProjectionRunner 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.dcb.api.DCBAppendCondition method) (eventsourcing.dcb.api.DCBEvent method) (eventsourcing.dcb.api.DCBQuery method) (eventsourcing.dcb.api.DCBQueryItem method) (eventsourcing.dcb.api.DCBSequencedEvent method) (eventsourcing.dcb.api.DCBSubscription method) (eventsourcing.dcb.application.DCBApplication method) (eventsourcing.dcb.application.DCBRepository method) (eventsourcing.dcb.domain.MetaEnduringObject method) (eventsourcing.dcb.domain.MetaSlice method) (eventsourcing.dcb.domain.MetaSupportsEventDecorator method) (eventsourcing.dcb.domain.Selector method) (eventsourcing.dcb.domain.Tagged method) (eventsourcing.dcb.persistence.DCBEventStore method) (eventsourcing.dcb.persistence.DCBEventStoreReadResponse method) (eventsourcing.dcb.persistence.DCBListenNotifySubscription method) (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.dcb.popo.InMemorySubscription method) (eventsourcing.dcb.popo.SimpleDCBReadResponse method) (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) (eventsourcing.dcb.postgres_tt.PostgresDCBSubscription method) (eventsourcing.interface.NotificationLogJSONClient method) (eventsourcing.interface.NotificationLogJSONService method) (eventsourcing.persistence.BaseInfrastructureFactory method) (eventsourcing.persistence.Cipher method) (eventsourcing.persistence.Connection method) (eventsourcing.persistence.ConnectionPool method) (eventsourcing.persistence.EventStore method) (eventsourcing.persistence.JSONTranscoder method) (eventsourcing.persistence.ListenNotifySubscription method) (eventsourcing.persistence.Mapper method) (eventsourcing.persistence.Notification method) (eventsourcing.persistence.Queue 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.POPORecorder method) (eventsourcing.popo.POPOSubscription method) (eventsourcing.popo.POPOTrackingRecorder method) (eventsourcing.postgres.BasePostgresFactory method) (eventsourcing.postgres.ConnectionPool method) (eventsourcing.postgres.PostgresAggregateRecorder method) (eventsourcing.postgres.PostgresApplicationRecorder method) (eventsourcing.postgres.PostgresDatastore 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.DCBApplicationSubscription 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.dcb_enrolment.domainmodel.Course method) (examples.dcb_enrolment.domainmodel.Student method) (examples.dcb_enrolment_with_enduring_objects.application.Course method) (examples.dcb_enrolment_with_enduring_objects.application.Student method) (examples.dcb_enrolment_with_enduring_objects.application.StudentAndCourse method) (examples.dcb_enrolment_with_vertical_slices.application.Course method) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs method) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent method) (examples.dcb_enrolment_with_vertical_slices.application.Student method) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse method) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse method) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames method) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses method) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName 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) (eventsourcing.projection.DCBApplicationSubscription method) __next__() (eventsourcing.persistence.ListenNotifySubscription method) (eventsourcing.persistence.Subscription method) (eventsourcing.projection.ApplicationSubscription method) (eventsourcing.projection.DCBApplicationSubscription 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.popo.POPOTrackingRecorder method) (eventsourcing.postgres.PostgresTrackingRecorder method) _update_body() (examples.contentmanagement.domainmodel.Page method) _update_pages() (examples.ftscontentmanagement.postgres.PostgresFtsRecorder method) (examples.ftscontentmanagement.sqlite.SQLiteFtsRecorder method)

A

accept_student() (examples.dcb_enrolment.domainmodel.Course method) AccountClosedError AccountNotFoundError add_item() (examples.shopstandard.domain.Cart method) add_item_to_cart() (examples.shopstandard.application.Shop method) add_product_to_shop() (examples.shopstandard.application.Shop method) add_trick() (examples.aggregate1.application.DogSchool method) (examples.aggregate1.domainmodel.Dog method) (examples.aggregate10.application.DogSchool method) (examples.aggregate10.domainmodel.Dog method) (examples.aggregate11.application.DogSchool method) (examples.aggregate11.domainmodel.Dog method) (examples.aggregate2.application.DogSchool method) (examples.aggregate2.domainmodel.Dog 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.aggregate8.domainmodel.Dog 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 method) 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) advance() (eventsourcing.dcb.application.DCBRepository method) AESCipher (class in eventsourcing.cipher) (class in eventsourcing.cryptography) after (eventsourcing.dcb.api.DCBAppendCondition attribute) 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) (class in examples.dcb_enrolment.domainmodel) 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) (class in examples.dcb_enrolment.domainmodel)

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) all_query_items_have_tags() (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) AlreadyJoinedError amount (examples.bankaccounts.domainmodel.BankAccount.Credited attribute) (examples.bankaccounts.domainmodel.BankAccount.Debited attribute) append() (eventsourcing.dcb.api.DCBRecorder method) (eventsourcing.dcb.persistence.DCBEventStore method) (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) 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.dcb.domain.Decision method) (eventsourcing.domain.CanMutateAggregate method) (eventsourcing.domain.DecoratedFuncCaller 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) as_dict() (eventsourcing.dcb.domain.Decision method) (eventsourcing.dcb.msgpack.Decision method) assert_implementation() (examples.dcb_enrolment.test_enrolment.EnrolmentTestCase method) 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) BaseInfrastructureFactory (class in eventsourcing.persistence)

BasePostgresFactory (class in eventsourcing.postgres) 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) CanTriggerEvent (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_identifier_length() (eventsourcing.postgres.PostgresRecorder static method) Cipher (class in eventsourcing.persistence) cipher() (eventsourcing.persistence.BaseInfrastructureFactory method) CLAIM (examples.cargoshipping.domainmodel.HandlingActivity attribute) clear() (examples.shopstandard.domain.Cart method) clear_cart() (examples.shopstandard.application.Shop method) ClearCart (class in examples.shopvertical.slices.clear_cart.cmd) ClearedCart (class in examples.shopvertical.events) close() (eventsourcing.dcb.application.DCBApplication method) (eventsourcing.persistence.BaseInfrastructureFactory method) (eventsourcing.persistence.ConnectionPool method) (eventsourcing.postgres.BasePostgresFactory method) (eventsourcing.postgres.PostgresDatastore method) (eventsourcing.sqlite.SQLiteFactory method) (examples.bankaccounts.domainmodel.BankAccount method) close_account() (examples.bankaccounts.application.BankAccounts method) collect_events() (eventsourcing.application.ProcessingEvent method) (eventsourcing.dcb.domain.Perspective 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.BaseInfrastructureFactory method) Connection (class in eventsourcing.persistence) ConnectionNotFromPoolError ConnectionPool (class in eventsourcing.persistence) (class in eventsourcing.postgres) ConnectionPoolClosedError ConnectionUnavailableError consistency_boundary() (eventsourcing.dcb.domain.EnduringObject method) (eventsourcing.dcb.domain.Group method) (eventsourcing.dcb.domain.Perspective method) (examples.dcb_enrolment_with_vertical_slices.application.Course method) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs method) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent method) (examples.dcb_enrolment_with_vertical_slices.application.Student method) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse method) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse method) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames method) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses method) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName method)

construct() (eventsourcing.persistence.BaseInfrastructureFactory class method) construct_env() (eventsourcing.application.Application method) (eventsourcing.dcb.application.DCBApplication 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_pg_stored_event() (eventsourcing.postgres.PostgresAggregateRecorder method) construct_psycopg_dcb_events() (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) construct_psycopg_query_items() (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT 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) Course (class in examples.dcb_enrolment.domainmodel) (class in examples.dcb_enrolment_with_enduring_objects.application) (class in examples.dcb_enrolment_with_vertical_slices.application) Course.Event (class in examples.dcb_enrolment.domainmodel) Course.NameUpdated (class in examples.dcb_enrolment_with_enduring_objects.application) Course.PlacesUpdated (class in examples.dcb_enrolment_with_enduring_objects.application) Course.Registered (class in examples.dcb_enrolment_with_enduring_objects.application) Course.StudentAccepted (class in examples.dcb_enrolment.domainmodel) course_id (examples.dcb_enrolment.domainmodel.Student.CourseJoined attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course.Registered attribute) (examples.dcb_enrolment_with_enduring_objects.application.StudentJoinedCourse attribute) (examples.dcb_enrolment_with_enduring_objects.application.StudentLeftCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNameUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.CoursePlacesUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseRegistered attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinedCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeftCourse attribute) CourseIDs (class in examples.dcb_enrolment_with_vertical_slices.application) CourseNames (class in examples.dcb_enrolment_with_vertical_slices.application) CourseNameUpdated (class in examples.dcb_enrolment_with_vertical_slices.application) CourseNotFoundError CoursePlacesUpdated (class in examples.dcb_enrolment_with_vertical_slices.application) CourseRegistered (class in examples.dcb_enrolment_with_vertical_slices.application) 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) (examples.dcb_enrolment.domainmodel.Course static method) (examples.dcb_enrolment.domainmodel.Student 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.BasePostgresFactory 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 method) current_voyage_number (examples.cargoshipping.domainmodel.Cargo property) Cursor (class in eventsourcing.persistence) cursor() (eventsourcing.persistence.Connection method) (eventsourcing.postgres.PostgresDatastore method) (eventsourcing.sqlite.SQLiteConnection method)

D

data (eventsourcing.dcb.api.DCBEvent attribute) (eventsourcing.dcb.postgres_tt.PsycopgDCBEvent attribute) DatabaseError DataError datetime_now_with_tzinfo() (in module eventsourcing.domain) DatetimeAsISO (class in eventsourcing.persistence) dcb_recorder() (eventsourcing.dcb.persistence.DCBInfrastructureFactory method) (eventsourcing.dcb.popo.InMemoryDCBFactory method) (eventsourcing.dcb.postgres_tt.PostgresTTDCBFactory method) DCBAppendCondition (class in eventsourcing.dcb.api) DCBApplication (class in eventsourcing.dcb.application) DCBApplicationSubscription (class in eventsourcing.projection) DCBEvent (class in eventsourcing.dcb.api) DCBEventStore (class in eventsourcing.dcb.persistence) DCBEventStoreReadResponse (class in eventsourcing.dcb.persistence) DCBInfrastructureFactory (class in eventsourcing.dcb.persistence) DCBListenNotifySubscription (class in eventsourcing.dcb.persistence) DCBMapper (class in eventsourcing.dcb.persistence) DCBQuery (class in eventsourcing.dcb.api) DCBQueryItem (class in eventsourcing.dcb.api) DCBReadResponse (class in eventsourcing.dcb.api) DCBRecorder (class in eventsourcing.dcb.api) DCBRepository (class in eventsourcing.dcb.application) DCBSequencedEvent (class in eventsourcing.dcb.api) DCBSubscription (class in eventsourcing.dcb.api) debit() (examples.bankaccounts.domainmodel.BankAccount method) DecimalAsStr (class in eventsourcing.persistence) Decision (class in eventsourcing.dcb.domain) (class in eventsourcing.dcb.msgpack) 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.msgpack.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) DecoratedFuncCaller (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) do() (eventsourcing.dcb.application.DCBApplication method) do_projection (eventsourcing.dcb.domain.Slice attribute) (examples.dcb_enrolment_with_vertical_slices.application.Course attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent attribute) (examples.dcb_enrolment_with_vertical_slices.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName attribute)

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.dcb_enrolment.domainmodel) (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.msgpack.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) EnduringObject (class in eventsourcing.dcb.domain) EnrolmentInterface (class in examples.dcb_enrolment.interface) EnrolmentTestCase (class in examples.dcb_enrolment.test_enrolment) EnrolmentWithAggregates (class in examples.dcb_enrolment.application) EnrolmentWithEnduringObjects (class in examples.dcb_enrolment_with_enduring_objects.application) EnrolmentWithVerticalSlices (class in examples.dcb_enrolment_with_vertical_slices.application) env (eventsourcing.dcb.application.DCBApplication attribute) (examples.aggregate7.orjsonpydantic.PydanticApplication attribute) (examples.aggregate9.msgpack.MsgspecApplication attribute) (examples.contentmanagement.application.ContentManagement attribute) (examples.dcb_enrolment.application.EnrolmentWithAggregates attribute) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects attribute) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices 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.BasePostgresFactory method) Environment (class in eventsourcing.utils) estimated_time_of_arrival (examples.cargoshipping.domainmodel.Cargo property) event (eventsourcing.dcb.api.DCBSequencedEvent attribute) 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.dcb.api module eventsourcing.dcb.application module eventsourcing.dcb.domain module eventsourcing.dcb.msgpack module eventsourcing.dcb.persistence module eventsourcing.dcb.popo module eventsourcing.dcb.postgres_tt 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.msgpack 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.dcb_enrolment.application module examples.dcb_enrolment.domainmodel module examples.dcb_enrolment.interface module examples.dcb_enrolment.test_enrolment module examples.dcb_enrolment_with_enduring_objects.application module examples.dcb_enrolment_with_vertical_slices.application 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.dcb.domain.Slice method) (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) (eventsourcing.persistence.Cursor method) (eventsourcing.sqlite.SQLiteCursor method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse method) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent method) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse method) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses method) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces method) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName 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) fail_if_events_match (eventsourcing.dcb.api.DCBAppendCondition attribute) 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) format() (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) 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) FullyBookedError

G

get() (eventsourcing.application.EventSourcedLog method) (eventsourcing.application.Repository method) (eventsourcing.dcb.application.DCBRepository method) (eventsourcing.persistence.EventStore method) (eventsourcing.persistence.Queue 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_course() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices 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_group() (eventsourcing.dcb.application.DCBRepository method) get_last() (eventsourcing.application.EventSourcedLog method) get_log_section() (eventsourcing.interface.NotificationLogInterface method) (eventsourcing.interface.NotificationLogJSONService method) get_many() (eventsourcing.dcb.application.DCBRepository 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_student() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) get_topic() (in module eventsourcing.utils) GetCartItems (class in examples.shopvertical.slices.get_cart_items.query) Group (class in eventsourcing.dcb.domain)

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_checked_for_multi_row_tracking_table (eventsourcing.postgres.PostgresProcessRecorder attribute) has_default() (eventsourcing.dcb.domain.TDecision method) has_one_query_item_one_type() (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) has_tracking_id() (eventsourcing.persistence.TrackingRecorder method) (eventsourcing.postgres.PostgresTrackingRecorder method) HasOriginatorIDVersion (class in eventsourcing.domain) head (eventsourcing.dcb.api.DCBReadResponse property) (eventsourcing.dcb.persistence.DCBEventStoreReadResponse property) (eventsourcing.dcb.popo.SimpleDCBReadResponse property) HONGKONG (examples.cargoshipping.domainmodel.Location attribute)

I

id (eventsourcing.dcb.domain.EnduringObject attribute) (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.dcb_enrolment_with_enduring_objects.application.Course attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student attribute) (examples.ftscontentmanagement.persistence.PageInfo attribute) (examples.shopstandard.domain.ProductDetails attribute) (examples.shopvertical.slices.list_products_in_shop.query.ProductDetails attribute) id_attr_name() (eventsourcing.dcb.domain.InitialDecision class method) 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) InitialDecision (class in eventsourcing.dcb.domain) (class in eventsourcing.dcb.msgpack) InMemoryDCBFactory (class in eventsourcing.dcb.popo) InMemoryDCBRecorder (class in eventsourcing.dcb.popo) InMemorySubscription (class in eventsourcing.dcb.popo) insert_events() (eventsourcing.persistence.AggregateRecorder method) (eventsourcing.popo.POPOAggregateRecorder method) (eventsourcing.popo.POPOApplicationRecorder method) (eventsourcing.postgres.PostgresAggregateRecorder method) (eventsourcing.postgres.PostgresApplicationRecorder 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) items (eventsourcing.dcb.api.DCBQuery attribute) Itinerary (class in examples.cargoshipping.domainmodel) ItineraryAsDict (class in examples.cargoshipping.application)

J

join_course() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment.domainmodel.Student method) (examples.dcb_enrolment.interface.EnrolmentInterface method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method)

JSONTranscoder (class in eventsourcing.persistence)

L

last_known_location (examples.cargoshipping.domainmodel.Cargo property) last_known_position (eventsourcing.dcb.domain.Perspective attribute) (eventsourcing.dcb.domain.Slice attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.Course attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent attribute) (examples.dcb_enrolment_with_vertical_slices.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName attribute) lead() (eventsourcing.system.Leader method) Leader (class in eventsourcing.system) leave_course() (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method)

Leg (class in examples.cargoshipping.domainmodel) LegAsDict (class in examples.cargoshipping.application) list_courses_for_student() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment.interface.EnrolmentInterface method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) list_products_in_shop() (examples.shopstandard.application.Shop method) list_students_for_course() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment.interface.EnrolmentInterface method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) listen() (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.popo.POPOApplicationRecorder 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) lock_table_statements (eventsourcing.postgres.PostgresApplicationRecorder attribute) LogEvent (class in eventsourcing.domain) LRUCache (class in eventsourcing.application)

M

Mapper (class in eventsourcing.persistence) mapper() (eventsourcing.persistence.InfrastructureFactory method) MapperDeserialisationError max_courses (examples.dcb_enrolment_with_enduring_objects.application.Student.MaxCoursesUpdated attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student.Registered attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentMaxCoursesUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentRegistered attribute) 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) MessagePackMapper (class in eventsourcing.dcb.msgpack) (class in examples.aggregate9.msgpack) MetaAggregate (class in eventsourcing.domain) MetaDomainEvent (class in eventsourcing.domain) MetaEnduringObject (class in eventsourcing.dcb.domain) MetaPerspective (class in eventsourcing.dcb.domain) MetaSlice (class in eventsourcing.dcb.domain) MetaSupportsEventDecorator (class in eventsourcing.dcb.domain) 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) 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.dcb.api eventsourcing.dcb.application eventsourcing.dcb.domain eventsourcing.dcb.msgpack eventsourcing.dcb.persistence eventsourcing.dcb.popo eventsourcing.dcb.postgres_tt 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.msgpack 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.dcb_enrolment.application examples.dcb_enrolment.domainmodel examples.dcb_enrolment.interface examples.dcb_enrolment.test_enrolment examples.dcb_enrolment_with_enduring_objects.application examples.dcb_enrolment_with_vertical_slices.application 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.msgpack) MsgspecStringIDAggregate (class in examples.dcb_enrolment.domainmodel) MsgspecStringIDAggregate.Event (class in examples.dcb_enrolment.domainmodel) MsgspecStringIDCreatedEvent (class in examples.dcb_enrolment.domainmodel) MsgspecStringIDEvent (class in examples.dcb_enrolment.domainmodel) MultiThreadedRunner (class in eventsourcing.system) MultiThreadedRunnerThread (class in eventsourcing.system) MutableAggregateProtocol (class in eventsourcing.domain) MutableOrImmutableAggregate (in module eventsourcing.domain) mutate() (eventsourcing.dcb.domain.Decision method) (eventsourcing.dcb.domain.InitialDecision method) (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.dcb.application.DCBApplication attribute) (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.msgpack.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.dcb_enrolment.application.EnrolmentWithAggregates attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course.NameUpdated attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course.Registered attribute) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student.NameUpdated attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student.Registered attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNameUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseRegistered attribute) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNameUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentRegistered 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)

names (examples.dcb_enrolment_with_vertical_slices.application.CourseNames property) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames property) new_booking() (examples.cargoshipping.domainmodel.Cargo class method) new_decisions (eventsourcing.dcb.domain.Perspective attribute) (eventsourcing.dcb.domain.Slice attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.Course attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent attribute) (examples.dcb_enrolment_with_vertical_slices.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName attribute) 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) NotAlreadyJoinedError NotFoundError 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.msgpack) 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) (eventsourcing.postgres.PgStoredEvent 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.dcb_enrolment.domainmodel.DomainEvent 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) ORIGINATOR_ID_TYPE (eventsourcing.postgres.BasePostgresFactory attribute) originator_id_type (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.dcb_enrolment.domainmodel.Aggregate.Event attribute) (examples.dcb_enrolment.domainmodel.Course.Event attribute) (examples.dcb_enrolment.domainmodel.MsgspecStringIDAggregate.Event attribute) (examples.dcb_enrolment.domainmodel.MsgspecStringIDCreatedEvent attribute) (examples.dcb_enrolment.domainmodel.MsgspecStringIDEvent attribute) (examples.dcb_enrolment.domainmodel.Student.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.dcb.domain.InitialDecision attribute) (eventsourcing.dcb.msgpack.InitialDecision attribute) (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) (examples.dcb_enrolment.domainmodel.MsgspecStringIDCreatedEvent 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) (eventsourcing.postgres.PgStoredEvent 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.dcb_enrolment.domainmodel.DomainEvent 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 Perspective (class in eventsourcing.dcb.domain) PgStoredEvent (class in eventsourcing.postgres) places (examples.dcb_enrolment_with_enduring_objects.application.Course.PlacesUpdated attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course.Registered attribute) (examples.dcb_enrolment_with_vertical_slices.application.CoursePlacesUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseRegistered attribute) 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) POPORecorder (class in eventsourcing.popo) POPOSubscription (class in eventsourcing.popo) POPOTrackingRecorder (class in eventsourcing.popo) position (eventsourcing.dcb.api.DCBSequencedEvent attribute) POSTGRES_CONN_MAX_AGE (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_CONNECT_TIMEOUT (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_DBNAME (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_ENABLE_DB_FUNCTIONS (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_GET_PASSWORD_TOPIC (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_HOST (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_IDLE_IN_TRANSACTION_SESSION_TIMEOUT (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_LOCK_TIMEOUT (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_MAX_OVERFLOW (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_MAX_WAITING (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_PASSWORD (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_POOL_SIZE (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_PORT (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_PRE_PING (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_SCHEMA (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_SINGLE_ROW_TRACKING (eventsourcing.postgres.BasePostgresFactory attribute) POSTGRES_USER (eventsourcing.postgres.BasePostgresFactory attribute) PostgresAggregateRecorder (class in eventsourcing.postgres) PostgresApplicationRecorder (class in eventsourcing.postgres) PostgresDatastore (class in eventsourcing.postgres) PostgresDCBRecorderTT (class in eventsourcing.dcb.postgres_tt) PostgresDCBSubscription (class in eventsourcing.dcb.postgres_tt) 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) PostgresTTDCBFactory (class in eventsourcing.dcb.postgres_tt) 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) projected_types (eventsourcing.dcb.domain.EnduringObject attribute) (eventsourcing.dcb.domain.Slice attribute) (examples.dcb_enrolment_with_enduring_objects.application.Course attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.Course attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.CourseNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.RegisterStudent attribute) (examples.dcb_enrolment_with_vertical_slices.application.Student attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinsCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeavesCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNames attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentsIDs attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateCourseName attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateMaxCourses attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdatePlaces attribute) (examples.dcb_enrolment_with_vertical_slices.application.UpdateStudentName attribute) 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) PsycopgDCBEvent (class in eventsourcing.dcb.postgres_tt) PsycopgDCBQueryItem (class in eventsourcing.dcb.postgres_tt) pull_and_process() (eventsourcing.system.Follower method) pull_notifications() (eventsourcing.system.Follower method) PullingThread (class in eventsourcing.system) put() (eventsourcing.persistence.EventStore method) (eventsourcing.persistence.Queue 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)

Queue (class in eventsourcing.persistence)

R

random() (in module eventsourcing.utils) read() (eventsourcing.dcb.api.DCBRecorder method) (eventsourcing.dcb.persistence.DCBEventStore method) (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) (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_course() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment.interface.EnrolmentInterface method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices 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_student() (examples.dcb_enrolment.application.EnrolmentWithAggregates method) (examples.dcb_enrolment.interface.EnrolmentInterface method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) register_topic() (in module eventsourcing.utils) register_transcodings() (eventsourcing.application.Application method) (examples.cargoshipping.application.BookingApplication method) register_type_adapters() (eventsourcing.postgres.PostgresDatastore method) RegisterCourse (class in examples.dcb_enrolment_with_vertical_slices.application) RegisterStudent (class in examples.dcb_enrolment_with_vertical_slices.application) remove_item() (examples.shopstandard.domain.Cart method) 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.dcb.application.DCBRepository 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) Selector (class in eventsourcing.dcb.domain) set_overdraft_limit() (examples.bankaccounts.application.BankAccounts method) (examples.bankaccounts.domainmodel.BankAccount 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) ShutDown shutdown() (eventsourcing.persistence.Queue method) SimpleDCBReadResponse (class in eventsourcing.dcb.popo) singledispatchmethod (class in eventsourcing.dispatch) SingleThreadedRunner (class in eventsourcing.system) Slice (class in eventsourcing.dcb.domain) 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) sql_create_statements (eventsourcing.postgres.PostgresAggregateRecorder attribute) (eventsourcing.postgres.PostgresApplicationRecorder attribute) (eventsourcing.postgres.PostgresProcessRecorder attribute) (eventsourcing.postgres.PostgresTrackingRecorder 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) (eventsourcing.postgres.PgStoredEvent 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.dcb.api.DCBSubscription method) (eventsourcing.dcb.persistence.DCBListenNotifySubscription method) (eventsourcing.dcb.popo.InMemorySubscription method) (eventsourcing.persistence.ListenNotifySubscription method) (eventsourcing.persistence.Subscription method) (eventsourcing.popo.POPOSubscription method) (eventsourcing.projection.ApplicationSubscription method) (eventsourcing.projection.BaseProjectionRunner method) (eventsourcing.projection.DCBApplicationSubscription 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) Student (class in examples.dcb_enrolment.domainmodel) (class in examples.dcb_enrolment_with_enduring_objects.application) (class in examples.dcb_enrolment_with_vertical_slices.application) Student.CourseJoined (class in examples.dcb_enrolment.domainmodel) Student.Event (class in examples.dcb_enrolment.domainmodel) Student.MaxCoursesUpdated (class in examples.dcb_enrolment_with_enduring_objects.application) Student.NameUpdated (class in examples.dcb_enrolment_with_enduring_objects.application) Student.Registered (class in examples.dcb_enrolment_with_enduring_objects.application) student_id (examples.dcb_enrolment.domainmodel.Course.StudentAccepted attribute) (examples.dcb_enrolment_with_enduring_objects.application.Student.Registered attribute) (examples.dcb_enrolment_with_enduring_objects.application.StudentJoinedCourse attribute) (examples.dcb_enrolment_with_enduring_objects.application.StudentLeftCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentJoinedCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentLeftCourse attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentMaxCoursesUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentNameUpdated attribute) (examples.dcb_enrolment_with_vertical_slices.application.StudentRegistered attribute) student_joins_course() (examples.dcb_enrolment_with_enduring_objects.application.StudentAndCourse method) student_leaves_course() (examples.dcb_enrolment_with_enduring_objects.application.StudentAndCourse method) StudentAndCourse (class in examples.dcb_enrolment_with_enduring_objects.application) StudentJoinedCourse (class in examples.dcb_enrolment_with_enduring_objects.application) (class in examples.dcb_enrolment_with_vertical_slices.application) StudentJoinsCourse (class in examples.dcb_enrolment_with_vertical_slices.application) StudentLeavesCourse (class in examples.dcb_enrolment_with_vertical_slices.application) StudentLeftCourse (class in examples.dcb_enrolment_with_enduring_objects.application) (class in examples.dcb_enrolment_with_vertical_slices.application) StudentMaxCoursesUpdated (class in examples.dcb_enrolment_with_vertical_slices.application) StudentNames (class in examples.dcb_enrolment_with_vertical_slices.application) StudentNameUpdated (class in examples.dcb_enrolment_with_vertical_slices.application) StudentNotFoundError StudentRegistered (class in examples.dcb_enrolment_with_vertical_slices.application) StudentsIDs (class in examples.dcb_enrolment_with_vertical_slices.application) submit() (examples.shopstandard.domain.Cart method) submit_cart() (examples.shopstandard.application.Shop method) SubmitCart (class in examples.shopvertical.slices.submit_cart.cmd) SubmittedCart (class in examples.shopvertical.events) subscribe() (eventsourcing.dcb.api.DCBRecorder method) (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.dcb.postgres_tt.PostgresDCBRecorderTT method) (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

Tagged (class in eventsourcing.dcb.domain) tags (eventsourcing.dcb.api.DCBEvent attribute) (eventsourcing.dcb.api.DCBQueryItem attribute) (eventsourcing.dcb.domain.Selector attribute) (eventsourcing.dcb.postgres_tt.PsycopgDCBEvent attribute) (eventsourcing.dcb.postgres_tt.PsycopgDCBQueryItem attribute) 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) TDecision (class in eventsourcing.dcb.domain) 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_postgres() (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) (examples.dcb_enrolment.domainmodel.DomainEvent 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_dcb_event() (eventsourcing.dcb.msgpack.MessagePackMapper method) (eventsourcing.dcb.persistence.DCBMapper method) to_domain_event() (eventsourcing.dcb.msgpack.MessagePackMapper method) (eventsourcing.dcb.persistence.DCBMapper method) (eventsourcing.persistence.Mapper method) (examples.aggregate7.orjsonpydantic.PydanticMapper method) (examples.aggregate9.msgpack.MessagePackMapper method)

to_stored_event() (eventsourcing.persistence.Mapper method) (examples.aggregate7.orjsonpydantic.PydanticMapper method) (examples.aggregate9.msgpack.MessagePackMapper method) TOKYO (examples.cargoshipping.domainmodel.Location attribute) TooManyCoursesError topic (eventsourcing.persistence.StoredEvent attribute) (eventsourcing.postgres.PgStoredEvent 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_migration_current (eventsourcing.postgres.PostgresProcessRecorder attribute) tracking_migration_previous (eventsourcing.postgres.PostgresProcessRecorder 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) tracking_table_exists (eventsourcing.postgres.PostgresProcessRecorder attribute) TrackingRecorder (class in eventsourcing.persistence) transaction() (eventsourcing.postgres.PostgresDatastore method) TransactionError Transcoder (class in eventsourcing.persistence) transcoder() (eventsourcing.persistence.BaseInfrastructureFactory 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.dcb.domain.EnduringObject method) (eventsourcing.dcb.domain.Group method) (eventsourcing.dcb.domain.Perspective method) (eventsourcing.domain.BaseAggregate method) (examples.aggregate4.baseclasses.Aggregate method) (examples.aggregate5.baseclasses.Aggregate method) triggers() (in module eventsourcing.domain) type (eventsourcing.dcb.api.DCBEvent attribute) (eventsourcing.dcb.postgres_tt.PsycopgDCBEvent attribute) (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) types (eventsourcing.dcb.api.DCBQueryItem attribute) (eventsourcing.dcb.domain.Selector attribute) (eventsourcing.dcb.postgres_tt.PsycopgDCBQueryItem attribute) TZINFO (in module eventsourcing.domain)

U

UnboundCommandMethodDecorator (class in eventsourcing.domain) unlisten() (eventsourcing.dcb.popo.InMemoryDCBRecorder method) (eventsourcing.popo.POPOApplicationRecorder method) UNLOAD (examples.cargoshipping.domainmodel.HandlingActivity attribute) update_body() (examples.contentmanagement.application.ContentManagement method) (examples.contentmanagement.domainmodel.Page method) update_course_name() (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) update_max_courses() (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_enduring_objects.application.Student method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) update_name() (examples.dcb_enrolment_with_enduring_objects.application.Course method) (examples.dcb_enrolment_with_enduring_objects.application.Student method) update_page() (examples.contentmanagement.domainmodel.Slug method) 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_places() (examples.dcb_enrolment_with_enduring_objects.application.Course method) (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) update_slug() (examples.contentmanagement.application.ContentManagement method) (examples.contentmanagement.domainmodel.Page method) update_student_name() (examples.dcb_enrolment_with_enduring_objects.application.EnrolmentWithEnduringObjects method) (examples.dcb_enrolment_with_vertical_slices.application.EnrolmentWithVerticalSlices method) update_title() (examples.contentmanagement.application.ContentManagement method) (examples.contentmanagement.domainmodel.Page method) UpdateCourseName (class in examples.dcb_enrolment_with_vertical_slices.application) UpdateMaxCourses (class in examples.dcb_enrolment_with_vertical_slices.application) UpdatePlaces (class in examples.dcb_enrolment_with_vertical_slices.application) UpdateStudentName (class in examples.dcb_enrolment_with_vertical_slices.application) 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)