Bewerken

Delen 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

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
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(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