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

AzureStreamQueueMapper Класс

  • Ссылка

Определение

Пространство имен:
Orleans.Streaming.AzureStorage.Providers.Streams.AzureQueue
Сборка:
Orleans.Streaming.AzureStorage.dll
Пакет:
Microsoft.Orleans.Streaming.AzureStorage v2.4.5
Пакет:
Microsoft.Orleans.Streaming.AzureStorage v3.6.5
Исходный код:
AzureStreamQueueMapper.cs
public class AzureStreamQueueMapper : Orleans.Streams.HashRingBasedStreamQueueMapper, Orleans.Streaming.AzureStorage.Providers.Streams.AzureQueue.IAzureStreamQueueMapper
type AzureStreamQueueMapper = class
    inherit HashRingBasedStreamQueueMapper
    interface IAzureStreamQueueMapper
    interface IStreamQueueMapper
Public Class AzureStreamQueueMapper
Inherits HashRingBasedStreamQueueMapper
Implements IAzureStreamQueueMapper
Наследование
Object
HashRingBasedStreamQueueMapper
AzureStreamQueueMapper
Реализации
IAzureStreamQueueMapper IStreamQueueMapper

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

AzureStreamQueueMapper(List<String>, String)

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

Методы

GetAllQueues()

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

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

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

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

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

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

Возвращает очередь Azure по секциям.
ToString() (Унаследовано от HashRingBasedStreamQueueMapper)

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