root/fi.utu.tech.powergoblin.measurement

Package-level declarations

Types

class ActiveMeasurementStore(val id: Int, initialName: String = "M-", val startTime: Long, val startEventIndex: Int)

An active measurement is something a session might potentially have. Compared to FinishedMeasurement, the active measurement has mutable fields for updating the runs and meter states. Use the routine 'finish' to produce a FinishedMeasurement.

BackgroundTasks

class BackgroundTasks(id: String, executor: TaskExecutor, mqttClient: MqttClientHandler)

Asynchronous background tasks executed by the executor.

Instance

class Instance(configuration: GlobalConfiguration, meterSources: Collection<MeterSource> = listOf(), subsystems: Collection<Subsystem> = meterSources, simulated: SimulatedMeterSource? = null, launchTime: <Error class: unknown class> = LocalDateTime.now(), val nodeManager: NodeManager = NodeManager()) : HTTPAPI, TelnetAPI, SessionContext

Handler for the application instance. Coordinates much of the application's functionality. Significant functionality is also delegated to meters' handlers, session handlers, and the server objects.

LogManager

class LogManager(configuration: GlobalConfiguration) : DirectoryManager

MeterHandlerPool

class MeterHandlerPool(poolId: String?, observer: ReadingObserver? = null)

Helper structure for handling the meter handlers in a session/free meters. The default observer will be applied to all added meters.

MeterNameGenerator

class MeterNameGenerator(existing: List<PowerMeter> = listOf())

Generates a unique id for a power meter in a thread-safe way. Contains a mutable database for name mappings.

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())

NodeManager

class NodeManager(configPath: <Error class: unknown class>? = null, val maxImageSize: Long = 1000000)

PeriodicStatusPrinter

open class PeriodicStatusPrinter(sessions: Collection<Session>, period: Long?, verbose: Boolean)

Mainly useful for monitoring the measurements. Periodically generates a status line with timestamp & number of received and logged events.

Session

class Session(val id: Int, globalConfiguration: GlobalConfiguration, configuration: SessionConfiguration = globalConfiguration.session, startTime: <Error class: unknown class>, stopTime: <Error class: unknown class>? = null, validationTime: <Error class: unknown class>? = null, version: String = globalAppVersion, val sessionContext: SessionContext, oldLogWriter: LogWriter? = null, initialLogPath: String? = null, initialHandlers: Collection<MeterHandler>, initialTimeSync: List<TimeSync>, initialResourceFilters: List<String> = globalConfiguration.session.resourceFilters, initialResourceSources: Collection<ResourceDataSource>, initialResourceDumps: Collection<String>, initialActiveSources: List<ActiveSource>, initialNodes: List<NodeSummary>, initialMeasurements: Collection<MeasurementSummary>, initialCounters: SessionCounters, initialTriggerEvents: List<TriggerEvent>, initialVariables: Variables, initialReportTemplate: ReportTemplate?) : SessionData, ReadingObserver

The controller class for a single session.

SessionContext

interface SessionContext

SessionData

interface SessionData

SessionSummaryAdapter

class SessionSummaryAdapter(summary: SessionSummary, val logPath: String) : SessionData

Task

data class Task(val name: String, val description: String? = null, val code: (<Error class: unknown class><String>) -> String)

TaskExecutor

class TaskExecutor(debug: Boolean, val executor: <Error class: unknown class> = Executors.newWorkStealingPool())

TaskInstance

class TaskInstance(val id: Int, val task: Task, val statusField: <Error class: unknown class><String>, val result: <Error class: unknown class><<Error class: unknown class><String, Long>>)

TimeSyncer

class TimeSyncer(syncPoints: List<TimeSync>?)