Interface PartitionHub.IConsumerInfo

DO NOT INHERIT

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

Properties

| Edit this page 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(int) method instead, which is optimised for this use case.

Declaration
ImmutableArray<long> ConsumerIds { get; }
Property Value
Type Description
ImmutableArray<long>
| Edit this page View Source

Size

Number of attached consumers.

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

Methods

| Edit this page View Source

ConsumerByIndex(int)

Obtain consumer identifier by index

Declaration
long ConsumerByIndex(int index)
Parameters
Type Name Description
int index
Returns
Type Description
long
| Edit this page View Source

QueueSize(long)

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
long consumerId
Returns
Type Description
int

Extension Methods