root/fi.utu.tech.powergoblin.measurement/Node

Node

class Node(val specs: NodeSpecs, val isController: Boolean = false, val hasAgent: Boolean = false, initialDataSources: Map<MeterDataSource, String> = mapOf(), messages: String = "", status: AgentStatus? = null, val id: String = HashAlgo.SHA1.calculateHash(specs.toJson()), timestamp: Long = System.currentTimeMillis()) : Observable<ResourceConsumptionEvent>

Constructors

constructor(specs: NodeSpecs, isController: Boolean = false, hasAgent: Boolean = false, initialDataSources: Map<MeterDataSource, String> = mapOf(), messages: String = "", status: AgentStatus? = null, id: String = HashAlgo.SHA1.calculateHash(specs.toJson()), timestamp: Long = System.currentTimeMillis())

Types

object Companion

Properties

val dataSources: <Error class: unknown class>

val hasAgent: Boolean = false

val isController: Boolean = false

val specs: NodeSpecs

val tasks: <Error class: unknown class><AgentCommand>

Functions

fun appendMessage(message: String, clear: Boolean)

open fun assign(observer: Observer<ResourceConsumptionEvent>)

Resets the meter state and adds an observer.

getAndClearTasks

fun getAndClearTasks(clear: Boolean): List<AgentCommand>

handleResourceEvents

fun handleResourceEvents(events: List<ResourceConsumptionEvent>)

fun isAssigned(): Boolean

fun publish(reading: ResourceConsumptionEvent)

fun summary(): NodeSummary

open fun unassign()

Resets the meter state and adds an observer.

fun updateStatus(newStatus: AgentStatus): Boolean

updateTimestamp

fun updateTimestamp()