Note

Access to this page requires authorization. You can try signing in or .

Access to this page requires authorization. You can try .

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
PersistentStreamProvider
Implements

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