root/fi.utu.tech.powergoblin.agent/Agent

Agent

class Agent(var configuration: AgentConfiguration, val pool: <Error class: unknown class>)

The agent manages the node. It maintains a connection to the PowerGoblin service, it constantly polls for new commands and performs them sequentially.

Most commands block until they either fail or succeed. The collector command is started as a background process.

Constructors

Agent

constructor(configuration: AgentConfiguration, pool: <Error class: unknown class>)

Properties

configuration

var configuration: AgentConfiguration

connection

val connection: ClientConnection

pool

val pool: <Error class: unknown class>

startTime

val startTime: <Error class: unknown class>

startTimeString

val startTimeString: <Error class: unknown class>

Functions

open fun close()

determineCapabilities

fun determineCapabilities(cmd: AgentDetermineCapabilitiesCommand)

download

fun download(cmd: AgentDownloadMeasurementCommand)

execute

fun execute(cmd: AgentExecuteCommand): String

isCollecting

fun isCollecting(): Boolean

launchCollectd

fun launchCollectd(cmd: AgentCollectCommand, test: Boolean = false, filter: List<CollectorFlag> = capabilities)

listen

fun listen()

locateMeasurements

fun locateMeasurements(): List<PlanEntry>

measure

fun measure(cmd: AgentMeasureCommand)

powerOff

fun powerOff()

reboot

fun reboot()

reconfigure

fun reconfigure(cmd: AgentReconfigureCommand)

rootPath

fun rootPath(): <Error class: unknown class>

runCommand

fun runCommand(cmd: AgentCommand, log: Boolean = true): String?

stopCollectd

fun stopCollectd()

updateAgentConfiguration

fun updateAgentConfiguration(): AgentConfiguration

Updates the 'configuration' (from goblin-agent.json).

updateNodeSpecs

fun updateNodeSpecs(pool: <Error class: unknown class>, newConfiguration: AgentConfiguration = updateAgentConfiguration()): NodeSpecs

Updates the

updateStatus

fun updateStatus(newTask: AgentTask? = null)