adapter

Documentation

Index

• type Adapter
  • func NewPrometheus(ctx context.Context, outputFileName string, w writer.Writer, logger log.Logger) Adapter
• type AdapterFactory
• type Prom
  • func (p *Prom) GetData() (string, error)
  • func (p *Prom) GetNumberOfTargetsFor(label string) (targets int)
  • func (p *Prom) GetStatus() *Status
  • func (p *Prom) Run(ctx context.Context, updates <-chan []*targetgroup.Group)
• type Status

Types

type Adapter

type Adapter interface {
	GetStatus() *Status
	Run(ctx context.Context, updates <-chan []*targetgroup.Group)
	GetNumberOfTargetsFor(label string) int
	GetData() (string, error)
}

func NewPrometheus

func NewPrometheus(ctx context.Context, outputFileName string, w writer.Writer, logger log.Logger) Adapter

New creates a new instance of Adapter.

type AdapterFactory

type AdapterFactory func(ctx context.Context, m *promDiscovery.Manager, w writer.Writer, logger log.Logger) (Adapter, error)

type Prom

type Prom struct {
	Status *Status
	// contains filtered or unexported fields
}

Adapter runs service discovery implementation and converts its target groups to JSON and writes to a k8s configmap.

func (*Prom) GetData

func (p *Prom) GetData() (string, error)

func (*Prom) GetNumberOfTargetsFor

func (p *Prom) GetNumberOfTargetsFor(label string) (targets int)

func (*Prom) GetStatus

func (p *Prom) GetStatus() *Status

func (*Prom) Run

func (p *Prom) Run(ctx context.Context, updates <-chan []*targetgroup.Group)

type Status

type Status struct {
	sync.Mutex
	Up bool
}