MBrace.Azure


WorkerManager

Namespace: MBrace.Azure.Runtime

Instance members

Instance memberDescription
CullNonResponsiveWorkers(...)
Signature: heartbeatThreshold:TimeSpan -> Async<unit>

Culls workers that have stopped sending heartbeats in a timespan larger than specified threshold

GetAllWorkers()
Signature: unit -> Async<WorkerState []>

Gets all worker records.

GetAvailableWorkers()
Signature: unit -> Async<WorkerState []>

Get workers that are active and actively sending heartbeats

GetInactiveWorkers()
Signature: unit -> Async<WorkerState []>

Workers that fail to give heartbeats.

GetNonResponsiveWorkers(...)
Signature: (heartbeatThreshold:TimeSpan option) -> Async<WorkerState []>

'Running' workers that fail to give heartbeats.

UnsubscribeWorker(workerId)
Signature: workerId:IWorkerId -> Async<unit>

Static members

Static memberDescription
Create(clusterId, logger)
Signature: (clusterId:ClusterId * logger:ISystemLogger) -> WorkerManager
Fork me on GitHub