QueueBalancerBase 类

定义

StreamQueueBalancer 的基类

public abstract class QueueBalancerBase : Orleans.Streams.IStreamQueueBalancer
type QueueBalancerBase = class
    interface IStreamQueueBalancer
Public MustInherit Class QueueBalancerBase
Implements IStreamQueueBalancer
继承
QueueBalancerBase
派生
实现

构造函数

QueueBalancerBase()

StreamQueueBalancer 的基类

QueueBalancerBase(IServiceProvider, ILogger)

StreamQueueBalancer 的基类

字段

queueBalanceListeners

其 IStreamQueueBalancerListener 的集合

属性

Cancellation

StreamQueueBalancer 的基类

Logger

StreamQueueBalancer 的基类

SiloAddress

StreamQueueBalancer 的基类

方法

GetMyQueues()

检索此均衡器的最新队列分布。

Initialize(IStreamQueueMapper)

初始化此实例。

NotifyListeners()

StreamQueueBalancer 的基类

OnClusterMembershipChange(HashSet<SiloAddress>)

StreamQueueBalancer 的基类

Shutdown()

StreamQueueBalancer 的基类

SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

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

UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

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

适用于