io.spine.server.storage.memory

Class InMemoryStorageFactory

java.lang.Object

io.spine.server.storage.memory.InMemoryStorageFactory

All Implemented Interfaces:

StorageFactory, java.lang.AutoCloseable

public final class InMemoryStorageFactory
extends java.lang.Object
implements StorageFactory

A factory for in-memory storages.

Method Summary

Modifier and Type	Method and Description
void	close()
<I> AggregateStorage<I>	createAggregateStorage(ContextSpec context, java.lang.Class<? extends Aggregate<I,?,?>> unused) NOTE: the parameter is unused.
CatchUpStorage	createCatchUpStorage(boolean multitenant) Creates a new CatchUpStorage.
InboxStorage	createInboxStorage(boolean multitenant) Creates a new InboxStorage.
<I> ProjectionStorage<I>	createProjectionStorage(ContextSpec context, java.lang.Class<? extends Projection<I,?,?>> projectionClass) Creates a new ProjectionStorage.
<I> RecordStorage<I>	createRecordStorage(ContextSpec context, java.lang.Class<? extends Entity<I,?>> entityClass) Creates a new RecordStorage.
static InMemoryStorageFactory	newInstance() Creates new instance of the factory which would serve the specified context.

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.StorageFactory

createEventStore

Method Detail

newInstance

public static InMemoryStorageFactory newInstance()

Creates new instance of the factory which would serve the specified context.

Returns:

new instance of the factory

createAggregateStorage

public <I> AggregateStorage<I> createAggregateStorage(ContextSpec context,
                                                      java.lang.Class<? extends Aggregate<I,?,?>> unused)

NOTE: the parameter is unused.

Specified by:

createAggregateStorage in interface StorageFactory

Type Parameters:

I - the type of aggregate IDs

Parameters:

context - specification of the Bounded Context AggregateRepository of which requests the creation of the storage

unused - the class of Aggregates to be stored

createRecordStorage

public <I> RecordStorage<I> createRecordStorage(ContextSpec context,
                                                java.lang.Class<? extends Entity<I,?>> entityClass)

Description copied from interface: StorageFactory

Creates a new RecordStorage.

Specified by:

createRecordStorage in interface StorageFactory

Type Parameters:

I - the type of entity IDs

Parameters:

context - specification of the Bounded Context RecordBasedRepository of which requests the creation of the storage

entityClass - the class of entities to be stored

createProjectionStorage

public <I> ProjectionStorage<I> createProjectionStorage(ContextSpec context,
                                                        java.lang.Class<? extends Projection<I,?,?>> projectionClass)

Description copied from interface: StorageFactory

Creates a new ProjectionStorage.

Specified by:

createProjectionStorage in interface StorageFactory

Type Parameters:

I - the type of stream projection IDs

Parameters:

context - specification of the Bounded Context ProjectionRepository of which requests the creation of the storage

projectionClass - the class of Projections to be stored

createInboxStorage

public InboxStorage createInboxStorage(boolean multitenant)

Description copied from interface: StorageFactory

Creates a new InboxStorage.

The instance of InboxStorage is used in the Delivery operations. Therefore there is typically just a single instance of InboxStorage per ServerEnvironment instance, unlike other Storage types which instances are created per-BoundedContext.

Specified by:

createInboxStorage in interface StorageFactory

Parameters:

multitenant - whether the created storage should be multi-tenant

createCatchUpStorage

public CatchUpStorage createCatchUpStorage(boolean multitenant)

Description copied from interface: StorageFactory

Creates a new CatchUpStorage.

Similar to InboxStorage, this type of storage is also used in the Delivery routines. So by default there is a single instance of CatchUpStorage per ServerEnvironment.

Specified by:

createCatchUpStorage in interface StorageFactory

Parameters:

multitenant - whether the created storage should be multi-tenant

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable