lokahiadminserver

Documentation

Overview

Package lokahiadminserver implements twirp package github.xe.lokahi.admin

Index

• type LocalRun
  • func (l *LocalRun) Checks(ctx context.Context, cids *lokahiadmin.CheckIDs) (*lokahiadmin.Run, error)
  • func (l *LocalRun) DoCheck(ctx context.Context, rid string, ck *database.Check) (*lokahiadmin.Health, database.Check)
  • func (l *LocalRun) Minutely() error
  • func (l *LocalRun) Run(ctx context.Context, cids *lokahiadmin.CheckIDs) (*lokahiadmin.Run, error)
  • func (l *LocalRun) SendWebhook(ctx context.Context, ck *lokahi.Check, health *lokahiadmin.Health, done func())
  • func (l *LocalRun) Stats(ctx context.Context, _ *lokahiadmin.Nil) (*lokahiadmin.HistogramData, error)
• type Runner

Types

type LocalRun

type LocalRun struct {
	HC *http.Client

	Cs  database.Checks
	Rs  database.Runs
	Ris database.RunInfos

	Nc *nats.Conn
	// contains filtered or unexported fields
}

func (*LocalRun) Checks

func (l *LocalRun) Checks(ctx context.Context, cids *lokahiadmin.CheckIDs) (*lokahiadmin.Run, error)

func (*LocalRun) DoCheck

func (l *LocalRun) DoCheck(ctx context.Context, rid string, ck *database.Check) (*lokahiadmin.Health, database.Check)

DoCheck executes a HTTP healthcheck given a run id and check.

func (*LocalRun) Minutely

func (l *LocalRun) Minutely() error

func (*LocalRun) Run

func (l *LocalRun) Run(ctx context.Context, cids *lokahiadmin.CheckIDs) (*lokahiadmin.Run, error)

func (*LocalRun) SendWebhook

func (l *LocalRun) SendWebhook(ctx context.Context, ck *lokahi.Check, health *lokahiadmin.Health, done func())

SendWebhook sends a webhook to a given target by check id.

func (*LocalRun) Stats

func (l *LocalRun) Stats(ctx context.Context, _ *lokahiadmin.Nil) (*lokahiadmin.HistogramData, error)

type Runner

type Runner interface {
	Run(context.Context, *lokahiadmin.CheckIDs) (*lokahiadmin.Run, error)
}