SiloBuilderStreamingExtensions 类

定义

用于连接 silo 上的流式处理的扩展方法。

public static class SiloBuilderStreamingExtensions
type SiloBuilderStreamingExtensions = class
Public Module SiloBuilderStreamingExtensions
继承
SiloBuilderStreamingExtensions

方法

AddPersistentStreams(ISiloBuilder, String, Func<IServiceProvider,String,IQueueAdapterFactory>, Action<ISiloPersistentStreamConfigurator>)

将 silo 配置为使用永久性流。

AddStreamFilter<T>(IClientBuilder, String)

添加流筛选器。

AddStreamFilter<T>(ISiloBuilder, String)

添加流筛选器。

AddStreaming(ISiloBuilder)

向此应用程序添加对流式处理的支持。

适用于