Edit

Share via


QueueBalancerBase Class

Definition

Base class for StreamQueueBalancer

public abstract class QueueBalancerBase : Orleans.Streams.IStreamQueueBalancer
type QueueBalancerBase = class
    interface IStreamQueueBalancer
Public MustInherit Class QueueBalancerBase
Implements IStreamQueueBalancer
Inheritance
QueueBalancerBase
Derived
Implements

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