Package one.microstream.storage.types

Interface StorageOperationController

All Known Implementing Classes:

StorageOperationController.Default

public interface StorageOperationController

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	StorageOperationController.Creator
static class	StorageOperationController.Default

Method Summary

Modifier and Type	Method	Description
void	activate()
StorageChannelCountProvider	channelCountProvider()
boolean	checkProcessingEnabled()
void	deactivate()
XGettingSequence<Throwable>	disruptions()
default boolean	hasDisruptions()
boolean	isChannelProcessingEnabled()
static StorageOperationController	New(StorageManager storageManager, StorageChannelCountProvider channelCountProvider)
static StorageOperationController.Creator	Provider()
void	registerDisruption(Throwable disruption)
void	setChannelProcessingEnabled(boolean enabled)

Method Detail

channelCountProvider

StorageChannelCountProvider channelCountProvider()

isChannelProcessingEnabled

boolean isChannelProcessingEnabled()

checkProcessingEnabled

boolean checkProcessingEnabled()
                        throws StorageExceptionDisruptingExceptions

Throws:

StorageExceptionDisruptingExceptions

registerDisruption

void registerDisruption(Throwable disruption)

disruptions

XGettingSequence<Throwable> disruptions()

hasDisruptions

default boolean hasDisruptions()

setChannelProcessingEnabled

void setChannelProcessingEnabled(boolean enabled)

activate

void activate()

deactivate

void deactivate()

New

static StorageOperationController New(StorageManager storageManager,
                                      StorageChannelCountProvider channelCountProvider)

Provider

static StorageOperationController.Creator Provider()