SupervisorStatistics

org.eso.ias.supervisor.SupervisorStatistics
See theSupervisorStatistics companion object
class SupervisorStatistics(id: String, val dasusIds: Set[String]) extends StatsCollectorBase

Stats logger produces statistics for the Supervisor

Value parameters

dasusIds

The IDs of the DAUS deployed in the Supervisur

id

The identifier of the Supervisor

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def logStats(): Unit

Emit the logs with the statistics and reset the counters

Emit the logs with the statistics and reset the counters

Attributes

Definition Classes
def numOfInputsOfDasu(id: String, inputsProcessed: Int): Unit

Updated the execution time and number of inputs processed ot the DASU with the passed id

Updated the execution time and number of inputs processed ot the DASU with the passed id

Value parameters

id

the ID of the daus

inputsProcessed

the number of inputs processed

Attributes

def numberOfInputsReceived(numberOfInputs: Int): Unit

Add the number of inputs received to the accumulator

Add the number of inputs received to the accumulator

Attributes

def supervisorPropagationTime(time: Long): Unit

Updates the time spent by the Supervisor to propagate the inputs to the DASUs

Updates the time spent by the Supervisor to propagate the inputs to the DASUs

Value parameters

time

The time spent by the Supervisor

Attributes

Inherited methods

def cleanUp(): Unit

Stop loging statistics

Stop loging statistics

Attributes

Inherited from:
StatsCollectorBase
def start(): Unit

Start logging statistics

Start logging statistics

Attributes

Inherited from:
StatsCollectorBase

Concrete fields

val dasusIds: Set[String]
val dasusInputsAndFrequency: Map[String, (Long, Long)]

The map to associate the execution time and processed inputs to each DASU.

The map to associate the execution time and processed inputs to each DASU.

The key is the ID of the DASU. The value is a couple with

  • the number of inputs processed
  • the number of updates invoked (to calculate thefrequency)

Attributes

val inputsProcessed: AtomicLong

Total number of inputs forwarded to the DASU to be processed in the last time interval

Total number of inputs forwarded to the DASU to be processed in the last time interval

Attributes

The longest time spent by the Supervisor to send IASIOs to all the DASUs

The longest time spent by the Supervisor to send IASIOs to all the DASUs

Attributes

val totInputsProcessed: AtomicLong

Total number of inputs forwarded to the DASU to be processed since when the Supervisor started

Total number of inputs forwarded to the DASU to be processed since when the Supervisor started

Attributes