Bewerken

Delen via

AzureStreamQueueMapper Class

  • Reference

Definition

Namespace:
Orleans.Streaming.AzureStorage.Providers.Streams.AzureQueue
Assembly:
Orleans.Streaming.AzureStorage.dll
Package:
Microsoft.Orleans.Streaming.AzureStorage v2.4.5
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)

Applies to