QueueBalancerBase

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. QueueBalancerBase

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Base class for StreamQueueBalancer

public abstract class QueueBalancerBase : IStreamQueueBalancer

Constructors

• QueueBalancerBase(IServiceProvider, ILogger) Initializes a new instance of the QueueBalancerBase class.

Properties

• Cancellation Gets the cancellation token which is signaled when this balancer shuts down.
• Logger Gets the logger.
• SiloAddress Gets the address of the local silo.

Methods

• GetMyQueues Retrieves the latest queue distribution for this balancer.
• Initialize(IStreamQueueMapper) Initializes this instance.
• NotifyListeners Notifies subscribers that the queue distribution has changed.
• OnClusterMembershipChange(HashSet<SiloAddress>) Handles a change to the set of active silos.
• Shutdown Shutdown the queue balancer.
• SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener) Subscribes to receive queue distribution change notifications
• UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener) Unsubscribes from receiving queue distribution notifications.