probestatus

Documentation

Overview

Package probestatus implements a surfacer that exposes probes' status over web interface. This surfacer builds an in-memory timeseries database from the incoming EventMetrics.

Index

• type Surfacer
  • func New(ctx context.Context, config *configpb.SurfacerConf, opts *options.Options, ...) (*Surfacer, error)
  • func (ps *Surfacer) Write(_ context.Context, em *metrics.EventMetrics)

Types

type Surfacer

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

Surfacer implements a status surfacer for Cloudprober.

func New

func New(ctx context.Context, config *configpb.SurfacerConf, opts *options.Options, l *logger.Logger) (*Surfacer, error)

New returns a probestatus surfacer based on the config provided. It sets up a goroutine to process both the incoming EventMetrics and the web requests for the URL handler /metrics.

func (*Surfacer) Write

func (ps *Surfacer) Write(_ context.Context, em *metrics.EventMetrics)

Write queues the incoming data into a channel. This channel is watched by a goroutine that actually processes the data and updates the in-memory database.