HashRingBasedPartitionedStreamQueueMapper

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Queue mapper that tracks which partition was mapped to which QueueId

public sealed class HashRingBasedPartitionedStreamQueueMapper : HashRingBasedStreamQueueMapper

Constructors

• HashRingBasedPartitionedStreamQueueMapper(IReadOnlyList<string>, string) Queue mapper that tracks which partition was mapped to which QueueId

Methods

• QueueToPartition(QueueId) Gets the partition by QueueId