common

Documentation

Index

• type CollectorContext
  • func NewCollectorContext(ctx context.Context, cl client.Client, ch chan<- prometheus.Metric, ...) *CollectorContext
  • func (cc *CollectorContext) Client() client.Client
  • func (cc *CollectorContext) ErrCount() int32
  • func (cc *CollectorContext) HandleError(err error, span trace.Span)
  • func (cc *CollectorContext) RecordMetrics(metrics ...prometheus.Metric)
  • func (cc *CollectorContext) RootCtx() context.Context
  • func (cc *CollectorContext) Tracer() trace.Tracer
  • func (cc *CollectorContext) WaitGroup() *sync.WaitGroup
• type Member
• type MemberList
• type Status
  • func (s *Status) EnabledValue() float64
  • func (s *Status) HealthValue() float64

Types

type CollectorContext

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

func NewCollectorContext

func NewCollectorContext(ctx context.Context, cl client.Client, ch chan<- prometheus.Metric, tracer trace.Tracer) *CollectorContext

func (*CollectorContext) Client

func (cc *CollectorContext) Client() client.Client

func (*CollectorContext) ErrCount

func (cc *CollectorContext) ErrCount() int32

func (*CollectorContext) HandleError

func (cc *CollectorContext) HandleError(err error, span trace.Span)

func (*CollectorContext) RecordMetrics

func (cc *CollectorContext) RecordMetrics(metrics ...prometheus.Metric)

func (*CollectorContext) RootCtx

func (cc *CollectorContext) RootCtx() context.Context

func (*CollectorContext) Tracer

func (cc *CollectorContext) Tracer() trace.Tracer

func (*CollectorContext) WaitGroup

func (cc *CollectorContext) WaitGroup() *sync.WaitGroup

type Member

type Member struct {
	Path string `json:"@odata.id"`
}

type MemberList

type MemberList struct {
	Members []Member
}

type Status

type Status struct {
	Health string `json:"Health"`
	State  string `json:"State"`
}

func (*Status) EnabledValue

func (s *Status) EnabledValue() float64

func (*Status) HealthValue

func (s *Status) HealthValue() float64