runner

Documentation

Overview

Package runner [responsible for updating the config and managing jobs accordingly]

Index

• type Config
• type Runner
  • func New(cfg *Config, debug bool) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context)

Types

type Config

type Config struct {
	ConfigPaths    []string          // Comma-separated config location URLs
	BackupConfig   []byte            // Raw backup config
	RefreshTimeout time.Duration     // How often to refresh config
	Format         string            // json or yaml
	Global         jobs.GlobalConfig // meant to pass cmdline and other args to every job
}

Config for the job runner

type Runner

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

Runner executes jobs according to the (fetched from remote) configuration

func New

func New(cfg *Config, debug bool) (*Runner, error)

New runner according to the config

func (*Runner) Run

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

Run the runner and block until Stop() is called