Freigeben über


SiloEventHubStreamConfigurator Klasse

Definition

public class SiloEventHubStreamConfigurator : Orleans.Streams.SiloRecoverableStreamConfigurator
type SiloEventHubStreamConfigurator = class
    inherit SiloRecoverableStreamConfigurator
Public Class SiloEventHubStreamConfigurator
Inherits SiloRecoverableStreamConfigurator
Vererbung

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

Gilt für: