SiloAzureQueueStreamConfigurator<TDataAdapter> Klasse

Definition

Namespace:

Orleans.Streaming

Assembly:

Orleans.Streaming.AzureStorage.dll

Paket:

Microsoft.Orleans.Streaming.AzureStorage v2.4.5

public class SiloAzureQueueStreamConfigurator<TDataAdapter> : Orleans.Streams.SiloPersistentStreamConfigurator where TDataAdapter : IAzureQueueDataAdapter

type SiloAzureQueueStreamConfigurator<'DataAdapter (requires 'DataAdapter :> IAzureQueueDataAdapter)> = class
    inherit SiloPersistentStreamConfigurator

Public Class SiloAzureQueueStreamConfigurator(Of TDataAdapter)
Inherits SiloPersistentStreamConfigurator

Typparameter

TDataAdapter

Vererbung

Object

SiloPersistentStreamConfigurator

SiloAzureQueueStreamConfigurator<TDataAdapter>

Konstruktoren

SiloAzureQueueStreamConfigurator<TDataAdapter>(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)
ConfigureAzureQueue(Action<OptionsBuilder<AzureQueueOptions>>)
ConfigureCache(Int32)
ConfigureComponent<TComponent>(Func<IServiceProvider,String,TComponent>)	(Geerbt von SiloPersistentStreamConfigurator)
ConfigureComponent<TOptions,TComponent>(Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)	(Geerbt von SiloPersistentStreamConfigurator)
TryConfigureDefaults()	(Geerbt von SiloPersistentStreamConfigurator)

Erweiterungsmethoden

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)