LeaseBasedQueueBalancer 類別

定義

命名空間:

Orleans.Streams

組件:

Orleans.Streaming.dll

套件:

Microsoft.Orleans.Streaming v8.1.0

LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。

public class LeaseBasedQueueBalancer : Orleans.Streams.QueueBalancerBase

type LeaseBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer

Public Class LeaseBasedQueueBalancer
Inherits QueueBalancerBase

繼承

Object

QueueBalancerBase

LeaseBasedQueueBalancer

實作

IStreamQueueBalancer

建構函式

LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, ILeaseProvider, ITimerRegistry, IServiceProvider, ILoggerFactory)

初始化 LeaseBasedQueueBalancer 類別的新執行個體。

欄位

queueBalanceListeners

其 IStreamQueueBalancerListener 的集合 (繼承來源 QueueBalancerBase)

屬性

Cancellation	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。 (繼承來源 QueueBalancerBase)
Logger	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。 (繼承來源 QueueBalancerBase)
SiloAddress	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。 (繼承來源 QueueBalancerBase)

方法

Create(IServiceProvider, String)	建立新的 LeaseBasedQueueBalancer 執行個體。
GetMyQueues()	擷取這個平衡器的最新佇列散發。
Initialize(IStreamQueueMapper)	初始化此執行個體。
NotifyListeners()	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。 (繼承來源 QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例、非預期的伺服器失敗案例中的佇列平衡，並嘗試盡可能支援理想的散發。
Shutdown()	關閉佇列平衡器。
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)	訂閱接收佇列發佈變更通知 (繼承來源 QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)	取消訂閱接收佇列散發通知。 (繼承來源 QueueBalancerBase)