LeaseBasedQueueBalancer Class

Reference

Definition

Namespace:: Orleans.Streams

Assembly:: Orleans.Runtime.dll

Assembly:: Orleans.Streaming.dll

Package:: Microsoft.Orleans.OrleansRuntime v2.4.5

Package:: Microsoft.Orleans.OrleansRuntime v3.6.5

Package:: Microsoft.Orleans.Streaming v7.2.5

Package:: Microsoft.Orleans.Streaming v8.0.0

Package:: Microsoft.Orleans.Streaming v8.1.0

Source:: LeaseBasedQueueBalancer.cs

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: Object

QueueBalancerBase
LeaseBasedQueueBalancer

Implements: IStreamQueueBalancer IDisposable

Constructors

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)	Creates a new LeaseBasedQueueBalancer instance.
Create(IServiceProvider, String, IDeploymentConfiguration)
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)

Applies to