Skip to content
Orleans logoMicrosoft Orleans

SiloEventHubStreamConfiguratorExtensions Methods

Extension methods for configuring Azure Event Hubs stream providers on an Orleans silo.

ConfigureCachePressuring(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubStreamCachePressureOptions>>)

staticextension
View source
public static void ConfigureCachePressuring(this ISiloEventHubStreamConfigurator configurator, Action<OptionsBuilder<EventHubStreamCachePressureOptions>> configureOptions)
Configures cache pressure monitoring.

Parameters

configuratorISiloEventHubStreamConfigurator
The stream configurator.
configureOptionsAction<OptionsBuilder<EventHubStreamCachePressureOptions>>
The delegate used to configure cache pressure options.

ConfigureCheckpointer(ISiloEventHubStreamConfigurator, Func<IServiceProvider, string, IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)

staticextension
View source
public static void ConfigureCheckpointer<TOptions>(this ISiloEventHubStreamConfigurator configurator, Func<IServiceProvider, string, IStreamQueueCheckpointerFactory> checkpointerFactoryBuilder, Action<OptionsBuilder<TOptions>> configureOptions)
Configures the factory used to create partition checkpointers.

Parameters

configuratorISiloEventHubStreamConfigurator
The stream configurator.
checkpointerFactoryBuilderFunc<IServiceProvider, string, IStreamQueueCheckpointerFactory>
The checkpointer factory builder.
configureOptionsAction<OptionsBuilder<TOptions>>
The delegate used to configure checkpointer options.

ConfigurePartitionReceiver(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubReceiverOptions>>)

staticextension
View source
public static void ConfigurePartitionReceiver(this ISiloEventHubStreamConfigurator configurator, Action<OptionsBuilder<EventHubReceiverOptions>> configureOptions)
Configures Event Hub partition receivers.

Parameters

configuratorISiloEventHubStreamConfigurator
The stream configurator.
configureOptionsAction<OptionsBuilder<EventHubReceiverOptions>>
The delegate used to configure receiver options.

UseAzureTableCheckpointer(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>>)

static
View source
public static void UseAzureTableCheckpointer(ISiloEventHubStreamConfigurator configurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>> configureOptions)
Configures the stream provider to persist checkpoints using Azure Table Storage.

Parameters

configuratorISiloEventHubStreamConfigurator
The stream configurator.
configureOptionsAction<OptionsBuilder<AzureTableStreamCheckpointerOptions>>
The delegate used to configure Azure Table Storage checkpointer options.