Поделиться через


SiloRecoverableStreamConfigurator Класс

Определение

public class SiloRecoverableStreamConfigurator : Orleans.Streams.SiloPersistentStreamConfigurator, Orleans.Streams.ISiloRecoverableStreamConfigurator
type SiloRecoverableStreamConfigurator = class
    inherit SiloPersistentStreamConfigurator
    interface ISiloRecoverableStreamConfigurator
    interface ISiloPersistentStreamConfigurator
Public Class SiloRecoverableStreamConfigurator
Inherits SiloPersistentStreamConfigurator
Implements ISiloRecoverableStreamConfigurator
Наследование
SiloRecoverableStreamConfigurator
Производный
Реализации

Конструкторы

SiloRecoverableStreamConfigurator(String, Action<Action<IServiceCollection>>, Func<IServiceProvider,String,IQueueAdapterFactory>)

Поля

configureDelegate (Унаследовано от SiloPersistentStreamConfigurator)
name (Унаследовано от SiloPersistentStreamConfigurator)

Методы

Configure<TOptions>(Action<OptionsBuilder<TOptions>>) (Унаследовано от SiloPersistentStreamConfigurator)
ConfigureComponent<TComponent>(Func<IServiceProvider,String,TComponent>) (Унаследовано от SiloPersistentStreamConfigurator)
ConfigureComponent<TOptions,TComponent>(Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>) (Унаследовано от SiloPersistentStreamConfigurator)
TryConfigureDefaults() (Унаследовано от SiloPersistentStreamConfigurator)

Методы расширения

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

Подсистема балансировки очередей потоков, использующая сведения о развертывании Azure для балансировки нагрузки. Требуется подсистема, работающая в Azure. Этот балансировщик поддерживает балансировку очередей в сценарии автоматического масштабирования кластера, непредвиденном сценарии сбоя сервера и попытке поддерживать идеальное распределение.

UseClusterConfigDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)
UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Подсистема балансировки очередей потоков, использующая сведения о развертывании Azure и состояния хранилища из oracle членства для балансировки нагрузки.
Требуется подсистема, работающая в Azure. В этом Балансировщике используются как сведения о полном наборе силосов, как сообщает код роли Azure, так и сведения от оракула членства о текущих активных (живых) силосах и очередях перебалансирований из неактивных силосов.

UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Подсистема балансировки очередей потоков, использующая сведения о развертывании Azure для балансировки нагрузки. Требуется подсистема, работающая в Azure. Этот Балансировщик использует как сведения о полном наборе силосов, как сообщает код роли Azure, но не использует информацию из oracle членства о текущих живых силосах. То есть она не перерасбалансирует очереди на основе динамических изменений в членстве в кластере.

UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
ConfigureLifecycle(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamLifecycleOptions>>)
ConfigurePartitionBalancing(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>)
ConfigurePartitionBalancing<TOptions>(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>, Action<OptionsBuilder<TOptions>>)
ConfigurePullingAgent(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamPullingAgentOptions>>)
ConfigureStreamPubSub(ISiloPersistentStreamConfigurator, StreamPubSubType)
ConfigureCacheEviction(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamCacheEvictionOptions>>)
ConfigureStatistics(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamStatisticOptions>>)

Применяется к