worker

Documentation

Overview

Package worker contains the core of the autodeb worker. It creates all dependencies injects them at the right place.

Index

• type Config
  • func ParseConfig(filepath string, fs filesystem.FS) (*Config, error)
• type Worker
  • func New(cfg *Config, loggingOutput io.Writer) (*Worker, error)
  • func (w *Worker) Shutdown() error

Types

type Config

type Config struct {
	ServerURL        string    `toml:"server_url"`
	AccessToken      string    `toml:"access_token"`
	WorkingDirectory string    `toml:"working_directory"`
	LogLevel         log.Level `toml:"log_level"`
	RunnerCount      int       `toml:"runner_count"`
}

Config contains configuration for Worker

func ParseConfig

func ParseConfig(filepath string, fs filesystem.FS) (*Config, error)

ParseConfig parses a configuration file to create a worker config

type Worker

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

Worker is the autodeb worker. It retrieves jobs from the main server and passes them to JobRunners that will execute them.

Workers are not safe for use by multiple goroutines.

func New

func New(cfg *Config, loggingOutput io.Writer) (*Worker, error)

New creates a Worker

func (*Worker) Shutdown

func (w *Worker) Shutdown() error

Shutdown stop the worker gracefully.