stats

type Controller interface {
	Close()
	RequestStat() chan *Statistics
	UpdateLoadStat(taskID string, config string, filters []string)
	UpdateUnloadStat(taskID string)
	UpdateExecutionStat(taskID string, metricsCount int, success bool, startTime, endTime time.Time)
	UpdateStreamingStat(taskID string, metricsCount int, startTime, lastUpdate time.Time)
}

type EmptyController struct {
}

type StatCommand interface {
	ApplyStat()
}

type Statistics struct {
	PluginInfo   pluginInfo             `json:"Plugin info"`
	TasksSummary tasksSummary           `json:"Tasks summary"`
	TasksDetails map[string]taskDetails `json:"Task details"`
}

type StatisticsController struct {
	// contains filtered or unexported fields
}