probe

Documentation

Overview

Package probe contains implementation of the network probe runners.

Index

• type Notification
• type Runner
  • func (runner *Runner) Start(ctx context.Context, notifyCh chan<- Notification, logger *zap.Logger)
  • func (runner *Runner) Stop()

Types

type Notification

type Notification struct {
	ID     string
	Status network.ProbeStatusSpec
}

Notification of a runner status.

type Runner

type Runner struct {
	ID    string
	Spec  network.ProbeSpecSpec
	Clock clock.Clock
	// contains filtered or unexported fields
}

Runner describes a state of running probe.

func (*Runner) Start

func (runner *Runner) Start(ctx context.Context, notifyCh chan<- Notification, logger *zap.Logger)

Start a runner with a given context.

func (*Runner) Stop

func (runner *Runner) Stop()

Stop a runner.