SiloEventHubStreamConfigurator Класс

Определение

Пространство имен:

Orleans.Streams

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.OrleansServiceBus v2.4.5

public class SiloEventHubStreamConfigurator : Orleans.Streams.SiloRecoverableStreamConfigurator

type SiloEventHubStreamConfigurator = class
    inherit SiloRecoverableStreamConfigurator

Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator

Наследование

Object

SiloPersistentStreamConfigurator

SiloRecoverableStreamConfigurator

SiloEventHubStreamConfigurator

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

SiloEventHubStreamConfigurator(String, Action<Action<IServiceCollection>>, Action<Action<IApplicationPartManager>>)

Поля

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

Методы

Configure<TOptions>(Action<OptionsBuilder<TOptions>>)	(Унаследовано от SiloPersistentStreamConfigurator)
ConfigureCachePressuring(Action<OptionsBuilder<EventHubStreamCachePressureOptions>>)
ConfigureCheckpointer<TOptions>(Func<IServiceProvider,String,IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)
ConfigureComponent<TComponent>(Func<IServiceProvider,String,TComponent>)	(Унаследовано от SiloPersistentStreamConfigurator)
ConfigureComponent<TOptions,TComponent>(Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)	(Унаследовано от SiloPersistentStreamConfigurator)
ConfigureEventHub(Action<OptionsBuilder<EventHubOptions>>)
ConfigurePartitionReceiver(Action<OptionsBuilder<EventHubReceiverOptions>>)
TryConfigureDefaults()	(Унаследовано от SiloPersistentStreamConfigurator)

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

UseEventHubCheckpointer(SiloEventHubStreamConfigurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>>)
UseAzureDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)	Подсистема балансировки очереди потоковой передачи, использующая сведения о развертывании Azure для балансировки нагрузки. Требуется silo, запущенный в Azure. Этот балансировщик поддерживает балансировку очередей в сценарии автомасштабирования кластера, непредвиденном сценарии сбоя сервера и попытке поддерживать идеальное распределение.
UseClusterConfigDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)
UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)	Подсистема балансировки очереди потоковой передачи, использующая сведения о развертывании Azure и состояния хранилища из oracle членства для балансировки нагрузки. Требуется silo, запущенный в Azure. Этот Балансировщик использует как сведения о полном наборе силосов, как сообщает код роли Azure, так и сведения из ооракуле членства об активном (активном) силосах и очередях перебалансирований из неактивных силосов.
UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)	Подсистема балансировки очереди потоковой передачи, использующая сведения о развертывании Azure для балансировки нагрузки. Требуется silo, запущенный в 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>>)