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)

Properties

• Cancellation
• Logger
• SiloAddress

Methods

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