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

HashRingBasedStreamQueueMapper Класс

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.dll
Сборка:
Orleans.Core.dll
Сборка:
Orleans.Streaming.dll
Пакет:
Microsoft.Orleans.Core v1.5.10
Пакет:
Microsoft.Orleans.Core v2.4.5
Пакет:
Microsoft.Orleans.Core v3.6.5
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0
Исходный код:
HashRingBasedStreamQueueMapper.cs

И IConsistentRingStreamQueueMapper , следовательно, IStreamQueueMapper который балансирует очереди, сопоставляя их с хеш-кольцом, состоящим из разрозненности.

public class HashRingBasedStreamQueueMapper : Orleans.Streams.IConsistentRingStreamQueueMapper
type HashRingBasedStreamQueueMapper = class
    interface IConsistentRingStreamQueueMapper
    interface IStreamQueueMapper
Public Class HashRingBasedStreamQueueMapper
Implements IConsistentRingStreamQueueMapper
Наследование
Object
HashRingBasedStreamQueueMapper
Производный
Реализации
IConsistentRingStreamQueueMapper IStreamQueueMapper

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

HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, String)

Инициализирует новый экземпляр класса HashRingBasedStreamQueueMapper.
HashRingBasedStreamQueueMapper(Int32, String)

И IConsistentRingStreamQueueMapper , следовательно, IStreamQueueMapper который балансирует очереди, сопоставляя их с хеш-кольцом, состоящим из разрозненности.

Методы

GetAllQueues()

Возвращает все очереди.
GetQueueForStream(Guid, String)

И IConsistentRingStreamQueueMapper , следовательно, IStreamQueueMapper который балансирует очереди, сопоставляя их с хеш-кольцом, состоящим из разрозненности.
GetQueueForStream(StreamId)

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

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

И IConsistentRingStreamQueueMapper , следовательно, IStreamQueueMapper который балансирует очереди, сопоставляя их с хеш-кольцом, состоящим из разрозненности.

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