server/io.spine.server.projection

Package-level declarations

This package provides classes for working with event stream projections.

Types

public class DefaultProjectionRepository<I, P extends Projection<I, S, ? extends Object>, S extends EntityState> extends ProjectionRepository<I, P, S> implements DefaultRepository

Default implementation of ProjectionRepository.

public abstract class Projection<I, M extends EntityState, B extends ValidatingBuilder<M>> extends TransactionalEntity<I, S, B> implements EventPlayer, EventSubscriber, HasVersionColumn<I, S>, HasLifecycleColumns<I, S>

Projection holds a structural representation of data extracted from a stream of events.

public class ProjectionEndpoint<I, P extends Projection<I, S, ? extends Object>, S extends EntityState> extends EntityMessageEndpoint<I, E, M> implements EventEndpoint<I>

Dispatches an event to projections.

public abstract class ProjectionMigration<I, P extends Projection<I, S, B>, S extends EntityState, B extends ValidatingBuilder<S>> extends Migration<I, E, S>

A Migration applied to a ProcessManager instance.

public abstract class ProjectionRepository<I, P extends Projection<I, S, ? extends Object>, S extends EntityState> extends EventDispatchingRepository<I, E, S>

Abstract base for repositories managing Projections.

public abstract class ProjectionStorage<I> extends RecordStorage<I>

The storage used by projection repositories for keeping Projections and the timestamp of the last event processed by the projection repository.

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

A transaction, within which projection instances are modified.