PersistentStreamProvider 类

定义

命名空间:

Orleans.Providers.Streams.Common

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

使用适配器进行持久性的持久性流提供程序

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

继承

Object

PersistentStreamProvider

实现

ILifecycleParticipant<ILifecycleObservable> IControllable IStreamSubscriptionManagerRetriever IStreamProvider

构造函数

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

使用适配器进行持久性的持久性流提供程序

属性

IsRewindable	使用适配器进行持久性的持久性流提供程序
Name	使用适配器进行持久性的持久性流提供程序

方法

Create(IServiceProvider, String)	使用适配器进行持久性的持久性流提供程序
ExecuteCommand(Int32, Object)	使用适配器进行持久性的持久性流提供程序
GetStream<T>(StreamId)	使用适配器进行持久性的持久性流提供程序
GetStreamSubscriptionManager()	使用适配器进行持久性的持久性流提供程序
Participate(ILifecycleObservable)	使用适配器进行持久性的持久性流提供程序
ParticipateIn<TLifecycle>(IServiceProvider, String)	使用适配器进行持久性的持久性流提供程序

扩展方法

TryGetStreamSubscriptionManager(IStreamProvider, IStreamSubscriptionManager)	返回 IStreamSubscriptionManager 提供的流提供程序的 。
GetStream<T>(IStreamProvider, Guid)	获取具有指定标识和命名空间的流。
GetStream<T>(IStreamProvider, Int64)	获取具有指定标识和命名空间的流。
GetStream<T>(IStreamProvider, String)	获取具有指定标识和命名空间的流。
GetStream<T>(IStreamProvider, String, Guid)	获取具有指定标识和命名空间的流。
GetStream<T>(IStreamProvider, String, Int64)	获取具有指定标识和命名空间的流。
GetStream<T>(IStreamProvider, String, String)	获取具有指定标识和命名空间的流。