runner

Documentation

Index

• Variables
• func GetCapabilities() ([]byte, error)
• type Runner
  • func New(logger *zap.Logger, policyName string, policyDir string) Runner
  • func (r *Runner) Configure(c *config.Policy) error
  • func (r *Runner) FullReset(ctx context.Context) error
  • func (r *Runner) GetStatus() State
  • func (r *Runner) Start(ctx context.Context, cancelFunc context.CancelFunc) error
  • func (r *Runner) Stop(ctx context.Context) error
• type RunnerOutput
  • func (rs *RunnerOutput) Write(p []byte) (n int, err error)
• type State
• type Status

Variables

var MapStatus = map[Status]string{
	Unknown:     "unknown",
	Running:     "running",
	RunnerError: "runner_error",
	Offline:     "offline",
}

Functions

func GetCapabilities

func GetCapabilities() ([]byte, error)

Types

type Runner

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

func New

func New(logger *zap.Logger, policyName string, policyDir string) Runner

func (*Runner) Configure

func (r *Runner) Configure(c *config.Policy) error

func (*Runner) FullReset

func (r *Runner) FullReset(ctx context.Context) error

func (*Runner) GetStatus

func (r *Runner) GetStatus() State

func (*Runner) Start

func (r *Runner) Start(ctx context.Context, cancelFunc context.CancelFunc) error

func (*Runner) Stop

func (r *Runner) Stop(ctx context.Context) error

type RunnerOutput

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

func (*RunnerOutput) Write

func (rs *RunnerOutput) Write(p []byte) (n int, err error)

type State

type State struct {
	Status     Status `yaml:"-"`
	StatusText string `yaml:"status"`

	RestartCount  int64     `yaml:"restart_count"`
	LastLog       string    `yaml:"-"`
	LastError     string    `yaml:"last_error"`
	LastRestartTS time.Time `yaml:"last_restart_time"`
	// contains filtered or unexported fields
}

type Status

type Status int

const (
	Unknown Status = iota
	Running
	RunnerError
	Offline
)