datasource

Documentation

Index

• func ConvertAllRawData(rawData []*core.ContainerRawData) []*core.ContainerWorkloadData
• func ConvertRawData(rawData *core.ContainerRawData) *core.ContainerWorkloadData
• type ContainerMetric
• type MetricDataSource
• type RawDataReader
  • func NewDataSourceRawDataReader(source MetricDataSource) RawDataReader

Functions

func ConvertAllRawData

func ConvertAllRawData(rawData []*core.ContainerRawData) []*core.ContainerWorkloadData

func ConvertRawData

func ConvertRawData(rawData *core.ContainerRawData) *core.ContainerWorkloadData

Types

type ContainerMetric

type ContainerMetric struct {
	ContainerId string
	Cpu         float32
	Mem         float32
	Timestamp   uint64
}

type MetricDataSource

type MetricDataSource interface {
	// 读取一条容器监控数据。若读取完毕，则error设置为io.EOF。error为其他时表示读取出错
	Load() (*ContainerMetric, error)
}

type RawDataReader

type RawDataReader interface {
	Read() ([]*core.ContainerRawData, error)
}

func NewDataSourceRawDataReader

func NewDataSourceRawDataReader(source MetricDataSource) RawDataReader