monitor

package

v0.0.0-...-7099f79 Latest Latest Go to latest Published: Apr 27, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func StartMonitor(ctx context.Context, containerName string, timeout int) (context.Context, error)

func WaitMonitorUntilProcessingFinished(ctx context.Context) (context.Context, error)

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

func (s *Info) Add(val float64)

func (s *Info) CalculateAvg() float64

func (s *Info) CalculateMax() float64

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

func (m *Monitor) Done() <-chan int

func (m *Monitor) Start(ctx context.Context, containerName string, timeout int) (context.Context, error)

type RecordsItem struct {
	Name    string    `json:"name"`
	Records []float64 `json:"records"`
	Unit    string    `json:"unit"`
}

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

func NewMonitorStatistic(name string) *Statistic

func (m *Statistic) ClearStatistic()

func (m *Statistic) GetCPURawData() []float64

func (m *Statistic) MarshalRecordsJSON() ([]byte, error)

func (m *Statistic) MarshalStatisticJSON() ([]byte, error)

func (m *Statistic) UpdateStatistic(stat *v1.ContainerStats)

type StatisticItem struct {
	Name  string  `json:"name"`
	Value float64 `json:"value"`
	Unit  string  `json:"unit"`
}