symo

type AppConf struct {
	MaxSeconds int
}

type CPU func(ctx context.Context, action MetricCommand) (*CPUData, error)

type CPUData struct {
	User   float64
	System float64
	Idle   float64
}

type ClientData struct {
	N int // информация отправляется каждые N секунд
	M int // информация усредняется за M секунд
}

type Clients interface {
	Start(context.Context, <-chan MetricsData)
	Stop(context.Context)
	NewClienter
}

type Collector interface {
	Start(context.Context, MetricCollectors, chan<- MetricsData)
	Stop(context.Context)
}

type CollectorToClientsCh chan MetricsData

type Config struct {
	App    AppConf
	Log    LoggerConf
	Server ServerConf
	Metric MetricConf
}

type DiskData struct {
	Name    string
	Tps     float64
	KBRead  float64
	KBWrite float64
}

type FSData struct {
	Path      string
	UsedSpace float64
	UsedInode float64
}

type GRPCServer interface {
	Start(addr string, clients NewClienter) error
	Stop(ctx context.Context)
}

type LoadAvg func(ctx context.Context) (*LoadAvgData, error)

type LoadAvgData struct {
	Load1  float64
	Load5  float64
	Load15 float64
}

type LoadDisks func(ctx context.Context, action MetricCommand) (LoadDisksData, error)

type LoadDisksData []DiskData

type Logger interface {
	Debug(args ...interface{})
	Info(args ...interface{})
	Error(args ...interface{})
	Fatal(args ...interface{})
}

type LoggerConf struct {
	Level string
}

type MetricCollectors struct {
	LoadAvg   LoadAvg
	CPU       CPU
	LoadDisks LoadDisks
	UsedFS    UsedFS
}

type MetricCommand int

type MetricConf struct {
	Loadavg   bool
	CPU       bool
	Loaddisks bool
	UsedFS    bool
}

type MetricsData struct {
	Time   time.Time
	Points Points
}

type NewClienter interface {
	// возвращает канал для получения отсылаемых данных и ф-ия отключения клиента
	NewClient(ClientData) (<-chan *Stats, func(), error)
}

type Point struct {
	LoadAvg   *LoadAvgData
	CPU       *CPUData
	LoadDisks LoadDisksData
	UsedFS    UsedFSData
}

type Points map[time.Time]*Point

type ServerConf struct {
	Port string
}

type Stats struct {
	Time      time.Time
	LoadAvg   *LoadAvgData
	CPU       *CPUData
	LoadDisks LoadDisksData
	UsedFS    UsedFSData
}

type UsedFS func(ctx context.Context, action MetricCommand) (UsedFSData, error)

type UsedFSData []FSData