IWorkerManager
Namespace: MBrace.Runtime
Worker manager abstraction; must be serializable
Instance members
| Instance member | Description |
DeclareWorkerStatus(id, status)
Signature: (id:IWorkerId * status:WorkerExecutionStatus) -> Async<unit>
Modifiers: abstract |
Asynchronously declares the current worker work item execution status. |
DecrementWorkItemCount(id)
Signature: id:IWorkerId -> Async<unit>
Modifiers: abstract |
Asynchronously declares that the worker active work item count has decreased by one. |
GetAvailableWorkers()
Signature: unit -> Async<WorkerState []>
Modifiers: abstract |
Asynchronously requests node performance metrics for all nodes. |
IncrementWorkItemCount(id)
Signature: id:IWorkerId -> Async<unit>
Modifiers: abstract |
Asynchronously declares that the worker active work item count has increased by one. |
SubmitPerformanceMetrics(id, perf)
Signature: (id:IWorkerId * perf:PerformanceInfo) -> Async<unit>
Modifiers: abstract |
Asynchronously submits node performance metrics for provided worker. |
SubscribeWorker(id, info)
Signature: (id:IWorkerId * info:WorkerInfo) -> Async<IDisposable>
Modifiers: abstract |
Subscribe a new worker instance to the cluster. |
TryGetWorkerState(id)
Signature: id:IWorkerId -> Async<WorkerState option>
Modifiers: abstract |
Asynchronously returns current worker information for provided worker reference. |
