Namespace Microsoft.Psi
Classes
Available
Collection of greedy interpolators that act on immediately available data.
Clock
Represents virtual time.
ComponentCompletedEventArgs
Class encapsulating the event arguments provided by the Component
ConfigurationHelper
A component helper for managing component configuration.
DebugExtensions
Class containing debug extensions for the executive subsystem.
DeliveryPolicy
Encapsulates the options for message delivery behavior.
DeliveryPolicy<T>
Encapsulates the options for message delivery behavior.
Emitter<T>
Represents a stream of messages. An emitter is similar to a .Net Event, in that it is used to propagate information to a set of subscriber that is only known at runtime. While a subscriber to an event is of type delegate, a subscriber to an emitter is of type Receiver<T> (which wraps a delegate).
Generators
Factory methods for constructing finite stream generators.
GreedyInterpolator<T>
Defines a greedy stream interpolator with the same input and output type.
GreedyInterpolator<TIn, TResult>
Defines a greedy stream interpolator.
Interpolator<T>
Defines a stream interpolator with the same input and output type.
Interpolator<TIn, TResult>
Defines a base abstract class for stream interpolators.
Interval<TPoint, TSpan, TEndpoint, T>
Represents an interval with bounded/unbounded and inclusive/exclusive end points.
IntervalEndpoint<TPoint>
Represents a bounded/unbounded, inclusive/exclusive interval endpoint value.
IntInterval
Represents an integer interval with bounded/unbounded and inclusive/exclusive end points.
KeyedSharedPool<T, TKey>
Provides a pool of shared objects organized by a key. The key is used both to group interchangeable objects as well as a parameter to the object allocation function.
MathExtensions
Extension methods for certain math operations.
Message
Static methods that simplify Message<T> creation.
Metadata
Represents common metadata used in Psi stores.
ObjectDisposedWithHistoryException
The exception that is thrown, including history, when an operation is performed on a disposed object.
Operators
Extension methods that simplify operator usage.
Operators.StreamEnumerable<T>
Enumerable stream class.
Operators.StreamObservable<T>
Observable stream class.
PerfCounterCollection<TKey>
Performance counter collection.
PerfCounters<TKey>
Provides methods for creating and updating the performance counters.
Pipeline
Represents a graph of components and controls scheduling and message passing.
PipelineCompletedEventArgs
Provides data for the Pipeline
PipelineExceptionNotHandledEventArgs
Provides data for the Pipeline
PipelineRunEventArgs
Class encapsulating the event arguments provided by the Pipeline
PlatformResources
Global registry of named platform resources.
PsiStore
Provides static methods to access multi-stream \psi stores.
PsiStreamMetadata
Represents metadata used in storing stream data in a Psi store.
RealInterval
Represents a real (double) interval with bounded/unbounded and inclusive/exclusive end points.
Receiver<T>
A receiver that calls the wrapped delegate to deliver messages by reference (hence, unsafe). The wrapped delegate must not modify or store the message or any part of the message.
RecyclingPool
Message recycling pool class.
RelativeTimeInterval
Represents a TimeSpan interval with bounded/unbounded and inclusive/exclusive end points.
ReplayDescriptor
Descriptor for pipeline replay.
Reproducible
Collection of reproducible interpolators.
ReproducibleInterpolator<T>
Defines a reproducible stream interpolator with the same input and output type.
ReproducibleInterpolator<TIn, TResult>
Defines a reproducible stream interpolator.
Serializer
The main entry point into the serialization subsystem. Provides methods to serialize, deserialize and clone objects.
Shared
Shared resource utility.
Shared<T>
Provides a container that tracks the usage of a shared resource (such as a large memory allocation). Follow the Cloning pattern and use the Shared.DeepClone extension method instead of direct assignment to create long-lived references to the same shared resource.
SharedArrayPool<T>
Provides a pool of shared arrays.
SharedPool<T>
Provides a pool of shared objects. Use this class in conjunction with Shared<T>.
StreamMetadataBase
Stream metadata base class.
Subpipeline
Represents a graph of components and controls scheduling and message passing.
TimeInterval
Represents a time interval with bounded/unbounded and inclusive/exclusive end points.
Timers
Factory methods for instantiating timers.
TypeResolutionHelper
Helper class for type resolution.
Structs
Envelope
Represents the envelope of a message published to a data stream. See Message<T> for details.
InterpolationResult<T>
Result of interpolation.
Message<T>
Represents a message that can be published to a data stream.
Interfaces
IConsumer<TIn>
Components that implement this interface are simple, single input consumers.
IEmitter
Enables message passing between components.
IInterval<TPoint, TSpan, TEndpoint, T>
Represents an interval with bounded/unbounded and inclusive/exclusive end points.
IIntervalEndpoint<TPoint>
Represents a bounded/unbounded, inclusive/exclusive interval endpoint value.
IPerfCounterCollection<TKey>
Represents a performance counter collection.
IPerfCounters<TKey>
Represents methods for creating and updating the performance counters.
IProducer<TOut>
Components that implement this interface are simple, single output generators.
IReceiver
Enables message passing between components.
IRecyclingPool<T>
Maintains a cache of unused instances that can be use as cloning or deserialization targets.
IStreamMetadata
Represents metadata used in storing stream data in a store.
Enums
DeliveryPolicySpec
Defines specifiers for global delivery policies.
EmitterCounters
The counters supported by all Emitters.
InterpolationResultType
Type of interpolation result.
MetadataKind
Specifies the kind of Metadata.
PerfCounterType
Specifies the formula used to update the performance counters.
ReceiverCounters
The counters we support.
StreamMetadataFlags
Specifies custom flags for Psi data streams.
Delegates
Emitter<T>.ClosedHandler
Emitter closed handler.
Emitter<T>.ValidateMessageHandler
Validate message handler.
Receiver<T>.UnsubscribedHandler
Receiver unsubscribed handler.