strategies

package

v1.5.0 Latest Latest Go to latest Published: Nov 16, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var Registrar = &StrategyRegistrar{
	Strategies: make(map[time.Duration][]Strategy),
}

This section is empty.

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

func (s *CpuTimes) Options() Options

func (s *CpuTimes) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error

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

func (s *DiskUsage) Options() Options

func (s *DiskUsage) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error

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

func (s *LoadAvg) Options() Options

func (s *LoadAvg) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error

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

func (s *Memory) Options() Options

func (s *Memory) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error

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

func (s *Net) Options() Options

func (s *Net) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error

type Options struct {
	Namespace string
	Id        string
	Frequency time.Duration
}

type Strategy interface {
	Options() Options
	Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error
}

Strategy provides a common interface for different monitoring tasks.

type StrategyRegistrar struct {
	Strategies map[time.Duration][]Strategy
}

func (r *StrategyRegistrar) RegisterStrategy(strategy Strategy)

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

func (s *Uptime) Options() Options

func (s *Uptime) Run(ctx context.Context, dataCh chan<- []*pb.MetricsPayload_Metric) error