LeaseBasedQueueBalancer Methods

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.

Create(IServiceProvider, string)

static

View source

public static IStreamQueueBalancer Create(IServiceProvider services, string name)

Creates a new LeaseBasedQueueBalancer instance.

Parameters

servicesIServiceProvider: The services.
namestring: The name.

Returns

The new LeaseBasedQueueBalancer instance.

GetMyQueues

override

View source

public override IEnumerable<QueueId> GetMyQueues()

Retrieves the latest queue distribution for this balancer.

Returns

Queue allocated to this balancer.

Initialize(IStreamQueueMapper)

override

View source

public override Task Initialize(IStreamQueueMapper queueMapper)

Initializes this instance.

Parameters

queueMapperIStreamQueueMapper: The queue mapper.

Returns

A System.Threading.Tasks.Task representing the operation.

Shutdown

override

View source

public override Task Shutdown()

Shutdown the queue balancer.

Returns

A System.Threading.Tasks.Task representing the operation.