MBrace.Runtime

Defines a Cloud work item evaluator that runs in a managed pool of application domains. Loading of assembly dependencies is performed by Vagabond, in a way where conflicting dependencies will never be collocated in the same AppDomain.

Logger that can be used to subscribe underlying loggers.

ILoclaSystemLogManager wrapper for AttacheableLogger

Distributed ICloudCancellationToken[Source] implementation

Represents a log entry that has been generated by an MBrace process

Represents a cloud computation that is being executed in the cluster.

Represents a cloud computation that is being executed in the cluster.

Cloud process metadata

Task result container

Cloud process execution state record

A cloud work item is fragment of a cloud process to be executed in a single machine.

Fault metadata of provided cloud work item

Unique cloud work item identifier

Cloud work item creation metadata

A logger that writes to the system console

Cloud execution time metadata

Logger that writes log entries to a local file

FsPickler.Binary implementation of ISerializer

FsPickler.Json implementation of ISerializer

Abstract FsPickler ISerializer implementation

FsPickler.Xml implementation of ISerializer

Defines a Vagabond assembly manager

Defines a serializable cancellation entry with global visibility that can be cancelled or polled for cancellation.

Defines a serializable cancellation entry manager with global visibility.

Defines a distributed counter entity.

Defines a cloud counter factory abstraction.

Abstraction used for managing cloud log entries

Cloud process completion source abstraction

Cloud process manager object

Defines a serializable, distributed result aggregator entity.

Defines a factory for creating runtime primitives.

Work item evaluator abstraction

Cloud work item lease token given to workers that dequeue it

CloudLogger instance used for logging a specific work item

Defines a distributed queue for work items

Object for managing system logs generated by the current process

Log polling abstraction used for subscribing to new log events

System logger instance used for logging cluster-wide entries

Runtime provided runtime identifier

Abstract MBrace runtime management object. Contains all functionality necessary for the coordination of an MBrace cluster.

Object for managing system logs generated by the entire cluster.

Abstract logger type used by underlying MBrace runtime implementations.

Runtime provided worker identifier must implement equality and comparison semantics

Worker manager abstraction; must be serializable

Json.Net implementation of ISerializer

Defines a Cloud work item evaluator that runs code within the current application domain

LogLevel enumeration

MBrace runtime client handle abstract class.

Action that can be marshalled across AppDomains

Serializable Logger proxy implementation that can be marshaled across AppDomains

A logger that performs no action

Implements the IDistribution provider implementation to be passed to MBrace workflow execution

Some node metrics, such as CPU, memory usage, etc

Collects statistics on CPU, memory, network, etc.

Global Registry for loading IRuntimeManager instances on primitive deserialization

Struct that specifies a single system log entry

Global Vagabond instance container

Worker agent with updatable configuration

Worker execution status for specific item

Worker metadata as specified by the instance itself

A Serializable object used to identify a specific worker in a cluster. Can be used to point computations for execution at specific machines.

Worker state object

Serializable ClosureSiftManager configuration object

Management object used for optimizing large closures using CloudValue and Vagabond. Type is not serializable, transfer using the StoreAssemblyManagerConfiguration object instead.

As simple store log schema where each cloud process creates its own root directory for storing logfiles; possibly not suitable for Azure where root directories are containers.

As simple store log schema where each cloud process creates its own root directory for storing logfiles; possibly not suitable for Azure where root directories are containers.

Creates a schema for writing and fetching log files for specific Cloud tasks in StoreCloudLogManager instances

Creates a schema for writing and fetching system log files for specific workers

Provides utility methods for persisting .NET objects to files in the cloud store. Can be safely serialized.

Represents an object entity that is either persisted in cloud store or comes as an encapsulated pickle if sufficiently small

Contains a closure that has been sifted of large values.

AssemblyManager implementation that uses cloud store to share Vagabond assemblies. Type is not serializable, transfer using the StoreAssemblyManagerConfiguration object instead.

Distributable StoreAssemblyManagement configuration object

Cloud log manager implementation that uses the underlying cloud store for persisting and reading log entries.

CloudValue provider implementation that is based on cloud storage.

Object used for polling log entries from cloud file store

Defines an object that serializes log entries to underlying store in batches

Tools for writing worker system logs to store.

File store caching facility

Cloud file store implementation targeting local file systems.

Thread-safe value container with optimistic update semantics

thread safe cache with expiry semantics

thread safe cache with expiry semantics

In-Memory caching mechanism using System.Runtime.Caching.MemoryCache

Provides a mechanism for cooperative work item execution monitoring.

CloudLogger implementation that writes output to stdout

Local file system CloudFilestore implementation

FsPickler Binary Serializer implementation

FsPickler Json Serializer implementation

FsPickler Xml Serializer implementation

Json.Net Serializer implementation

Cloud cancellation token implementation that wraps around System.Threading.CancellationToken

Cloud cancellation token source implementation that wraps around System.Threading.CancellationTokenSource

Cloud process implementation that wraps around System.Threading.Task for inmemory runtimes

Defines an MBrace thread pool runtime instance that is capable of executing cloud workflows in the thread pool of the current process.

Collection of workflows that provide parallelism using the .NET thread pool

Defines an in-memory dictionary factory using ConcurrentDictionary

ThreadPool runtime IParallelismProvider implementation

Defines an in-memory queue factory using mailbox processor

Provides an In-Memory CloudValue implementation

In-Memory WorkerRef implementation