DeploymentBasedQueueBalancer 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
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(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) |