IConsistentRingStreamQueueMapper Methods

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IConsistentRingStreamQueueMapper
5. Methods

Markdown

The stream queue mapper is responsible for mapping ring ranges from the load balancing ring provider to stream queues. Implementation must be thread safe.

GetQueuesForRange(IRingRange)

abstract

public abstract IEnumerable<QueueId> GetQueuesForRange(IRingRange range)

Gets the queues which map to the specified range.

Parameters

rangeIRingRange

The range.

Returns

The queues which map to the specified range.