WorkerManager
Namespace: MBrace.AWS.Runtime
Instance members
| Instance member | Description |
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 member | Description |
Create(clusterId, logger)
Signature: (clusterId:ClusterId * logger:ISystemLogger) -> WorkerManager
|
