root
API
Generated with
root/org.eso.ias/org.eso.ias.heartbeat/org.eso.ias.heartbeat.report

org.eso.ias.heartbeat.report

package org.eso.ias.heartbeat.report

Members list

Type members

Classlikes

object HbsCollector

Companion object

Companion object

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
class HbsCollector(val brokers: String, val consumerId: String, val ttl: Long = ..., val ttlCheckTime: Long = ...) extends TimerTask, HbListener

HbsCollector gets and collects the HBs received between invocations of startCollectingHbs and stopCollectingHBs.

HbsCollector gets and collects the HBs received between invocations of startCollectingHbs and stopCollectingHBs.

HBs older than a given TTL (>0) are automatically removed from the container so that dead processes will disappear after they stop sending HBs. The reception time of the HB is checked against the TTL in a Timer task.

The removal of old HBs periodically done by the timer task can be paused/resumed

TODO: There is some overlap with the HbMonitor here: let HbMonitor re-use this class

Value parameters

brokers

Kafka brokers to connect to

consumerId

The id for the kafka consumer

ttl

time to leave (msec>=0) disabled by default, if ttl>0, HBs older then ttl are automatically removed from the container if ttl<=0, received HBs are never removed from the container It makes sense to link TTL to the HB period set in the CDB ("hbFrequency")

ttlCheckTime

the period (msec>0) to check for old HBs

Attributes

Companion
object
Supertypes
trait HbListener
class TimerTask
trait Runnable
class Object
trait Matchable
class Any
Show all
Generated with