In package com.cdsap.talaiot.publisher
class com.cdsap.talaiot.publisher.TalaiotPublisherImpl
Implementation of TalaiotPublisher. It will retrieve all the metrics trough the MetricsProvider and the Publishers defined in the configuration trough the PublisherProvider. At the publishing phase it will aggregate the data of in a TaskMeasurementAggregated to publish the result on each publisher retrieved. Before the publishing phase we will apply the TaskFilterProcessor. Filtering doesn't apply to the TaskDependencyGraphPublisher
Constructors
constructor(extension: TalaiotExtension, logger: LogTracker, metricsProvider: Provider, publisherProvider: Provider)
Implementation of TalaiotPublisher. It will retrieve all the metrics trough the MetricsProvider and the Publishers defined in the configuration trough the PublisherProvider. At the publishing phase it will aggregate the data of in a TaskMeasurementAggregated to publish the result on each publisher retrieved. Before the publishing phase we will apply the TaskFilterProcessor. Filtering doesn't apply to the TaskDependencyGraphPublisher
-
extension: TalaiotExtension -
logger: LogTracker -
metricsProvider: Provider -
publisherProvider: Provider
Methods
fun publish(taskLengthList: MutableList, startMs: Long, configuraionMs: Long?, endMs: Long, success: Boolean)
-
taskLengthList: MutableList -
startMs: Long -
configuraionMs: Long? -
endMs: Long -
success: Boolean