runtime

Documentation

Index

• type Engine
  • func NewEngine(cfg *spec.Config, cfgPath string) *Engine
  • func (e *Engine) Run(ctx context.Context) error
• type LocalJobSource
  • func NewLocalJobSource(checks []spec.CheckSpec) *LocalJobSource
  • func (s *LocalJobSource) Ack(_ context.Context, _ spec.Lease, _ spec.CheckResult) error
  • func (s *LocalJobSource) Heartbeat(_ context.Context, _ spec.Lease) error
  • func (s *LocalJobSource) Nack(_ context.Context, _ spec.Lease, _ string) error
  • func (s *LocalJobSource) Poll(_ context.Context, _ spec.WorkerInfo) ([]spec.Lease, error)
  • func (s *LocalJobSource) UpdateChecks(checks []spec.CheckSpec)

Types

type Engine

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

func NewEngine

func NewEngine(cfg *spec.Config, cfgPath string) *Engine

func (*Engine) Run

func (e *Engine) Run(ctx context.Context) error

type LocalJobSource

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

func NewLocalJobSource

func NewLocalJobSource(checks []spec.CheckSpec) *LocalJobSource

func (*LocalJobSource) Ack

func (s *LocalJobSource) Ack(_ context.Context, _ spec.Lease, _ spec.CheckResult) error

func (*LocalJobSource) Heartbeat

func (s *LocalJobSource) Heartbeat(_ context.Context, _ spec.Lease) error

func (*LocalJobSource) Nack

func (s *LocalJobSource) Nack(_ context.Context, _ spec.Lease, _ string) error

func (*LocalJobSource) Poll

func (s *LocalJobSource) Poll(_ context.Context, _ spec.WorkerInfo) ([]spec.Lease, error)

func (*LocalJobSource) UpdateChecks

func (s *LocalJobSource) UpdateChecks(checks []spec.CheckSpec)