StorageOperationController (MicroStream API)

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(StorageSystem storageSystem, StorageChannelCountProvider channelCountProvider)`
`static StorageOperationController.Creator`	`Provider()`
`void`	`registerDisruption(Throwable disruption)`
`void`	`setChannelProcessingEnabled(boolean enabled)`

Method Details
- 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(StorageSystem storageSystem, StorageChannelCountProvider channelCountProvider)
- Provider
  
  static StorageOperationController.Creator Provider()