SiloPersistentStreamConfiguratorExtension Methods

Extension methods for ISiloPersistentStreamConfigurator.

UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)

staticextension

public static void UseConsistentRingQueueBalancer(this ISiloPersistentStreamConfigurator configurator)

Configures the stream provider to use the consistent ring queue balancer.

Parameters

configuratorISiloPersistentStreamConfigurator: The confiurator.

UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, TimeSpan?)

staticextension

View source

public static void UseDynamicClusterConfigDeploymentBalancer(this ISiloPersistentStreamConfigurator configurator, TimeSpan? siloMaturityPeriod = null)

Configures the stream provider to use the dynamic cluster configuration deployment balancer.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
siloMaturityPeriodTimeSpan?: The silo maturity period.

UseLeaseBasedQueueBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)

staticextension

View source

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

Configures the stream provider to use the lease based queue balancer.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
configureOptionsAction<OptionsBuilder<LeaseBasedQueueBalancerOptions>>: The configure options.

UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, TimeSpan?)

staticextension

View source

public static void UseStaticClusterConfigDeploymentBalancer(this ISiloPersistentStreamConfigurator configurator, TimeSpan? siloMaturityPeriod = null)

Configures the stream provider to use the static cluster configuration deployment balancer.

Parameters

configuratorISiloPersistentStreamConfigurator: The configuration builder.
siloMaturityPeriodTimeSpan?: The silo maturity period.