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


DeploymentBasedQueueBalancer Класс

Определение

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

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
Наследование
DeploymentBasedQueueBalancer
Реализации

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

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

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions)

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

Поля

queueBalanceListeners

Коллекция для IStreamQueueBalancerListener

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

Свойства

Cancellation

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

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

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

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

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

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

Методы

Create(IServiceProvider, String, IDeploymentConfiguration)

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

GetMyQueues()

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

Initialize(IStreamQueueMapper)

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

NotifyListeners()

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

(Унаследовано от QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

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

DeploymentBasedQueueBalancer — это подсистема балансировки очередей потоков, которая использует сведения о развертывании для распределения очередей. DeploymentBasedQueueBalancer использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.

(Унаследовано от QueueBalancerBase)
SiloStatusChangeNotification(SiloAddress, SiloStatus)

Вызывается при изменении состояния силоса в кластере.

  • Уведомлять прослушивателей
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Подписывается на получение уведомлений об изменениях распределения очереди

(Унаследовано от QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Отмена подписки на получение уведомлений о распределении очередей.

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

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