Edit

HashRingBasedStreamQueueMapper Class

  • Reference

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.dll
Assembly:
Orleans.Core.dll
Assembly:
Orleans.Streaming.dll
Package:
Microsoft.Orleans.Core v1.5.10
Package:
Microsoft.Orleans.Core v2.4.5
Package:
Microsoft.Orleans.Core v3.6.5
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Source:
HashRingBasedStreamQueueMapper.cs

A IConsistentRingStreamQueueMapper and hence IStreamQueueMapper which balances queues by mapping them onto a hash ring consisting of silos.

public class HashRingBasedStreamQueueMapper : Orleans.Streams.IConsistentRingStreamQueueMapper
type HashRingBasedStreamQueueMapper = class
    interface IConsistentRingStreamQueueMapper
    interface IStreamQueueMapper
Public Class HashRingBasedStreamQueueMapper
Implements IConsistentRingStreamQueueMapper
Inheritance
Object
HashRingBasedStreamQueueMapper
Derived
Implements
IConsistentRingStreamQueueMapper IStreamQueueMapper

Constructors

HashRingBasedStreamQueueMapper(HashRingStreamQueueMapperOptions, String)

Initializes a new instance of the HashRingBasedStreamQueueMapper class.
HashRingBasedStreamQueueMapper(Int32, String)

Methods

GetAllQueues()

Gets all queues.
GetQueueForStream(Guid, String)
GetQueueForStream(StreamId)

Gets the queue for the specified stream.
GetQueuesForRange(IRingRange)

Gets the queues which map to the specified range.
ToString()

Returns a string that represents the current object.

Applies to