Logo Orsak

DelegatingScalingEffectJob<'r, 'err> Type

A job whose workload is a function, so the builder needs no subclass per job.

Constructors

Constructor Description

DelegatingScalingEffectJob(name, logger, _services, work, runnerFactory, workload, ?maxExtraWorkers, ?monitorInterval, ?restartDelay, ?maxRestartDelay)

Full Usage: DelegatingScalingEffectJob(name, logger, _services, work, runnerFactory, workload, ?maxExtraWorkers, ?monitorInterval, ?restartDelay, ?maxRestartDelay)

Parameters:
Returns: DelegatingScalingEffectJob<'r, 'err>
name : string
logger : ILogger
_services : IServiceProvider
work : unit -> Effect<'r, unit, 'err>
runnerFactory : CancellationToken -> 'r
workload : CancellationToken -> Task<WorkerLoad>
?maxExtraWorkers : int
?monitorInterval : TimeSpan
?restartDelay : TimeSpan
?maxRestartDelay : TimeSpan
Returns: DelegatingScalingEffectJob<'r, 'err>

Inherited members

Inherited from ScalingEffectJob<'r, unit, 'err>

Instance members

Instance member Description

this.GetWorkload

Full Usage: this.GetWorkload

Parameters:
Returns: Task<WorkerLoad>
Modifiers: abstract

How much work the job has, checked every monitorInterval to decide whether to add or remove a worker. An exception is logged, and the workers stay as they are until the next check.

arg0 : CancellationToken
Returns: Task<WorkerLoad>

Type something to start searching.