io.spine.server.storage

Interface StorageFactory

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

InMemoryStorageFactory

public interface StorageFactory
extends java.lang.AutoCloseable

A factory for creating storages used by repositories EventStore and Stand.

Method Summary

Modifier and Type	Method and Description
<I> AggregateStorage<I>	createAggregateStorage(ContextSpec context, java.lang.Class<? extends Aggregate<I,?,?>> aggregateClass) Creates a new AggregateStorage.
CatchUpStorage	createCatchUpStorage(boolean multitenant) Creates a new CatchUpStorage.
default EventStore	createEventStore(ContextSpec context) Creates a new EventStore.
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.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

createAggregateStorage

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

Creates a new AggregateStorage.

Type Parameters:

I - the type of aggregate IDs

Parameters:

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

aggregateClass - the class of Aggregates to be stored

createRecordStorage

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

Creates a new RecordStorage.

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

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

Creates a new ProjectionStorage.

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

InboxStorage createInboxStorage(boolean multitenant)

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.

Parameters:

multitenant - whether the created storage should be multi-tenant

createCatchUpStorage

CatchUpStorage createCatchUpStorage(boolean multitenant)

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.

Parameters:

multitenant - whether the created storage should be multi-tenant

createEventStore

default EventStore createEventStore(ContextSpec context)

Creates a new EventStore.

Parameters:

context - specification of the Bounded Context events of which the store would serve