io.zeebe.util.sched

Class ActorScheduler.ActorSchedulerBuilder

java.lang.Object

io.zeebe.util.sched.ActorScheduler.ActorSchedulerBuilder

Enclosing class:

ActorScheduler

public static class ActorScheduler.ActorSchedulerBuilder
extends Object

Constructor Summary

Constructors

Constructor and Description
ActorSchedulerBuilder()

Method Summary

Modifier and Type	Method and Description
ActorScheduler	build()
ActorClock	getActorClock()
ActorExecutor	getActorExecutor()
ActorScheduler.ActorThreadFactory	getActorThreadFactory()
ActorTimerQueue	getActorTimerQueue()
ThreadPoolExecutor	getBlockingTasksRunner()
java.time.Duration	getBlockingTasksShutdownTime()
int	getCpuBoundActorThreadCount()
ActorThreadGroup	getCpuBoundActorThreads()
int	getIoBoundActorThreadCount()
ActorThreadGroup	getIoBoundActorThreads()
MetricsManager	getMetricsManager()
double[]	getPriorityQuotas()
String	getSchedulerName()
ActorScheduler.ActorSchedulerBuilder	setActorClock(ActorClock actorClock)
ActorScheduler.ActorSchedulerBuilder	setActorThreadFactory(ActorScheduler.ActorThreadFactory actorThreadFactory)
ActorScheduler.ActorSchedulerBuilder	setActorTimerQueue(ActorTimerQueue actorTimerQueue)
ActorScheduler.ActorSchedulerBuilder	setBlockingTasksShutdownTime(java.time.Duration blockingTasksShutdownTime)
ActorScheduler.ActorSchedulerBuilder	setCpuBoundActorThreadCount(int actorThreadCount)
ActorScheduler.ActorSchedulerBuilder	setIoBoundActorThreadCount(int ioBoundActorsThreadCount)
ActorScheduler.ActorSchedulerBuilder	setMetricsManager(MetricsManager metricsManager)
ActorScheduler.ActorSchedulerBuilder	setSchedulerName(String schedulerName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ActorSchedulerBuilder

public ActorSchedulerBuilder()

Method Detail

setActorTimerQueue

public ActorScheduler.ActorSchedulerBuilder setActorTimerQueue(ActorTimerQueue actorTimerQueue)

setActorClock

public ActorScheduler.ActorSchedulerBuilder setActorClock(ActorClock actorClock)

setMetricsManager

public ActorScheduler.ActorSchedulerBuilder setMetricsManager(MetricsManager metricsManager)

setCpuBoundActorThreadCount

public ActorScheduler.ActorSchedulerBuilder setCpuBoundActorThreadCount(int actorThreadCount)

setIoBoundActorThreadCount

public ActorScheduler.ActorSchedulerBuilder setIoBoundActorThreadCount(int ioBoundActorsThreadCount)

setActorThreadFactory

public ActorScheduler.ActorSchedulerBuilder setActorThreadFactory(ActorScheduler.ActorThreadFactory actorThreadFactory)

setBlockingTasksShutdownTime

public ActorScheduler.ActorSchedulerBuilder setBlockingTasksShutdownTime(java.time.Duration blockingTasksShutdownTime)

setSchedulerName

public ActorScheduler.ActorSchedulerBuilder setSchedulerName(String schedulerName)

getSchedulerName

public String getSchedulerName()

getActorClock

public ActorClock getActorClock()

getActorTimerQueue

public ActorTimerQueue getActorTimerQueue()

getMetricsManager

public MetricsManager getMetricsManager()

getCpuBoundActorThreadCount

public int getCpuBoundActorThreadCount()

getIoBoundActorThreadCount

public int getIoBoundActorThreadCount()

getPriorityQuotas

public double[] getPriorityQuotas()

getActorThreadFactory

public ActorScheduler.ActorThreadFactory getActorThreadFactory()

getBlockingTasksRunner

public ThreadPoolExecutor getBlockingTasksRunner()

getBlockingTasksShutdownTime

public java.time.Duration getBlockingTasksShutdownTime()

getActorExecutor

public ActorExecutor getActorExecutor()

getCpuBoundActorThreads

public ActorThreadGroup getCpuBoundActorThreads()

getIoBoundActorThreads

public ActorThreadGroup getIoBoundActorThreads()

build

public ActorScheduler build()