MBrace.Runtime


WorkerAgent

Namespace: MBrace.Runtime

Worker agent with updatable configuration

Instance members

Instance memberDescription
CurrentStatus
Signature: WorkerExecutionStatus

Gets Current worker state configuration

CompiledName: get_CurrentStatus

CurrentWorker
Signature: IWorkerId

Worker ref representing the current worker instance.

CompiledName: get_CurrentWorker

CurrentWorkItemCount
Signature: int

Gets the current number of work items run by the worker

CompiledName: get_CurrentWorkItemCount

IsRunning
Signature: bool

Gets whether worker agent is currently running

CompiledName: get_IsRunning

MaxWorkItemCount
Signature: int

Gets the maximum number of work items allowed by the worker

CompiledName: get_MaxWorkItemCount

Start()
Signature: unit -> Async<unit>

Starts agent with supplied configuration

Stop(timeout)
Signature: (timeout:int option) -> Async<unit>

Removes current configuration from agent.

Static members

Static memberDescription
Create(...)
Signature: (runtimeManager:IRuntimeManager * workerId:IWorkerId * workItemEvaluator:ICloudWorkItemEvaluator * maxConcurrentWorkItems:int * submitPerformanceMetrics:bool * heartbeatInterval:TimeSpan * heartbeatThreshold:TimeSpan) -> Async<WorkerAgent>

Creates a new Worker agent instance with provided runtime configuration.

Fork me on GitHub