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


SiloEventHubStreamConfigurator Класс

Определение

public class SiloEventHubStreamConfigurator : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.IPersistentStreamConfigurator, Orleans.Hosting.ISiloEventHubStreamConfigurator
public class SiloEventHubStreamConfigurator : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.ISiloEventHubStreamConfigurator
type SiloEventHubStreamConfigurator = class
    inherit SiloRecoverableStreamConfigurator
    interface ISiloEventHubStreamConfigurator
    interface IEventHubStreamConfigurator
    interface INamedServiceConfigurator
    interface ISiloRecoverableStreamConfigurator
    interface ISiloPersistentStreamConfigurator
    interface IPersistentStreamConfigurator
Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator
Implements IPersistentStreamConfigurator, ISiloEventHubStreamConfigurator
Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator
Implements ISiloEventHubStreamConfigurator
Наследование
Реализации

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

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

Свойства

ConfigureDelegate

Возвращает делегат, используемый для настройки службы.

(Унаследовано от NamedServiceConfigurator)
Name

Возвращает имя службы.

(Унаследовано от NamedServiceConfigurator)

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

ConfigureEventHub(IEventHubStreamConfigurator, Action<OptionsBuilder<EventHubOptions>>)
UseDataAdapter(IEventHubStreamConfigurator, Func<IServiceProvider,String,IEventHubDataAdapter>)
UseDataAdapter(IEventHubStreamConfigurator, Func<IServiceProvider,String,IEventHubDataAdapter>)
Configure<TOptions>(INamedServiceConfigurator, Action<OptionsBuilder<TOptions>>)

Настраивает параметры именованной службы.

ConfigureComponent<TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>)

Добавляет одиночный компонент в именованную службу.

ConfigureComponent<TOptions,TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)

Добавляет одиночный компонент в именованную службу и настраивает параметры именованной службы.

ConfigureLifecycle<T>(INamedServiceConfigurator)
ConfigureStreamPubSub(IPersistentStreamConfigurator, StreamPubSubType)

Настраивает тип потоковой публикации или подтипа.

UseAzureBlobLeaseProvider(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<AzureBlobLeaseProviderOptions>>)

Настройка silo для использования поставщика аренды BLOB-объектов Azure

ConfigureCachePressuring(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubStreamCachePressureOptions>>)
ConfigureCheckpointer<TOptions>(ISiloEventHubStreamConfigurator, Func<IServiceProvider,String,IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)
ConfigurePartitionReceiver(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<EventHubReceiverOptions>>)
UseAzureTableCheckpointer(ISiloEventHubStreamConfigurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)

Настраивает поставщика потоковой передачи для использования балансировщика очереди согласованного круга.

UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

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

UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Настраивает поставщика потоков для использования подсистемы балансировки конфигурации динамического кластера.

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

Настраивает поставщика потоков для использования балансировщика очередей на основе аренды.

UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

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

UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Настраивает поставщика потоков для использования подсистемы балансировки конфигурации статического кластера.

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

Настраивает поставщик обратной передачи сообщений агентов извлечения.

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

Настраивает поставщик обратного выхода средства чтения очереди агентов извлечения.

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>>)

Настраивает агент извлечения.

ConfigureCacheEviction(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamCacheEvictionOptions>>)

Настраивает параметры вытеснения кэша для надежного поставщика потоков.

ConfigureStatistics(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamStatisticOptions>>)

Настраивает параметры статистики для надежного поставщика потоков.

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