LeaseBasedQueueBalancer Class
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
LeaseBasedQueueBalancer. This balancer supports queue balancing in cluster auto-scale scenarios, unexpected server failure scenarios, and tries to support ideal distribution as much as possible.
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
- Inheritance
- Implements
Remarks
Initializes a new instance of the LeaseBasedQueueBalancer class.
Constructors
LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, ILeaseProvider, IServiceProvider, ILoggerFactory, TimeProvider) |
LeaseBasedQueueBalancer. This balancer supports queue balancing in cluster auto-scale scenarios, unexpected server failure scenarios, and tries to support ideal distribution as much as possible. |
LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, ILeaseProvider, ITimerRegistry, IServiceProvider, ILoggerFactory) |
Initializes a new instance of the LeaseBasedQueueBalancer class. |
LeaseBasedQueueBalancer(String, LeaseBasedQueueBalancerOptions, IServiceProvider, ISiloStatusOracle, IDeploymentConfiguration, ILoggerFactory) |
Constructor |
Fields
LeaseCategory |
Lease category for LeaseBasedQueueBalancer |
queueBalanceListeners |
A collection for its IStreamQueueBalancerListener (Inherited from QueueBalancerBase) |
Properties
Cancellation | (Inherited from QueueBalancerBase) |
Logger | (Inherited from QueueBalancerBase) |
SiloAddress | (Inherited from QueueBalancerBase) |
Methods
Create(IServiceProvider, String, IDeploymentConfiguration) | |
Create(IServiceProvider, String) |
Creates a new LeaseBasedQueueBalancer instance. |
Dispose() | Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. |
GetMyQueues() |
Retrieves the latest queue distribution for this balancer. |
Initialize(IStreamQueueMapper) |
Initializes this instance. |
NotifyListeners() | (Inherited from QueueBalancerBase) |
OnClusterMembershipChange(HashSet<SiloAddress>) | System.Object.OnClusterMembershipChange(System.Collections.Generic.HashSet{Orleans.Runtime.SiloAddress}) |
OnClusterMembershipChange(HashSet<SiloAddress>) | (Inherited from QueueBalancerBase) |
Shutdown() |
Shutdown the queue balancer. |
Shutdown() | (Inherited from QueueBalancerBase) |
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener) |
Subscribes to receive queue distribution change notifications (Inherited from QueueBalancerBase) |
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener) |
Unsubscribes from receiving queue distribution notifications. (Inherited from QueueBalancerBase) |