server/io.spine.server.aggregate

Package-level declarations

Types

public abstract class Aggregate<I, S extends EntityState, B extends ValidatingBuilder<S>> extends CommandHandlingEntity<I, S, B> implements EventPlayer, EventReactor

Abstract base for aggregates.

AggregateField

public enum AggregateField implements StorageField

A container for the storage fields specific for the AggregateStorage and its implementations.

AggregatePart

public abstract class AggregatePart<I, S extends EntityState, B extends ValidatingBuilder<S>, R extends AggregateRoot> extends Aggregate<I, S, B>

A part of a larger aggregate.

AggregatePartRepository

public abstract class AggregatePartRepository<I, A extends AggregatePart<I, ? extends Object, ? extends Object, R>, R extends AggregateRoot> extends AggregateRepository<I, A>

Common abstract base for repositories that manage AggregateParts.

AggregateReadRequest

public final class AggregateReadRequest implements ReadRequest

A request to read events for a particular Aggregate from AggregateStorage.

AggregateRepository

public abstract class AggregateRepository<I, A extends Aggregate<I, ? extends Object, ? extends Object>> extends Repository<I, E> implements CommandDispatcher, EventProducingRepository, EventDispatcherDelegate

The repository which manages instances of Aggregates.

AggregateRoot

public class AggregateRoot

A root object for a larger aggregate.

AggregateRootDirectory

public interface AggregateRootDirectory

A mapping of aggregate roots to the associated parts.

AggregateStorage

public abstract class AggregateStorage extends AbstractStorage<I, M, R> implements StorageWithLifecycleFlags<I, M, R>

An event-sourced storage of aggregate part events and snapshots.

AggregateTransaction

public class AggregateTransaction<I, S extends EntityState, B extends ValidatingBuilder<S>> extends EventPlayingTransaction<I, E, S, B>

A transaction, within which Aggregate instances are modified.

Apply

@Retention(value = RetentionPolicy.RUNTIME)

@Target(value = ElementType.METHOD)

public @interface Apply

Marks a method of an aggregate as one that modifies the state of the aggregate with data from the passed event.

DefaultAggregatePartRepository

public final class DefaultAggregatePartRepository<I, A extends AggregatePart<I, ? extends Object, ? extends Object, R>, R extends AggregateRoot> extends AggregatePartRepository<I, A, R> implements DefaultRepository

Default implementation of AggregatePartRepository.

DefaultAggregateRepository

public final class DefaultAggregateRepository<I, A extends Aggregate<I, ? extends Object, ? extends Object>> extends AggregateRepository<I, A> implements DefaultRepository

Default implementation of AggregateRepository.

EventImportDispatcher

public final class EventImportDispatcher implements EventDispatcher

Dispatches events to be imported to the associated aggregate repository.

ImportBus

public final class ImportBus extends UnicastBus<T, E, C, D>

Dispatches events to repositories of aggregates that import these events.

InMemoryRootDirectory

public final class InMemoryRootDirectory implements AggregateRootDirectory

An in-mem implementation of AggregateRootDirectory.

UnsupportedImportEventException

public final class UnsupportedImportEventException extends RuntimeException implements MessageUnhandled

Thrown when there are no aggregates that accept an event message for import.