monitor

Documentation

Index

• type Discoverer
• type Monitor
  • func NewMonitorQueue(d Discoverer, metricsPrefix, outfilepath string, log *zerolog.Logger) *Monitor
  • func (q *Monitor) AddMetricsHandler(r *mux.Router)
  • func (q *Monitor) DoDiscover(ctx context.Context, interval time.Duration, region, query string) error
  • func (q *Monitor) DoObserve(ctx context.Context, interval time.Duration, promUrl, promQ, promL string) error
  • func (q *Monitor) InitMetrics(prefix string)
  • func (q *Monitor) NextItem(r string) (interface{}, bool)
  • func (q *Monitor) NextName(r string) (string, bool)
• type Queue
• type State

Types

type Discoverer

type Discoverer interface {
	// Discover returns discovered data, warnings and error
	Discover(region, query string) (data map[string]interface{}, warns []error, e error)
}

type Monitor

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

func NewMonitorQueue

func NewMonitorQueue(d Discoverer, metricsPrefix, outfilepath string, log *zerolog.Logger) *Monitor

func (*Monitor) AddMetricsHandler

func (q *Monitor) AddMetricsHandler(r *mux.Router)

func (*Monitor) DoDiscover

func (q *Monitor) DoDiscover(ctx context.Context, interval time.Duration, region, query string) error

func (*Monitor) DoObserve

func (q *Monitor) DoObserve(ctx context.Context, interval time.Duration, promUrl, promQ, promL string) error

func (*Monitor) InitMetrics

func (q *Monitor) InitMetrics(prefix string)

func (*Monitor) NextItem

func (q *Monitor) NextItem(r string) (interface{}, bool)

func (*Monitor) NextName

func (q *Monitor) NextName(r string) (string, bool)

type Queue

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

type State

type State int32