Edit

Share via

HashRingBasedPartitionedStreamQueueMapper Class

  • Reference

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.Streaming.dll
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Package:
Microsoft.Orleans.Streaming v8.2.0
Package:
Microsoft.Orleans.Streaming v9.0.0
Package:
Microsoft.Orleans.Streaming v9.1.2

Queue mapper that tracks which partition was mapped to which QueueId

C# 
public sealed class HashRingBasedPartitionedStreamQueueMapper : Orleans.Streams.HashRingBasedStreamQueueMapper
Inheritance
Object
HashRingBasedStreamQueueMapper
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(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

Product Versions
.NET Orleans 7.0.0, 8.0.0, 8.1.0, 8.2.0, 9.0.0