SiloPersistentStreamConfiguratorExtensions Methods

Extensions for ISiloPersistentStreamConfigurator.

ConfigureBackoffProvider(ISiloPersistentStreamConfigurator, Func<IServiceProvider, string, IMessageDeliveryBackoffProvider>)

staticextension

public static void ConfigureBackoffProvider(this ISiloPersistentStreamConfigurator configurator, Func<IServiceProvider, string, IMessageDeliveryBackoffProvider> factory)

Configures the pulling agents' message delivery backoff provider.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
factoryFunc<IServiceProvider, string, IMessageDeliveryBackoffProvider>: The message delivery backoff factory.

ConfigureBackoffProvider(ISiloPersistentStreamConfigurator, Func<IServiceProvider, string, IQueueReaderBackoffProvider>)

staticextension

View source

public static void ConfigureBackoffProvider(this ISiloPersistentStreamConfigurator configurator, Func<IServiceProvider, string, IQueueReaderBackoffProvider> factory)

Configures the pulling agents' queue reader backoff provider.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
factoryFunc<IServiceProvider, string, IQueueReaderBackoffProvider>: The queue reader backoff factory.

ConfigureLifecycle(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamLifecycleOptions>>)

staticextension

View source

public static void ConfigureLifecycle(this ISiloPersistentStreamConfigurator configurator, Action<OptionsBuilder<StreamLifecycleOptions>> configureOptions)

Configures the lifecycle.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
configureOptionsAction<OptionsBuilder<StreamLifecycleOptions>>: The configuration delegate.

ConfigurePartitionBalancing(ISiloPersistentStreamConfigurator, Func<IServiceProvider, string, IStreamQueueBalancer>)

staticextension

View source

public static void ConfigurePartitionBalancing(this ISiloPersistentStreamConfigurator configurator, Func<IServiceProvider, string, IStreamQueueBalancer> factory)

Configures partition balancing.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
factoryFunc<IServiceProvider, string, IStreamQueueBalancer>: The partition balancer factory.

ConfigurePartitionBalancing(ISiloPersistentStreamConfigurator, Func<IServiceProvider, string, IStreamQueueBalancer>, Action<OptionsBuilder<TOptions>>)

staticextension

View source

public static void ConfigurePartitionBalancing<TOptions>(this ISiloPersistentStreamConfigurator configurator, Func<IServiceProvider, string, IStreamQueueBalancer> factory, Action<OptionsBuilder<TOptions>> configureOptions)

Configures partition balancing.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
factoryFunc<IServiceProvider, string, IStreamQueueBalancer>: The partition balancer factory.
configureOptionsAction<OptionsBuilder<TOptions>>: The configuration delegate.

ConfigurePullingAgent(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamPullingAgentOptions>>)

staticextension

View source

public static void ConfigurePullingAgent(this ISiloPersistentStreamConfigurator configurator, Action<OptionsBuilder<StreamPullingAgentOptions>> configureOptions = null)

Configures the pulling agent.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
configureOptionsAction<OptionsBuilder<StreamPullingAgentOptions>>: The configuration delegate.