Skip to content
Orleans logoMicrosoft Orleans

SiloBuilderStreamingExtensions Methods

Extension methods for configuring streaming on silos.

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

staticextension
View source
public static ISiloBuilder AddPersistentStreams(this ISiloBuilder builder, string name, Func<IServiceProvider, string, IQueueAdapterFactory> adapterFactory, Action<ISiloPersistentStreamConfigurator> configureStream)
Configures the silo to use persistent streams.

Parameters

builderISiloBuilder
The builder.
namestring
The provider name.
adapterFactoryFunc<IServiceProvider, string, IQueueAdapterFactory>
The provider adapter factory.
configureStreamAction<ISiloPersistentStreamConfigurator>
The stream provider configuration delegate.

Returns

The silo builder.

AddStreamFilter(IClientBuilder, string)

staticextension
View source
public static IClientBuilder AddStreamFilter<T>(this IClientBuilder builder, string name)
Adds a stream filter.

Parameters

builderIClientBuilder
The builder.
namestring
The stream filter name.

Returns

The client builder.

AddStreamFilter(ISiloBuilder, string)

staticextension
View source
public static ISiloBuilder AddStreamFilter<T>(this ISiloBuilder builder, string name)
Adds a stream filter.

Parameters

builderISiloBuilder
The builder.
namestring
The stream filter name.

Returns

The silo builder.

AddStreaming(ISiloBuilder)

staticextension
View source
public static ISiloBuilder AddStreaming(this ISiloBuilder builder)
Add support for streaming to this application.

Parameters

builderISiloBuilder
The builder.

Returns

The silo builder.