querier

Documentation

Index

• Variables
• func BuildQueriers(sources []config.Datasource) (map[string]Querier, error)
• type Datadog
  • func NewDatadog(cfg config.Datasource) (*Datadog, error)
  • func (d *Datadog) Status(ctx context.Context, query config.Query) (bool, error)
  • func (d *Datadog) Uptime(ctx context.Context, query config.Query) (float32, []Item, error)
• type Item
• type Prometheus
  • func NewPrometheus(conf config.Datasource) (*Prometheus, error)
  • func (q *Prometheus) Status(ctx context.Context, query config.Query) (bool, error)
  • func (q *Prometheus) Uptime(ctx context.Context, query config.Query) (float32, []Item, error)
• type Querier

Variables

var (
	ErrInvalidDatasourceMapping = errors.New("unknown datasource/querier mapping")
)

var (
	ErrInvalidNumberOfSeries = errors.New("datadog returned an invalid number of series")
)

var (
	ErrTypeNotImplemented = errors.New("query result type not implemented yet")
)

Functions

func BuildQueriers

func BuildQueriers(sources []config.Datasource) (map[string]Querier, error)

Types

type Datadog

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

func NewDatadog

func NewDatadog(cfg config.Datasource) (*Datadog, error)

func (*Datadog) Status

func (d *Datadog) Status(ctx context.Context, query config.Query) (bool, error)

func (*Datadog) Uptime

func (d *Datadog) Uptime(ctx context.Context, query config.Query) (float32, []Item, error)

type Item

type Item struct {
	Time  time.Time
	Value float64
}

type Prometheus

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

func NewPrometheus

func NewPrometheus(conf config.Datasource) (*Prometheus, error)

func (*Prometheus) Status

func (q *Prometheus) Status(ctx context.Context, query config.Query) (bool, error)

func (*Prometheus) Uptime

func (q *Prometheus) Uptime(ctx context.Context, query config.Query) (float32, []Item, error)

type Querier

type Querier interface {
	// Calculate the uptime of the service
	// Returns the % uptime, and the series of items of the metric
	Uptime(context.Context, config.Query) (float32, []Item, error)

	// Check whether the service is up/down
	Status(context.Context, config.Query) (bool, error)
}