PersistentStreamProvider Class

Reference

Definition

Namespace:: Orleans.Providers.Streams.Common

Assembly:: Orleans.Core.dll

Assembly:: Orleans.Streaming.dll

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

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

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

Properties

IsRewindable
Name

Methods

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

Extension Methods

TryGetStreamSubscriptionManager(IStreamProvider, IStreamSubscriptionManager)	Returns the IStreamSubscriptionManager for the provided stream provider.
TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)
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)	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.

Applies to

Share via