IParallelismProvider

Namespace: MBrace.Core.Internals

MBrace dependency used for initiating parallel/distributed workflows.

Instance members

Instance member	Description
`CloudProcessId` Signature: string Modifiers: abstract	Get cloud process identifier CompiledName: `get_CloudProcessId`
`CreateCancellationTokenSource(parents)` Signature: (parents:ICloudCancellationToken []) -> Async<ICloudCancellationTokenSource> Modifiers: abstract	Creates a linked cancellation token source given collection of cloud cancellation tokens.
`CurrentWorker` Signature: IWorkerRef Modifiers: abstract	Gets currently running worker CompiledName: `get_CurrentWorker`
`FaultPolicy` Signature: FaultPolicy Modifiers: abstract	Gets the current fault policy. CompiledName: `get_FaultPolicy`
`GetAvailableWorkers()` Signature: unit -> Async<IWorkerRef []> Modifiers: abstract	Get all available workers in cluster
`IsForcedLocalParallelismEnabled` Signature: bool Modifiers: abstract	Specifies whether runtime will evaluate all parallelism primitives using threadpool semantics CompiledName: `get_IsForcedLocalParallelismEnabled`
`IsTargetedWorkerSupported` Signature: bool Modifiers: abstract	Specifies whether runtime supports submission of tasks to specific worker nodes CompiledName: `get_IsTargetedWorkerSupported`
`Logger` Signature: ICloudLogger Modifiers: abstract	Gets the current logger instance. CompiledName: `get_Logger`
`ScheduleChoice(computations)` Signature: (computations:seq<'a * IWorkerRef option>) -> Cloud<'T option> Modifiers: abstract Type parameters: 'a, 'T	Parallel nondeterministic choice implementation.
`ScheduleCreateProcess(...)` Signature: (workflow:Cloud<'T> * faultPolicy:FaultPolicy * cancellationToken:ICloudCancellationToken option * target:IWorkerRef option * procName:string option) -> Cloud<ICloudProcess<'T>> Modifiers: abstract Type parameters: 'T	Start a new computation as a cloud process.
`ScheduleLocalChoice(computations)` Signature: (computations:seq<LocalCloud<'T option>>) -> LocalCloud<'T option> Modifiers: abstract Type parameters: 'T	Parallel nondeterministic choice implementation.
`ScheduleLocalParallel(computations)` Signature: computations:seq<LocalCloud<'T>> -> LocalCloud<'T []> Modifiers: abstract Type parameters: 'T	Parallel fork/join implementation.
`ScheduleParallel(computations)` Signature: (computations:seq<'a * IWorkerRef option>) -> Cloud<'T []> Modifiers: abstract Type parameters: 'a, 'T	Parallel fork/join implementation.
`WithFaultPolicy(newPolicy)` Signature: newPolicy:FaultPolicy -> IParallelismProvider Modifiers: abstract	Creates a new scheduler instance with updated fault policy.
`WithForcedLocalParallelismSetting(...)` Signature: localParallelismEnabled:bool -> IParallelismProvider Modifiers: abstract	Creates a new distribution provider instance with toggled local parallelism semantics
`WorkItemId` Signature: string Modifiers: abstract	Get cloud work item identifier CompiledName: `get_WorkItemId`