Interface PartitionHub.IConsumerInfo

DO NOT INHERIT

Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public interface IConsumerInfo

Properties

| Improve this Doc View Source

ConsumerIds

Sequence of all identifiers of current consumers.

Use this method only if you need to enumerate consumer existing ids. When selecting a specific consumerId by its index, prefer using the dedicated ConsumerByIndex(Int32) method instead, which is optimised for this use case.

Declaration
ImmutableArray<long> ConsumerIds { get; }
Property Value
Type Description
System.Collections.Immutable.ImmutableArray<Int64>
| Improve this Doc View Source

Size

Number of attached consumers.

Declaration
int Size { get; }
Property Value
Type Description
Int32

Methods

| Improve this Doc View Source

ConsumerByIndex(Int32)

Obtain consumer identifier by index

Declaration
long ConsumerByIndex(int index)
Parameters
Type Name Description
Int32 index
Returns
Type Description
Int64
| Improve this Doc View Source

QueueSize(Int64)

Approximate number of buffered elements for a consumer. Larger value than other consumers could be an indication of that the consumer is slow.

Note that this is a moving target since the elements are consumed concurrently.

Declaration
int QueueSize(long consumerId)
Parameters
Type Name Description
Int64 consumerId
Returns
Type Description
Int32

Extension Methods