HashRingBasedStreamQueueMapper

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

A IConsistentRingStreamQueueMapper and hence IStreamQueueMapper which balances queues by mapping them onto a hash ring consisting of silos.

public class HashRingBasedStreamQueueMapper : IConsistentRingStreamQueueMapper, IStreamQueueMapper

Constructors

• HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, string) Initializes a new instance of the HashRingBasedStreamQueueMapper class.

Methods

• GetAllQueues Gets all queues.
• GetQueueForStream(StreamId) Gets the queue for the specified stream.
• GetQueuesForRange(IRingRange) Gets the queues which map to the specified range.
• ToStringReturns a string that represents the current object.