io.spine.server.storage.memory

Class InMemoryCatchUpStorage

java.lang.Object

io.spine.server.storage.AbstractStorage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

io.spine.server.storage.memory.InMemoryCatchUpStorage

All Implemented Interfaces:

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

public class InMemoryCatchUpStorage
extends AbstractStorage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>
implements CatchUpStorage, io.spine.logging.Logging

An in-memory implementation of CatchUpStorage.

Constructor Summary

Constructors

Constructor and Description
InMemoryCatchUpStorage(boolean multitenant)

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<io.spine.server.delivery.CatchUpId>	index() Returns an iterator over identifiers of records in the storage.
java.util.Optional<io.spine.server.delivery.CatchUp>	read(CatchUpReadRequest request) Reads a record from the storage by the specified request.
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.CatchUpId id, io.spine.server.delivery.CatchUp record) Writes a record into the storage.

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

checkNotClosed, checkNotClosed, close, isClosed, isMultitenant, isOpen

Methods inherited from class java.lang.Object

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

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

close, isMultitenant, isOpen

Methods inherited from interface io.spine.logging.Logging

_config, _debug, _error, _fine, _finer, _finest, _info, _severe, _trace, _warn, debugLevel, errorLevel, logger, loggerFor

Constructor Detail

InMemoryCatchUpStorage

public InMemoryCatchUpStorage(boolean multitenant)

Method Detail

write

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

Description copied from interface: CatchUpStorage

Writes a message to the storage.

Specified by:

write in interface CatchUpStorage

Parameters:

message - a message to write

readAll

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

Description copied from interface: CatchUpStorage

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

Specified by:

readAll in interface CatchUpStorage

index

public java.util.Iterator<io.spine.server.delivery.CatchUpId> index()

Description copied from interface: Storage

Returns an iterator over identifiers of records in the storage.

Specified by:

index in interface Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

read

public java.util.Optional<io.spine.server.delivery.CatchUp> read(CatchUpReadRequest request)

Description copied from interface: Storage

Reads a record from the storage by the specified request.

Specified by:

read in interface Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

Parameters:

request - the request to read the record

Returns:

a record instance or Optional.empty() if there is no record matching this request

write

public void write(io.spine.server.delivery.CatchUpId id,
                  io.spine.server.delivery.CatchUp record)

Description copied from interface: Storage

Writes a record into the storage.

Rewrites it if a record with this ID already exists in the storage.

Specified by:

write in interface Storage<io.spine.server.delivery.CatchUpId,io.spine.server.delivery.CatchUp,CatchUpReadRequest>

Parameters:

id - the ID for the record

record - the record to store

readByType

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

Description copied from interface: CatchUpStorage

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

Specified by:

readByType in interface CatchUpStorage

Parameters:

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