通过

LeaseBasedQueueBalancer 类

  • 参考

定义

命名空间:
Orleans.Streams
程序集:
Orleans.Runtime.dll
程序集:
Orleans.Streaming.dll
包:
Microsoft.Orleans.OrleansRuntime v2.4.5
包:
Microsoft.Orleans.OrleansRuntime v3.6.5
包:
Microsoft.Orleans.Streaming v7.2.5
包:
Microsoft.Orleans.Streaming v8.0.0
包:
Microsoft.Orleans.Streaming v8.1.0
包:
Microsoft.Orleans.Streaming v8.2.0
Source:
LeaseBasedQueueBalancer.cs

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

public class LeaseBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, IDisposable, Orleans.Streams.IStreamQueueBalancer
public class LeaseBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Streams.IStreamQueueBalancer
public class LeaseBasedQueueBalancer : Orleans.Streams.QueueBalancerBase
type LeaseBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer
    interface IDisposable
type LeaseBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer
Public Class LeaseBasedQueueBalancer
Inherits QueueBalancerBase
Implements IDisposable, IStreamQueueBalancer
Public Class LeaseBasedQueueBalancer
Inherits QueueBalancerBase
Implements IStreamQueueBalancer
Public Class LeaseBasedQueueBalancer
Inherits QueueBalancerBase
继承
Object
QueueBalancerBase
LeaseBasedQueueBalancer
实现
IStreamQueueBalancer IDisposable

注解

初始化 LeaseBasedQueueBalancer 类的新实例。

构造函数

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

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。
LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, ILeaseProvider, ITimerRegistry, IServiceProvider, ILoggerFactory)

初始化 LeaseBasedQueueBalancer 类的新实例。
LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, IServiceProvider, ISiloStatusOracle, IDeploymentConfiguration, ILoggerFactory)

构造 函数

字段

LeaseCategory

LeaseBasedQueueBalancer 的租约类别
queueBalanceListeners

其 IStreamQueueBalancerListener 的集合

(继承自 QueueBalancerBase)

属性

Cancellation

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

(继承自 QueueBalancerBase)
Logger

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

(继承自 QueueBalancerBase)
SiloAddress

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

(继承自 QueueBalancerBase)

方法

Create(IServiceProvider, String, IDeploymentConfiguration)

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。
Create(IServiceProvider, String)

创建新的 LeaseBasedQueueBalancer 实例。
Dispose()

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。
GetMyQueues()

检索此负载均衡器的最新队列分布。
Initialize(IStreamQueueMapper)

初始化此实例。
NotifyListeners()

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

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

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。
OnClusterMembershipChange(HashSet<SiloAddress>)

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

(继承自 QueueBalancerBase)
Shutdown()

关闭队列均衡器。
Shutdown()

LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案中的队列均衡、意外的服务器故障方案，并尝试尽可能多地支持理想的分发。

(继承自 QueueBalancerBase)
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

订阅接收队列分发更改通知

(继承自 QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

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

(继承自 QueueBalancerBase)

适用于