通过

PersistentStreamProvider<TAdapterFactory> 类

  • 参考

定义

命名空间:
Orleans.Providers.Streams.Common
程序集:
Orleans.dll
包:
Microsoft.Orleans.Core v1.5.10

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

public class PersistentStreamProvider<TAdapterFactory> : Orleans.Providers.IControllable, Orleans.Streams.Core.IStreamSubscriptionManagerRetriever where TAdapterFactory : IQueueAdapterFactory, new()
type PersistentStreamProvider<'AdapterFactory (requires 'AdapterFactory :> IQueueAdapterFactory and 'AdapterFactory : (new : unit -> 'AdapterFactory))> = class
    interface IStreamProviderImpl
    interface IStreamProvider
    interface IProvider
    interface IControllable
    interface IStreamSubscriptionManagerRetriever
Public Class PersistentStreamProvider(Of TAdapterFactory)
Implements IControllable, IStreamSubscriptionManagerRetriever

类型参数

TAdapterFactory
继承
Object
PersistentStreamProvider<TAdapterFactory>
派生
实现
IControllable IProvider IStreamSubscriptionManagerRetriever IStreamProvider IStreamProviderImpl

构造函数

PersistentStreamProvider<TAdapterFactory>()

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

属性

IsRewindable

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

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

方法

Close()

使用适配器进行持久性的持久性流提供程序
ExecuteCommand(Int32, Object)

使用适配器进行持久性的持久性流提供程序
GetStream<T>(Guid, String)

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

使用适配器进行持久性的持久性流提供程序
Init(String, IProviderRuntime, IProviderConfiguration)

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

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

扩展方法

TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)

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

适用于