DispatcherBeanFactory

@Factory

The dispatchers (think views of thread pools) and static scopes we use for dataflow.

Constructors

constructor()

@Named(value = "aggregationDispatcher")

@Singleton

fun aggregationDispatcher(@Named(value = "inputStreams") inputStreams: ConnectorInputStreams): ExecutorCoroutineDispatcher

@Named(value = "flushDispatcher")

@Singleton

fun flushDispatcher(): CoroutineDispatcher

@Named(value = "pipelineRunnerDispatcher")

@Singleton

fun pipelineRunnerDispatcher(): CoroutineDispatcher

@Named(value = "pipelineRunnerScope")

@Singleton

fun pipelineRunnerDispatcher(@Named(value = "pipelineRunnerDispatcher") dispatcher: CoroutineDispatcher): CoroutineScope

@Named(value = "stateReconcilerScope")

@Singleton

fun stateDispatcher(@Named(value = "stateReconcilerDispatcher") dispatcher: CoroutineDispatcher): CoroutineScope

@Named(value = "stateReconcilerDispatcher")

@Singleton

fun stateReconcilerDispatcher(): CoroutineDispatcher

@Named(value = "streamFinalizeDispatcher")

@Singleton

fun streamFinalizeDispatcher(): CoroutineDispatcher

@Named(value = "streamInitDispatcher")

@Singleton

fun streamInitDispatcher(): CoroutineDispatcher