StorageFactory

public interface StorageFactory implements AutoCloseable

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

Functions

public abstract AggregateStorage createAggregateStorage(ContextSpec context, Class<? extends Aggregate<I, ? extends Object, ? extends Object>> aggregateClass)

public abstract CatchUpStorage createCatchUpStorage(boolean multitenant)

Creates a new CatchUpStorage.

Creates a new EventStore.

public abstract InboxStorage createInboxStorage(boolean multitenant)

Creates a new InboxStorage.

public abstract ProjectionStorage createProjectionStorage(ContextSpec context, Class<? extends Projection<I, ? extends Object, ? extends Object>> projectionClass)

public abstract RecordStorage createRecordStorage(ContextSpec context, Class<? extends Entity<I, ? extends Object>> entityClass)

Creates a new RecordStorage.

public abstract void close()