LeaseBasedQueueBalancer

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

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 : QueueBalancerBase, IStreamQueueBalancer

Remarks

Initializes a new instance of the LeaseBasedQueueBalancer class.

Constructors

• LeaseBasedQueueBalancer(string, LeaseBasedQueueBalancerOptions, ILeaseProvider, IServiceProvider, ILoggerFactory, TimeProvider) 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.

Methods

• Create(IServiceProvider, string) Creates a new LeaseBasedQueueBalancer instance.
• GetMyQueues Retrieves the latest queue distribution for this balancer.
• Initialize(IStreamQueueMapper) Initializes this instance.
• Shutdown Shutdown the queue balancer.