io.spine.server.delivery

Interface CatchUpStorage

All Superinterfaces:

java.lang.AutoCloseable, Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

All Known Implementing Classes:

InMemoryCatchUpStorage

@SPI
public interface CatchUpStorage
extends Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

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

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<io.spine.server.delivery.CatchUp>	readAll() Returns an Iterable over all the stored catch-up processes.
java.lang.Iterable<io.spine.server.delivery.CatchUp>	readByType(io.spine.type.TypeUrl projectionType) Reads all the catch-up processes which update the projection of the specified type.
void	write(io.spine.server.delivery.CatchUp message) Writes a message to the storage.

Methods inherited from interface io.spine.server.storage.Storage

close, index, isMultitenant, isOpen, read, write

Method Detail

write

void write(io.spine.server.delivery.CatchUp message)

Writes a message to the storage.

Parameters:

message - a message to write

readAll

java.lang.Iterable<io.spine.server.delivery.CatchUp> readAll()

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

readByType

java.lang.Iterable<io.spine.server.delivery.CatchUp> readByType(io.spine.type.TypeUrl projectionType)

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

Parameters:

projectionType - the type of the projection state to use for filtering