worker

Documentation

Index

• Variables
• func NewPauseCmd() *cobra.Command
• func NewResumeCmd() *cobra.Command
• func NewRootCmd() *cobra.Command
• func NewRunCmd() *cobra.Command
• type Config
• type ConfigLog
• type ConfigRPC
• type ConfigUpstream

Variables

var ErrConfiguration = errors.New("configuration error")

var ErrRun = errors.New("run failed")

Functions

func NewPauseCmd

func NewPauseCmd() *cobra.Command

func NewResumeCmd

func NewResumeCmd() *cobra.Command

func NewRootCmd

func NewRootCmd() *cobra.Command

func NewRunCmd

func NewRunCmd() *cobra.Command

Types

type Config

type Config struct {
	Name  string `yaml:"name"`
	Token string `yaml:"token"`

	Labels    map[string]string  `yaml:"labels"`
	Resources map[string]float64 `yaml:"resources"`

	Log ConfigLog `yaml:"log"`

	RPC ConfigRPC `yaml:"rpc"`

	Upstreams []ConfigUpstream `yaml:"upstreams"`
}

type ConfigLog

type ConfigLog struct {
	Level        string `yaml:"level"`
	File         string `yaml:"file"`
	RotateSize   string `yaml:"rotate-size"`
	MaxRotations uint   `yaml:"max-rotations"`
}

type ConfigRPC

type ConfigRPC struct {
	Endpoint string `yaml:"endpoint"`
}

type ConfigUpstream

type ConfigUpstream struct {
	Token    string `yaml:"token"`
	Endpoint string `yaml:"endpoint"`
}