trait ConsumerInfo extends AnyRef

Annotations
@DoNotInherit()
Source
Hub.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
ConsumerInfo
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerInfo
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def consumerIdByIdx(idx: Int): Long

    Obtain consumer identifier by index

  2. 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.

  3. 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.

  4. abstract def size: Int

    Number of attached consumers.