Edit

Share via


HashRingBasedStreamQueueMapper Class

Definition

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

public class HashRingBasedStreamQueueMapper : Orleans.Streams.IConsistentRingStreamQueueMapper
type HashRingBasedStreamQueueMapper = class
    interface IConsistentRingStreamQueueMapper
    interface IStreamQueueMapper
Public Class HashRingBasedStreamQueueMapper
Implements IConsistentRingStreamQueueMapper
Inheritance
HashRingBasedStreamQueueMapper
Derived
Implements

Constructors

HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, String)

Initializes a new instance of the HashRingBasedStreamQueueMapper class.

HashRingBasedStreamQueueMapper(Int32, String)

Methods

GetAllQueues()

Gets all queues.

GetQueueForStream(Guid, String)
GetQueueForStream(StreamId)

Gets the queue for the specified stream.

GetQueuesForRange(IRingRange)

Gets the queues which map to the specified range.

ToString()

Returns a string that represents the current object.

Applies to