Redigera

Dela via


AzureStreamQueueMapper Class

Definition

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
AzureStreamQueueMapper
Implements

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)

Applies to