Freigeben über


DeploymentBasedQueueBalancer Klasse

Definition

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Runtime.ISiloStatusListener, Orleans.Streams.IStreamQueueBalancer
public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Streams.IStreamQueueBalancer
public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase
type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface ISiloStatusListener
    interface IStreamQueueBalancer
type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements ISiloStatusListener, IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Vererbung
DeploymentBasedQueueBalancer
Implementiert

Konstruktoren

DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions, IServiceProvider, ILogger<DeploymentBasedQueueBalancer>)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

Felder

queueBalanceListeners

Eine Auflistung für den IStreamQueueBalancerListener

(Geerbt von QueueBalancerBase)

Eigenschaften

Cancellation

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)
Logger

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)
SiloAddress

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)

Methoden

Create(IServiceProvider, String, IDeploymentConfiguration)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

GetMyQueues()

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

Initialize(IStreamQueueMapper)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

NotifyListeners()

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)
Shutdown()

DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet ein Silostatus oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.

(Geerbt von QueueBalancerBase)
SiloStatusChangeNotification(SiloAddress, SiloStatus)

Wird aufgerufen, wenn sich der Status eines Silos im Cluster ändert.

  • Listener benachrichtigen
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Abonnements zum Empfangen von Änderungsbenachrichtigungen für die Warteschlangenverteilung

(Geerbt von QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Wird vom Empfang von Warteschlangenverteilungsbenachrichtigungen abgemeldet.

(Geerbt von QueueBalancerBase)

Gilt für: