Documentation ¶
Index ¶
Constants ¶
View Source
const BufferSize = 32
Variables ¶
This section is empty.
Functions ¶
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 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( settings *service.Settings, logger *observability.NexusLogger, 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.