PersistentStreamProvider

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. PersistentStreamProvider

class

Namespace: Orleans.Providers.Streams.Common

NuGetSourceMarkdown

Persistent stream provider that uses an adapter for persistence

public class PersistentStreamProvider : ILifecycleParticipant<ILifecycleObservable>, IControllable, IStreamSubscriptionManagerRetriever, IInternalStreamProvider, IStreamProvider

Constructors

• PersistentStreamProvider(string, StreamPubSubOptions, StreamLifecycleOptions, IProviderRuntime, DeepCopier, ILogger<PersistentStreamProvider>) Initializes a new instance of the PersistentStreamProvider class.

Properties

• IsRewindable Gets a value indicating whether this is a rewindable provider - supports creating rewindable streams (streams that allow subscribing from previous point in time).
• Name Gets the name of the stream provider.

Methods

• Create(IServiceProvider, string) Creates a persistent stream provider.
• ExecuteCommand(int, object?) A function to execute a control command.
• GetStream(StreamId) Gets the stream with the specified identity.
• GetStreamSubscriptionManager Gets the stream subscription manager.
• Participate(ILifecycleObservable) Adds the provided observer as a participant in the lifecycle.
• ParticipateIn(IServiceProvider, string) Gets the named persistent stream provider as a participant in the specified lifecycle.