AzureStreamQueueMapper Class

Definition

Namespace:

Orleans.Streaming.AzureStorage.Providers.Streams.AzureQueue

Assembly:

Orleans.Streaming.AzureStorage.dll

Package:

Microsoft.Orleans.Streaming.AzureStorage v3.6.5

Source:

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

Inheritance

Object

HashRingBasedStreamQueueMapper

AzureStreamQueueMapper

Implements

IAzureStreamQueueMapper IStreamQueueMapper

Constructors

AzureStreamQueueMapper(List<String>, String)

Queue mapper that tracks which Azure queue 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)
PartitionToAzureQueue(QueueId)	Gets the Azure queue by partition
ToString()	(Inherited from HashRingBasedStreamQueueMapper)