proberunner

Documentation

Index

• Variables
• type Runner
  • func New(opts RunnerOpts, probeRepo repositories.ProbeRepository, ...) *Runner
  • func (r *Runner) Available() int
  • func (r *Runner) Busy() int
  • func (r *Runner) Start(ctx context.Context)
• type RunnerOpts

Variables

var ErrUnsupportedGoal = errors.New("no associated prober for goal")

Types

type Runner

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

func New

func New(
	opts RunnerOpts,
	probeRepo repositories.ProbeRepository,
	uc probeserver.UseCase,
	probers probers.ForGoal,
	metrics *metrics.Collector,
	logger *zerolog.Logger,
) *Runner

func (*Runner) Available

func (r *Runner) Available() int

func (*Runner) Busy

func (r *Runner) Busy() int

func (*Runner) Start

func (r *Runner) Start(ctx context.Context)

type RunnerOpts

type RunnerOpts struct {
	PollInterval time.Duration
	Concurrency  int
	ProbeTimeout time.Duration
}