root
API
Generated with
root/org.eso.ias/org.eso.ias.supervisor/org.eso.ias.supervisor.test/DasuMock

DasuMock

org.eso.ias.supervisor.test.DasuMock
See theDasuMock companion object
class DasuMock(dasuIdentifier: Identifier, dasuDao: DasuDao, outputPublisher: OutputPublisher, inputSubscriber: InputSubscriber) extends Dasu

A mockup of the DASUs to run in the Supervisor without the complexity of DASUs and ASCEs

Value parameters

dasuDao

the DASU configuration

inputSubscriber

the subscriber getting events to be processed

outputPublisher

the publisher to send the output

Attributes

Companion
object
Graph
Supertypes
class Dasu
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def ack(alarmIdentifier: Identifier): Boolean

ACK the alarm if the ASCE that produces it runs in this DASU.

ACK the alarm if the ASCE that produces it runs in this DASU.

The DASU delegates the acknowledgment to the ASCE that produces the alarm

Value parameters

alarmIdentifier

the identifier of the alarm to ACK

Attributes

Returns

true if the alarm has been ACKed, false otherwise

See also
Definition Classes
def cleanUp(): Unit

Release all the resources before exiting

Release all the resources before exiting

Attributes

override def enableAutoRefreshOfOutput(enable: Boolean): Unit

Enable/Disable the automatic update of the output in case no new inputs arrive.

Enable/Disable the automatic update of the output in case no new inputs arrive.

Most likely, the value of the output remains the same while the validity could change.

Attributes

Definition Classes
def getAsceIds(): Set[String]

The IDs of the ASCEs running in the DASU

The IDs of the ASCEs running in the DASU

Attributes

def getInputIds(): Set[String]

The inputs of the DASU

The inputs of the DASU

Attributes

override def inputsReceived(iasios: Iterable[IASValue[_]]): Unit

Updates the output with the inputs received and simulate the sending of the output

Updates the output with the inputs received and simulate the sending of the output

Value parameters

iasios

the inputs received

Attributes

See also

InputsListener

Definition Classes
def start(): Try[Unit]

Start getting events from the inputs subscriber to produce the output

Start getting events from the inputs subscriber to produce the output

Attributes

Concrete fields

val asceDaos: Seq[AsceDao]

The configuration of the ASCEs that run in the DASU

The configuration of the ASCEs that run in the DASU

Attributes

val inputsOfTheDasu: Set[String]

The inputs of the DASU

The inputs of the DASU

Attributes

val inputsReceivedFromSuperv: ArrayBuffer[String]

All the inputs received so far

All the inputs received so far

Attributes

val numOfCleanUps: AtomicInteger

How many times cleanUp has been called

How many times cleanUp has been called

Attributes

val numOfDisableAutorefresh: AtomicInteger

How many times the Supervisor disabled the auto refresh of the output

How many times the Supervisor disabled the auto refresh of the output

Attributes

val numOfEnableAutorefresh: AtomicInteger

How many times the Supervisor enabled the auto refresh of the output

How many times the Supervisor enabled the auto refresh of the output

Attributes

val numOfStarts: AtomicInteger

How many times the Supervisor started the DASU

How many times the Supervisor started the DASU

Attributes

val output: IASValue[_]

The output published when inputs are received

The output published when inputs are received

Attributes

val unexpectedInputsReceived: ArrayBuffer[String]

unexpected inputs received so far: if everything works well this should always be empty otherwise the Supervisor sent a IASIO to a DASU that does not need it

unexpected inputs received so far: if everything works well this should always be empty otherwise the Supervisor sent a IASIO to a DASU that does not need it

Attributes

Inherited fields

val autoSendTimeInterval: Integer

Attributes

Inherited from:
Dasu
val autoSendTimeIntervalMillis: Long

Auto send time interval in milliseconds

Auto send time interval in milliseconds

Attributes

Inherited from:
Dasu
val fromTemplate: Boolean

True if the DASU has been generated from a template, False otherwise

True if the DASU has been generated from a template, False otherwise

Attributes

Inherited from:
Dasu
val id: String

The ID of the DASU

The ID of the DASU

Attributes

Inherited from:
Dasu
lazy val templateInstance: Option[Int]

The number of the instance if the DASU has been generated from a template; empty otherwise

The number of the instance if the DASU has been generated from a template; empty otherwise

Attributes

Inherited from:
Dasu
val throttling: Long

The minimum allowed refresh rate when a flow of inputs arrive (i.e. the throttiling) is given by Dasu.DefaultMinAllowedRefreshRate, if not overridden by a java property

The minimum allowed refresh rate when a flow of inputs arrive (i.e. the throttiling) is given by Dasu.DefaultMinAllowedRefreshRate, if not overridden by a java property

Attributes

Inherited from:
Dasu
val validityThreshold: Integer

Attributes

Inherited from:
Dasu
val validityThresholdMillis: Long

The validityThreshold in milliseconds

The validityThreshold in milliseconds

Attributes

Inherited from:
Dasu
Generated with