io.spine.server.storage.memory

Class InMemoryProjectionStorage<I>

java.lang.Object

io.spine.server.storage.AbstractStorage<I,io.spine.server.entity.EntityRecord,RecordReadRequest<I>>

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

io.spine.server.projection.ProjectionStorage<I>

io.spine.server.storage.memory.InMemoryProjectionStorage<I>

Type Parameters:

I - the type of stream projection IDs

All Implemented Interfaces:

Storage<I,io.spine.server.entity.EntityRecord,RecordReadRequest<I>>, StorageWithLifecycleFlags<I,io.spine.server.entity.EntityRecord,RecordReadRequest<I>>, java.lang.AutoCloseable

public final class InMemoryProjectionStorage<I>
extends ProjectionStorage<I>

The in-memory implementation of ProjectionStorage.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the storage.
boolean	delete(I id) Deletes the record with the passed ID.
java.util.Iterator<I>	index() Returns an iterator over identifiers of records in the storage.
protected java.util.Iterator<io.spine.server.entity.EntityRecord>	readAllRecords(io.spine.client.ResponseFormat format) Obtains an iterator for reading all records.
protected java.util.Iterator<io.spine.server.entity.EntityRecord>	readMultipleRecords(java.lang.Iterable<I> ids, com.google.protobuf.FieldMask fieldMask) Obtains an iterator for reading multiple records by IDs, and applying the passed field mask to the results.
RecordStorage<I>	recordStorage() Returns an entity storage implementation.

Methods inherited from class io.spine.server.projection.ProjectionStorage

readAllRecords, readRecord, writeRecord, writeRecords

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

columnList, read, read, readAll, readAll, readAll, readLifecycleFlags, readMultiple, write, write, write, writeLifecycleFlags

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

checkNotClosed, checkNotClosed, 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

isMultitenant, isOpen

Method Detail

index

public java.util.Iterator<I> index()

Description copied from interface: Storage

Returns an iterator over identifiers of records in the storage.

recordStorage

public RecordStorage<I> recordStorage()

Description copied from class: ProjectionStorage

Returns an entity storage implementation.

Specified by:

recordStorage in class ProjectionStorage<I>

close

public void close()

Description copied from class: AbstractStorage

Closes the storage.

Specified by:

close in interface Storage<I,io.spine.server.entity.EntityRecord,RecordReadRequest<I>>

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class AbstractStorage<I,io.spine.server.entity.EntityRecord,RecordReadRequest<I>>

delete

public boolean delete(I id)

Description copied from class: RecordStorage

Deletes the record with the passed ID.

Specified by:

delete in class RecordStorage<I>

Parameters:

id - the record to delete

Returns:

true if the operation succeeded, false otherwise

readMultipleRecords

protected java.util.Iterator<io.spine.server.entity.EntityRecord> readMultipleRecords(java.lang.Iterable<I> ids,
                                                                                      com.google.protobuf.FieldMask fieldMask)

Description copied from class: RecordStorage

Obtains an iterator for reading multiple records by IDs, and applying the passed field mask to the results.

The size of the returned Iterator matches the size of the given ids, with nulls in place of missing or inactive entities.

Specified by:

readMultipleRecords in class RecordStorage<I>

See Also:

BulkStorageOperationsMixin.readMultiple(java.lang.Iterable<I>, com.google.protobuf.FieldMask)

readAllRecords

protected java.util.Iterator<io.spine.server.entity.EntityRecord> readAllRecords(io.spine.client.ResponseFormat format)

Description copied from class: RecordStorage

Obtains an iterator for reading all records.

Only active entities are returned.

Specified by:

readAllRecords in class RecordStorage<I>

Parameters:

format - the expected format of the query response

See Also:

BulkStorageOperationsMixin.readAll(io.spine.client.ResponseFormat)