PersistentStreamProvider Class

Definition

Namespace:: Orleans.Providers.Streams.Common

Assembly:: Orleans.Streaming.dll

Assembly:: Orleans.Core.dll

Package:: Microsoft.Orleans.Streaming v10.0.0

Package:: Microsoft.Orleans.Core v2.4.5

Package:: Microsoft.Orleans.Core v3.6.5

Package:: Microsoft.Orleans.Streaming v7.2.5

Package:: Microsoft.Orleans.Streaming v8.0.0

Package:: Microsoft.Orleans.Streaming v8.1.0

Package:: Microsoft.Orleans.Streaming v8.2.0

Package:: Microsoft.Orleans.Streaming v9.0.0

Package:: Microsoft.Orleans.Streaming v9.1.2

Source:: PersistentStreamProvider.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Persistent stream provider that uses an adapter for persistence

public class PersistentStreamProvider : Orleans.ILifecycleParticipant<Orleans.ILifecycleObservable>, Orleans.Providers.IControllable, Orleans.Streams.Core.IStreamSubscriptionManagerRetriever, Orleans.Streams.IStreamProvider

type PersistentStreamProvider = class
    interface IStreamProvider
    interface IControllable
    interface IStreamSubscriptionManagerRetriever
    interface ILifecycleParticipant<ILifecycleObservable>

Public Class PersistentStreamProvider
Implements IControllable, ILifecycleParticipant(Of ILifecycleObservable), IStreamProvider, IStreamSubscriptionManagerRetriever

Inheritance: Object
PersistentStreamProvider

Implements: ILifecycleParticipant<ILifecycleObservable> IControllable IStreamSubscriptionManagerRetriever IStreamProvider

Constructors

Name	Description
PersistentStreamProvider(String, StreamPubSubOptions, StreamLifecycleOptions, IProviderRuntime, DeepCopier, ILogger<PersistentStreamProvider>)
PersistentStreamProvider(String, StreamPubSubOptions, StreamLifecycleOptions, IProviderRuntime, SerializationManager, ILogger<PersistentStreamProvider>)

Properties

Name	Description
IsRewindable
Name

Methods

Name	Description
Create(IServiceProvider, String)
ExecuteCommand(Int32, Object)
GetStream<T>(Guid, String)
GetStream<T>(StreamId)
GetStreamSubscriptionManager()
Participate(ILifecycleObservable)
ParticipateIn<TLifecycle>(IServiceProvider, String)

Extension Methods

Name	Description
GetStream<T>(IStreamProvider, Guid)	Gets the stream with the specified identity and namespace.
GetStream<T>(IStreamProvider, Int64)	Gets the stream with the specified identity and namespace.
GetStream<T>(IStreamProvider, String, Guid)	Gets the stream with the specified identity and namespace.
GetStream<T>(IStreamProvider, String, Int64)	Gets the stream with the specified identity and namespace.
GetStream<T>(IStreamProvider, String, String)	Gets the stream with the specified identity and namespace.
GetStream<T>(IStreamProvider, String)	Gets the stream with the specified identity and namespace.
TryGetStreamSubscriptionManager(IStreamProvider, IStreamSubscriptionManager)	Returns the IStreamSubscriptionManager for the provided stream provider.
TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)

Applies to