HashRingBasedStreamQueueMapper 类

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

因此IStreamQueueMapper，IConsistentRingStreamQueueMapper它通过将队列映射到由 silo 组成的哈希环来平衡队列。

public class HashRingBasedStreamQueueMapper : Orleans.Streams.IConsistentRingStreamQueueMapper

type HashRingBasedStreamQueueMapper = class
    interface IConsistentRingStreamQueueMapper
    interface IStreamQueueMapper

Public Class HashRingBasedStreamQueueMapper
Implements IConsistentRingStreamQueueMapper

继承

Object

HashRingBasedStreamQueueMapper

派生

Orleans.ServiceBus.Providers.EventHubQueueMapper

Orleans.Streaming.AzureStorage.Providers.Streams.AzureQueue.AzureStreamQueueMapper

Orleans.Streams.HashRingBasedPartitionedStreamQueueMapper

实现

IConsistentRingStreamQueueMapper IStreamQueueMapper

构造函数

HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, String)

初始化 HashRingBasedStreamQueueMapper 类的新实例。

方法

GetAllQueues()	获取所有队列。
GetQueueForStream(StreamId)	获取指定流的队列。
GetQueuesForRange(IRingRange)	获取映射到指定范围的队列。
ToString()	因此IStreamQueueMapper，IConsistentRingStreamQueueMapper它通过将队列映射到由 silo 组成的哈希环来平衡队列。