trait ConsumerInfo extends javadsl.PartitionHub.ConsumerInfo
- Annotations
- @DoNotInherit() @ApiMayChange()
- Source
- Hub.scala
- Alphabetic
- By Inheritance
- ConsumerInfo
- ConsumerInfo
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
consumerIdByIdx(idx: Int): Long
Obtain consumer identifier by index
Obtain consumer identifier by index
- Definition Classes
- ConsumerInfo → ConsumerInfo
-
abstract
def
consumerIds: IndexedSeq[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: List[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 → ConsumerInfo
-
abstract
def
size: Int
Number of attached consumers.
Number of attached consumers.
- Definition Classes
- ConsumerInfo → ConsumerInfo