@SPI public interface CatchUpStorage extends Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>
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.
|
void write(io.spine.server.delivery.CatchUp message)
message
- a message to writejava.lang.Iterable<io.spine.server.delivery.CatchUp> readAll()
Iterable
over all the stored catch-up processes.java.lang.Iterable<io.spine.server.delivery.CatchUp> readByType(io.spine.type.TypeUrl projectionType)
projectionType
- the type of the projection state to use for filtering