Documentation ¶
Index ¶
- func Average(nums []float64) float64
- func GetRocmSMICmd() (string, error)
- type Asset
- type Buffer
- type CPU
- type Disk
- type GPUAMD
- func (g *GPUAMD) AggregateMetrics() map[string]float64
- func (g *GPUAMD) ClearMetrics()
- func (g *GPUAMD) IsAvailable() bool
- func (g *GPUAMD) Name() string
- func (g *GPUAMD) ParseStats(stats map[string]interface{}) Stats
- func (g *GPUAMD) Probe() *service.MetadataRequest
- func (g *GPUAMD) SampleMetrics()
- func (g *GPUAMD) Samples() map[string][]float64
- type GPUApple
- type GPUNvidia
- type InfoDict
- type List
- type Measurement
- type Memory
- type Network
- type Stats
- type StatsKeys
- type SystemMonitor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetRocmSMICmd ¶
Types ¶
type Buffer ¶
type Buffer struct {
// contains filtered or unexported fields
}
Buffer is the in-memory metrics buffer for the system monitor
type CPU ¶
type CPU struct {
// contains filtered or unexported fields
}
func (*CPU) AggregateMetrics ¶
func (*CPU) ClearMetrics ¶
func (c *CPU) ClearMetrics()
func (*CPU) IsAvailable ¶
func (*CPU) Probe ¶
func (c *CPU) Probe() *service.MetadataRequest
func (*CPU) SampleMetrics ¶
func (c *CPU) SampleMetrics()
type Disk ¶
type Disk struct {
// contains filtered or unexported fields
}
func (*Disk) AggregateMetrics ¶
func (*Disk) ClearMetrics ¶
func (d *Disk) ClearMetrics()
func (*Disk) IsAvailable ¶
func (*Disk) Probe ¶
func (d *Disk) Probe() *service.MetadataRequest
func (*Disk) SampleMetrics ¶
func (d *Disk) SampleMetrics()
type GPUAMD ¶
type GPUAMD struct { GetROCMSMIStatsFunc func() (InfoDict, error) // contains filtered or unexported fields }
func (*GPUAMD) AggregateMetrics ¶
func (*GPUAMD) ClearMetrics ¶
func (g *GPUAMD) ClearMetrics()
func (*GPUAMD) IsAvailable ¶
func (*GPUAMD) ParseStats ¶
func (*GPUAMD) Probe ¶
func (g *GPUAMD) Probe() *service.MetadataRequest
func (*GPUAMD) SampleMetrics ¶
func (g *GPUAMD) SampleMetrics()
type GPUApple ¶
type GPUApple struct {
// contains filtered or unexported fields
}
func NewGPUApple ¶
func (*GPUApple) AggregateMetrics ¶
func (*GPUApple) ClearMetrics ¶
func (g *GPUApple) ClearMetrics()
func (*GPUApple) IsAvailable ¶
func (*GPUApple) Probe ¶
func (g *GPUApple) Probe() *service.MetadataRequest
func (*GPUApple) SampleMetrics ¶
func (g *GPUApple) SampleMetrics()
type GPUNvidia ¶
type GPUNvidia struct {
// contains filtered or unexported fields
}
func NewGPUNvidia ¶
func (*GPUNvidia) AggregateMetrics ¶
func (*GPUNvidia) ClearMetrics ¶
func (g *GPUNvidia) ClearMetrics()
func (*GPUNvidia) IsAvailable ¶
func (*GPUNvidia) Probe ¶
func (g *GPUNvidia) Probe() *service.MetadataRequest
func (*GPUNvidia) SampleMetrics ¶
func (g *GPUNvidia) SampleMetrics()
type List ¶
type List struct {
// contains filtered or unexported fields
}
func (*List) Append ¶
func (l *List) Append(element Measurement)
func (*List) GetElements ¶
func (l *List) GetElements() []Measurement
type Measurement ¶
type Measurement struct { // timestamp of the measurement Timestamp *timestamppb.Timestamp // value of the measurement Value float64 }
type Memory ¶
type Memory struct {
// contains filtered or unexported fields
}
func (*Memory) AggregateMetrics ¶
func (*Memory) ClearMetrics ¶
func (m *Memory) ClearMetrics()
func (*Memory) IsAvailable ¶
func (*Memory) Probe ¶
func (m *Memory) Probe() *service.MetadataRequest
func (*Memory) SampleMetrics ¶
func (m *Memory) SampleMetrics()
type Network ¶
type Network struct {
// contains filtered or unexported fields
}
func NewNetwork ¶
func (*Network) AggregateMetrics ¶
func (*Network) ClearMetrics ¶
func (n *Network) ClearMetrics()
func (*Network) IsAvailable ¶
func (*Network) Probe ¶
func (n *Network) Probe() *service.MetadataRequest
func (*Network) SampleMetrics ¶
func (n *Network) SampleMetrics()
type SystemMonitor ¶
type SystemMonitor struct {
// contains filtered or unexported fields
}
func NewSystemMonitor ¶
func NewSystemMonitor( logger *observability.CoreLogger, settings *service.Settings, outChan chan *service.Record, ) *SystemMonitor
NewSystemMonitor creates a new SystemMonitor with the given settings
func (*SystemMonitor) Do ¶
func (sm *SystemMonitor) Do()
func (*SystemMonitor) GetBuffer ¶
func (sm *SystemMonitor) GetBuffer() map[string]List
func (*SystemMonitor) Monitor ¶
func (sm *SystemMonitor) Monitor(asset Asset)
func (*SystemMonitor) Probe ¶
func (sm *SystemMonitor) Probe() *service.MetadataRequest
func (*SystemMonitor) Stop ¶
func (sm *SystemMonitor) Stop()
Click to show internal directories.
Click to hide internal directories.