Package io.fluxcapacitor.javaclient.persisting.eventsourcing

package io.fluxcapacitor.javaclient.persisting.eventsourcing
  • Class
    Description
    AggregateEventStream<T>
    A wrapper around a stream of aggregate events, enriched with metadata such as the aggregate ID and the last known sequence number.
    Apply
    Indicates that a method or constructor applies an update to an entity, or creates or deletes an entity.
    DefaultEventStore
    Default implementation of the EventStore interface, providing mechanisms to store and retrieve events associated with aggregate instances.
    DefaultSnapshotStore
    Default implementation of the SnapshotStore interface, responsible for managing snapshots of aggregate roots in an event-sourced system.
    EventSourcingException
    Thrown when an event sourcing operation fails.
    EventStore
    High-level abstraction for accessing and storing domain events in an event-sourced system.
    InterceptApply
    Indicates that a method should intercept and potentially transform an update before it is applied to an entity.
    NoOpSnapshotStore
    A SnapshotStore implementation that is used when snapshotting is explicitly disabled, such as when snapshotPeriod <= 0 is configured on an aggregate via Aggregate.
    NoSnapshotTrigger
    A SnapshotTrigger implementation that never triggers snapshot creation.
    PeriodicSnapshotTrigger
    A SnapshotTrigger that triggers snapshot creation at fixed intervals based on the aggregate's sequence number.
    SnapshotStore
    Interface for managing snapshots of aggregates in an event-sourced system.
    SnapshotTrigger
    Functional interface used to determine whether a new snapshot should be created for an aggregate.