org.eso.ias.extras.times

Members list

Type members

Classlikes

class CalcConversionTime(servers: String) extends SimpleKafkaIasiosConsumer, IasioListener

CalcConversionTime continuosly gets IASIOs from the core topic and evaluate and periodically log the average time spent by the Converter.

CalcConversionTime continuosly gets IASIOs from the core topic and evaluate and periodically log the average time spent by the Converter.

The time is calculated by checking the timestamps of the IASIOs. To make calculation more precise (in spite of memory consumption) the process keep in memory all the evaluated times

The tool logs 2 average times:

  • total, end to end: from when the plugin pushed the value in the plugin topic to the moment the converter push the IASIO in the core topic
  • conversion time: from when the converter takes the value from the plugin topic to the moment the IASIO i spushed in the BSDB

The former takes into account the delay a value remains in the plugin topic before being processed. If it is too long then it is probably the case to deploy another converter.

The latter is pure converter calculation and should never grow substantially.

Value parameters

servers

Kafka brokers

Attributes

Companion
object
Supertypes
trait IasioListener
class SimpleKafkaIasiosConsumer
trait StringsConsumer
class Object
trait Matchable
class Any
Show all

Companion object

Companion object

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type