HashRingBasedPartitionedStreamQueueMapper Class

Definition

Queue mapper that tracks which partition was mapped to which QueueId

public sealed class HashRingBasedPartitionedStreamQueueMapper : Orleans.Streams.HashRingBasedStreamQueueMapper
type HashRingBasedPartitionedStreamQueueMapper = class
    inherit HashRingBasedStreamQueueMapper
Public NotInheritable Class HashRingBasedPartitionedStreamQueueMapper
Inherits HashRingBasedStreamQueueMapper
Inheritance
HashRingBasedPartitionedStreamQueueMapper

Constructors

HashRingBasedPartitionedStreamQueueMapper(IReadOnlyList<String>, String)

Queue mapper that tracks which partition was mapped to which QueueId

Methods

GetAllQueues()

Gets all queues.

(Inherited from HashRingBasedStreamQueueMapper)
GetQueueForStream(Guid, String) (Inherited from HashRingBasedStreamQueueMapper)
GetQueueForStream(StreamId)

Gets the queue for the specified stream.

(Inherited from HashRingBasedStreamQueueMapper)
GetQueuesForRange(IRingRange)

Gets the queues which map to the specified range.

(Inherited from HashRingBasedStreamQueueMapper)
QueueToPartition(QueueId)

Gets the partition by QueueId

ToString() (Inherited from HashRingBasedStreamQueueMapper)

Applies to