SiloEventHubStreamConfigurator Klasse

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.EventHubs.dll

Paket:

Microsoft.Orleans.OrleansServiceBus v2.4.5

public class SiloEventHubStreamConfigurator : Orleans.Streams.SiloRecoverableStreamConfigurator

type SiloEventHubStreamConfigurator = class
    inherit SiloRecoverableStreamConfigurator

Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator

Vererbung

Object

SiloPersistentStreamConfigurator

SiloRecoverableStreamConfigurator

SiloEventHubStreamConfigurator

Konstruktoren

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

Felder

configureDelegate	(Geerbt von SiloPersistentStreamConfigurator)
name	(Geerbt von SiloPersistentStreamConfigurator)

Methoden

Configure<TOptions>(Action<OptionsBuilder<TOptions>>)	(Geerbt von SiloPersistentStreamConfigurator)
ConfigureCachePressuring(Action<OptionsBuilder<EventHubStreamCachePressureOptions>>)
ConfigureCheckpointer<TOptions>(Func<IServiceProvider,String,IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)
ConfigureComponent<TComponent>(Func<IServiceProvider,String,TComponent>)	(Geerbt von SiloPersistentStreamConfigurator)
ConfigureComponent<TOptions,TComponent>(Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)	(Geerbt von SiloPersistentStreamConfigurator)
ConfigureEventHub(Action<OptionsBuilder<EventHubOptions>>)
ConfigurePartitionReceiver(Action<OptionsBuilder<EventHubReceiverOptions>>)
TryConfigureDefaults()	(Geerbt von SiloPersistentStreamConfigurator)

Erweiterungsmethoden

UseEventHubCheckpointer(SiloEventHubStreamConfigurator, Action<OptionsBuilder<AzureTableStreamCheckpointerOptions>>)
UseAzureDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)	Stream-Warteschlangenausgleich, der Azure-Bereitstellungsinformationen für den Lastenausgleich verwendet. Erfordert siloausführung in Azure. Dieser Balancer unterstützt den Warteschlangenausgleich im Szenario der automatischen Skalierung des Clusters, unerwartetes Serverfehlerszenario und versuchen, die ideale Verteilung zu unterstützen.
UseClusterConfigDeploymentLeaseBasedBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)
UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)
UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)	Stream queue balancer that uses Azure deployment information and silo statuses from Membership oracle for load balancing. Erfordert siloausführung in Azure. Dieser Balancer verwendet sowohl die Informationen über den vollständigen Satz von Silos wie vom Azure-Rollencode gemeldet und die Informationen aus Mitgliedschafts-Oracle über derzeit aktive (alive) Silos und rebalancen Warteschlangen von nicht aktiven Silos.
UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)
UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)	Stream-Warteschlangenausgleich, der Azure-Bereitstellungsinformationen für den Lastenausgleich verwendet. Erfordert siloausführung in Azure. Dieser Balancer verwendet beide Informationen über den vollständigen Satz von Silos, wie vom Azure-Rollencode gemeldet, verwendet jedoch NICHT die Informationen aus Mitgliedschafts oracle über derzeit lebendigen Silos. Dies bedeutet, dass die Warteschlangen nicht basierend auf dynamischen Änderungen in der Clustermitgliedschaft neu ausgeglichen werden.
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>>)