io.spine.server.delivery

Class CatchUpStorage

java.lang.Object

io.spine.server.storage.AbstractStorage<I,R>

io.spine.server.storage.RecordStorage<I,R>

io.spine.server.storage.RecordStorageDelegate<I,M>

io.spine.server.storage.MessageStorage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp>

io.spine.server.delivery.CatchUpStorage

All Implemented Interfaces:

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

@SPI
public class CatchUpStorage
extends MessageStorage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp>

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

Constructor Summary

Constructors

Constructor and Description
CatchUpStorage(StorageFactory factory, boolean multitenant)

Method Summary

Modifier and Type	Method and Description
protected java.util.Iterator<io.spine.server.delivery.CatchUp>	readAll() Reads all message records in the storage.
java.util.Iterator<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 the message to the storage.

Methods inherited from class io.spine.server.storage.MessageStorage

write, writeBatch

Methods inherited from class io.spine.server.storage.RecordStorageDelegate

close, delete, deleteAll, deleteRecord, index, index, isMultitenant, isOpen, queryForAll, read, read, readAll, readAll, readAll, readAllRecords, toQuery, toQuery, toQuery, toQuery, write, writeAll, writeRecord

Methods inherited from class io.spine.server.storage.RecordStorage

queryBuilder

Methods inherited from class io.spine.server.storage.AbstractStorage

checkNotClosed, checkNotClosed, isClosed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CatchUpStorage

public CatchUpStorage(StorageFactory factory,
                      boolean multitenant)

Method Detail

readByType

public java.util.Iterator<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

readAll

protected java.util.Iterator<io.spine.server.delivery.CatchUp> readAll()

Reads all message records in the storage.

This method should be used with the performance and memory considerations in mind.

Overrides to open as a part of the protected API.

Overrides:

readAll in class RecordStorageDelegate<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp>

Returns:

iterator over the records

write

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

Writes the message to the storage.

The identifier and the columns for the written record are extracted via the record specification.

Overrides to open as a part of the public API.

Overrides:

write in class MessageStorage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp>

Parameters:

message - the message to write