org.eso.ias.heartbeat

Members list

Type members

Classlikes

class HbEngine extends Runnable

The HbEngine periodically sends the message to the publisher subscriber framework.

The HbEngine periodically sends the message to the publisher subscriber framework.

Users of this class shall only notify of changes in the status message.

It is a singleton to be sure that the same tool does not send the HB twice.

The initial status is STARTING_UP; then it must be updated by calling updateHbState to follow the computational phases of the tool that sends the HB.

Value parameters

frequency

the frequency to send the heartbeat (seconds)

hb

the heartbeat of the tool

publisher

publish HB messages

Attributes

Companion
object
Supertypes
trait Runnable
class Object
trait Matchable
class Any
object HbEngine

Companion object

Companion object

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
HbEngine.type

HbPublisher trait for sending heartbeat

HbPublisher trait for sending heartbeat

Implementers of this trait sends the heartbeat to the publisher framework, a file or any other

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
abstract class HbProducer(val serializer: HbMsgSerializer)

Implementation of HbProducer pushes the HB status message

Implementation of HbProducer pushes the HB status message

Value parameters

serializer

The serializer to transform the HB state in a string

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Heartbeat

The HB published in the kafka topic,

The HB published in the kafka topic,

It is composed of a type and a name (that together are the unique identifier of the tool) plus the hostname where the tool runs

The Heartbeat is immutable.

Value parameters

hbType

The type of the tool

hostName

the hostname where the tool runs

name

The name of the tool

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object Heartbeat

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
Heartbeat.type