Package io.fluxzero.sdk.persisting.eventsourcing.client
package io.fluxzero.sdk.persisting.eventsourcing.client
-
ClassDescriptionLow-level client interface for interacting with the event store in Fluxzero.An implementation of the
EventStoreClientinterface that provides an in-memory event storage solution.Applies direct model documents and due snapshots, returning their local-handler publication for execution after the materialized state and graph-projection fences have advanced.Writes current materialized graph documents, returning their local-handler publication for execution after the graph-projection fence has advanced.A client implementation for managing and storing events in an in-memory event store.Allows already-prepared, independent model commits to enter the websocket queue as one batch.Request-owned context for completing model commits in the transport result batch that contains them.Completes aligned model results and their request-owned contexts as one unit.WebSocket-based implementation of theEventStoreClient, enabling interaction with the Fluxzero Runtime's event store via a persistent WebSocket connection.