QueueBalancerBase 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:: QueueBalancerBase.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.

Base class for StreamQueueBalancer

public abstract class QueueBalancerBase : Orleans.Streams.IStreamQueueBalancer

type QueueBalancerBase = class
    interface IStreamQueueBalancer

Public MustInherit Class QueueBalancerBase
Implements IStreamQueueBalancer

Inheritance: Object
QueueBalancerBase

Derived: Orleans.Streams.DeploymentBasedQueueBalancer

Orleans.Streams.LeaseBasedQueueBalancer

Implements: IStreamQueueBalancer

Constructors

QueueBalancerBase()
QueueBalancerBase(IServiceProvider, ILogger)

Fields

queueBalanceListeners

A collection for its IStreamQueueBalancerListener

Properties

Cancellation
Logger
SiloAddress

Methods

GetMyQueues()	Retrieves the latest queue distribution for this balancer.
Initialize(IStreamQueueMapper)	Initializes this instance.
NotifyListeners()
OnClusterMembershipChange(HashSet<SiloAddress>)
Shutdown()
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)	Subscribes to receive queue distribution change notifications
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)	Unsubscribes from receiving queue distribution notifications.

Applies to