metrics

type Collections struct {
	Count int // this is the number of collections run.  Will use this to calculate the average.
	Data  map[string]PerDimension
}

type Collector interface {
	Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *StatsEntityWrapper)
	UpdateConfig(config *config.Config)
}

type CommonDim struct {
	SystemId, Hostname, InstanceTags, InstanceGroup,
	DisplayName, NginxId string

	PublishedAPI, NginxType, NginxBuild, NginxVersion,
	NginxBinPath, NginxConfPath string

	NginxAccessLogPaths []string
}

type MetricsHandler func(float64, int) float64

type MetricsReportBundle struct {
	Data []*proto.MetricsReport
}

type NginxCollectorConfig struct {
	NginxId            string
	StubStatus         string
	PlusAPI            string
	BinPath            string
	ConfPath           string
	CollectionInterval time.Duration
	AccessLogs         []string
	ErrorLogs          []string
	ClientVersion      int
}

type NginxSource interface {
	Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *StatsEntityWrapper)
	Update(dimensions *CommonDim, collectorConf *NginxCollectorConfig)
	Stop()
}

type PerDimension struct {
	Dimensions    []*proto.Dimension
	RunningSumMap map[string]float64
}

type Source interface {
	Collect(ctx context.Context, wg *sync.WaitGroup, m chan<- *StatsEntityWrapper)
}

type StatsEntityWrapper struct {
	Type proto.MetricsReport_Type
	Data *proto.StatsEntity
}