Поделиться через

HashRingBasedPartitionedStreamQueueMapper Класс

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.Streaming.dll
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0
Пакет:
Microsoft.Orleans.Streaming v8.2.0

Модуль сопоставления очередей, который отслеживает, какая секция была сопоставлена с какой queueId

public sealed class HashRingBasedPartitionedStreamQueueMapper : Orleans.Streams.HashRingBasedStreamQueueMapper
type HashRingBasedPartitionedStreamQueueMapper = class
    inherit HashRingBasedStreamQueueMapper
Public NotInheritable Class HashRingBasedPartitionedStreamQueueMapper
Inherits HashRingBasedStreamQueueMapper
Наследование
Object
HashRingBasedStreamQueueMapper
HashRingBasedPartitionedStreamQueueMapper

Конструкторы

HashRingBasedPartitionedStreamQueueMapper(IReadOnlyList<String>, String)

Модуль сопоставления очередей, который отслеживает, какая секция была сопоставлена с какой queueId

Методы

GetAllQueues()

Возвращает все очереди.

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueueForStream(Guid, String)

Модуль сопоставления очередей, который отслеживает, какая секция была сопоставлена с какой queueId

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueueForStream(StreamId)

Возвращает очередь для указанного потока.

(Унаследовано от HashRingBasedStreamQueueMapper)
GetQueuesForRange(IRingRange)

Возвращает очереди, которые сопоставляются с указанным диапазоном.

(Унаследовано от HashRingBasedStreamQueueMapper)
QueueToPartition(QueueId)

Возвращает секцию по QueueId
ToString()

Модуль сопоставления очередей, который отслеживает, какая секция была сопоставлена с какой queueId

(Унаследовано от HashRingBasedStreamQueueMapper)

Применяется к