Edit

Share via

HashRingBasedPartitionedStreamQueueMapper Constructor

  • Reference

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.Streaming.dll
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Package:
Microsoft.Orleans.Streaming v8.2.0

Queue mapper that tracks which partition was mapped to which QueueId

public HashRingBasedPartitionedStreamQueueMapper (System.Collections.Generic.IReadOnlyList<string> partitionIds, string queueNamePrefix);
new Orleans.Streams.HashRingBasedPartitionedStreamQueueMapper : System.Collections.Generic.IReadOnlyList<string> * string -> Orleans.Streams.HashRingBasedPartitionedStreamQueueMapper
Public Sub New (partitionIds As IReadOnlyList(Of String), queueNamePrefix As String)

Parameters

partitionIds
IReadOnlyList<String>

List of partitions

queueNamePrefix
String

Prefix for QueueIds. Must be unique per stream provider

Applies to