Interface IReactiveMetadataProxy

Interface for a client-side proxy for the metadata discovery operations on reactive processing services.

Namespace: Reaqtor

Assembly: Reaqtor.Client.Model.dll

Syntax

public interface IReactiveMetadataProxy

Remarks

This interface provides essential information for reactive processing services that perform delegation. Implementers can extend the provided metadata.

Properties

Observables

Gets a queryable dictionary of observable definition objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveObservableDefinition> Observables { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveObservableDefinition>

Observers

Gets a queryable dictionary of observer definition objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveObserverDefinition> Observers { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveObserverDefinition>

StreamFactories

Gets a queryable dictionary of stream factory definition objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveStreamFactoryDefinition> StreamFactories { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveStreamFactoryDefinition>

Streams

Gets a queryable dictionary of stream objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveStreamProcess> Streams { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveStreamProcess>

SubscriptionFactories

Gets a queryable dictionary of subscription factory definition objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveSubscriptionFactoryDefinition> SubscriptionFactories { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveSubscriptionFactoryDefinition>

Subscriptions

Gets a queryable dictionary of subscription objects.

Declaration

IQueryableDictionary<Uri, IAsyncReactiveSubscriptionProcess> Subscriptions { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IAsyncReactiveSubscriptionProcess>