Skip to content
Orleans logoMicrosoft Orleans

HashRingBasedStreamQueueMapper Methods

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

GetQueueForStream(StreamId)

View source
public QueueId GetQueueForStream(StreamId streamId)
Gets the queue for the specified stream.

Parameters

streamIdStreamId
The stream identifier.

Returns

The queue responsible for the specified stream.

GetQueuesForRange(IRingRange)

View source
public 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.

ToString

override
View source
public override string ToString()
Returns a string that represents the current object.

Returns

A string that represents the current object.