DeploymentBasedQueueBalancer 类

定义

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

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 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions)

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

字段

queueBalanceListeners

其 IStreamQueueBalancerListener 的集合

(继承自 QueueBalancerBase)

属性

Cancellation

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)
Logger

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)
SiloAddress

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)

方法

Create(IServiceProvider, String, IDeploymentConfiguration)

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

GetMyQueues()

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

Initialize(IStreamQueueMapper)

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

NotifyListeners()

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

OnClusterMembershipChange(HashSet<SiloAddress>)

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)
Shutdown()

DeploymentBasedQueueBalancer 是一个流队列均衡器,它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期有多少个 silo,并使用 silo 状态 Oracle 来确定哪些接收器可用。 利用此信息,它会尝试使用最适合的资源均衡算法来平衡队列。

(继承自 QueueBalancerBase)
SiloStatusChangeNotification(SiloAddress, SiloStatus)

当群集中 silo 的状态更改时调用。

  • 通知侦听器
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

订阅以接收队列分布更改通知

(继承自 QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

取消订阅接收队列分发通知。

(继承自 QueueBalancerBase)

适用于