MBrace.Runtime


ICloudWorkItemQueue

Namespace: MBrace.Runtime

Defines a distributed queue for work items

Instance members

Instance memberDescription
BatchEnqueue(wormItems)
Signature: (wormItems:CloudWorkItem []) -> Async<unit>
Modifiers: abstract

Asynchronoulsy enqueue a batch of work items to queue.

Enqueue(workItem, isClientSideEnqueue)
Signature: (workItem:CloudWorkItem * isClientSideEnqueue:bool) -> Async<unit>
Modifiers: abstract

Asynchronously enqueue a singular work item to queue.

TryDequeue(id)
Signature: id:IWorkerId -> Async<ICloudWorkItemLeaseToken option>
Modifiers: abstract

Asynchronously attempt to dequeue a work item, if it exists.

Fork me on GitHub