CatchUpStorage

public interface CatchUpStorage implements Storage<I, M, R>

A storage for the state of the ongoing catch-up processes.

Functions

public abstract Iterable<CatchUp> readAll()

Returns an Iterable over all the stored catch-up processes.

public abstract Iterable<CatchUp> readByType(TypeUrl projectionType)

Reads all the catch-up processes which update the projection of the specified type.

public abstract void write(CatchUp message)

Writes a message to the storage.

public abstract void close()

Closes the storage.

public abstract void close()

public abstract Iterator<I> index()

Returns an iterator over identifiers of records in the storage.

public abstract boolean isMultitenant()

Verifies whether the storage is multitenant.

public abstract boolean isOpen()

Verifies whether the storage is open.

public abstract Optional<M> read(R request)

Reads a record from the storage by the specified request.

public abstract void write(I id, M record)

Writes a record into the storage.