trait ConsumerInfo extends javadsl.PartitionHub.ConsumerInfo
- Annotations
- @DoNotInherit()
- Source
- Hub.scala
- Alphabetic
- By Inheritance
- ConsumerInfo
- ConsumerInfo
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def consumerIdByIdx(idx: Int): Long
Obtain consumer identifier by index
Obtain consumer identifier by index
- Definition Classes
- → ConsumerInfo
- abstract def consumerIds: [Long]
Sequence of all identifiers of current consumers.
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 #consumerIdByIdx method instead, which is optimised for this use case.
- abstract def getConsumerIds: [Long]
Sequence of all identifiers of current consumers.
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 #consumerIdByIdx method instead, which is optimised for this use case.
- Definition Classes
- ConsumerInfo
- abstract def queueSize(consumerId: Long): Int
Approximate number of buffered elements for a consumer.
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.
- Definition Classes
- → ConsumerInfo
- abstract def size: Int
Number of attached consumers.
Number of attached consumers.
- Definition Classes
- → ConsumerInfo