Logo Orsak

ScalingJobBuilder2<'T, 'r> Type

Constructors

Constructor Description

ScalingJobBuilder2(t)

Full Usage: ScalingJobBuilder2(t)

Parameters:
    t : ^T

Returns: ScalingJobBuilder2<^T, 'r>
t : ^T
Returns: ScalingJobBuilder2<^T, 'r>

Instance members

Instance member Description

this.Run

Full Usage: this.Run

Parameters:
Returns: ScalingJobDefinition
Modifiers: inline
spec : ScalingJobSpec<(unit -> Effect<'r, unit, 'err>), EnvironmentNotSet, WorkloadNotSet>
Returns: ScalingJobDefinition

Inherited members

Inherited from ScalingJobBuilder

Instance members

Instance member Description

environment create

Full Usage: environment create

Parameters:
Returns: ScalingJobSpec<'Work, ('b -> CancellationToken -> 'r), 'Load>
Type parameters: 'Work, 'a, 'Load, 'r, 'b (requires :> System.IServiceProvider)

The environment of a worker, from the services and the token that stops the worker.

create : IServiceProvider -> CancellationToken -> 'r
Returns: ScalingJobSpec<'Work, ('b -> CancellationToken -> 'r), 'Load>

maxExtraWorkers count

Full Usage: maxExtraWorkers count

Parameters:
    count : int

Returns: ScalingJobSpec<'a, 'b, 'c>
Type parameters: 'a, 'b, 'c
count : int
Returns: ScalingJobSpec<'a, 'b, 'c>

maxRestartDelay delay

Full Usage: maxRestartDelay delay

Parameters:
Returns: ScalingJobSpec<'a, 'b, 'c>
Type parameters: 'a, 'b, 'c
delay : TimeSpan
Returns: ScalingJobSpec<'a, 'b, 'c>

monitorEvery interval

Full Usage: monitorEvery interval

Parameters:
Returns: ScalingJobSpec<'a, 'b, 'c>
Type parameters: 'a, 'b, 'c
interval : TimeSpan
Returns: ScalingJobSpec<'a, 'b, 'c>

restartAfter delay

Full Usage: restartAfter delay

Parameters:
Returns: ScalingJobSpec<'a, 'b, 'c>
Type parameters: 'a, 'b, 'c
delay : TimeSpan
Returns: ScalingJobSpec<'a, 'b, 'c>

this.Run

Full Usage: this.Run

Parameters:
Returns: ScalingJobDefinition
Type parameters: 'r, 'err

Only a spec with work, an environment and a workload gets here: 'r and 'err are shared by them.

spec : ScalingJobSpec<(unit -> Effect<'r, unit, 'err>), (IServiceProvider -> CancellationToken -> 'r), (IServiceProvider -> CancellationToken -> Task<WorkerLoad>)>
Returns: ScalingJobDefinition

this.Run

Full Usage: this.Run

Parameters:
Returns: ScalingJobDefinition
Type parameters: 'r, 'err
spec : ScalingJobSpec<(unit -> Effect<'r, unit, 'err>), (IServiceProvider -> CancellationToken -> 'r), WorkloadNotSet>
Returns: ScalingJobDefinition

work work

Full Usage: work work

Parameters:
Returns: ScalingJobSpec<(unit -> Effect<'r, unit, 'err>), 'Env, 'Load>
Type parameters: 'a, 'Env, 'Load, 'r, 'err

The effect each worker runs over and over, created once per worker from the services.

work : Expr<(unit -> Effect<'r, unit, 'err>)>
Returns: ScalingJobSpec<(unit -> Effect<'r, unit, 'err>), 'Env, 'Load>

workload workload

Full Usage: workload workload

Parameters:
Returns: ScalingJobSpec<'Work, 'Env, ('b -> CancellationToken -> Task<WorkerLoad>)>
Type parameters: 'Work, 'Env, 'a, 'b (requires :> System.IServiceProvider)

How much work there is, from the services, checked to decide whether to add or remove a worker.

workload : IServiceProvider -> CancellationToken -> Task<WorkerLoad>
Returns: ScalingJobSpec<'Work, 'Env, ('b -> CancellationToken -> Task<WorkerLoad>)>

this.Yield

Full Usage: this.Yield

Parameters:
    () : unit

Returns: ScalingJobSpec<WorkNotSet, EnvironmentNotSet, WorkloadNotSet>

Type something to start searching.