backup

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HandlerError = iota
	CommandStartError
	CommandFailedError
	CommandTimeoutError
	CommandKillError
)
View Source
const DEFAULT_TIMEOUT = time.Minute * 10
View Source
const UNKNOWN_TASK = "(unknown)"

Variables

This section is empty.

Functions

func IsTaskError

func IsTaskError(err error, code ...ErrorCode) bool

Types

type ErrorCode

type ErrorCode int

type Result

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

func NewResultFailed

func NewResultFailed(task *Task, err error, logs []string) Result

func NewResultSkipped

func NewResultSkipped(task *Task) Result

func NewResultSuccess

func NewResultSuccess(task *Task, logs []string) Result

func NewResultTimeout

func NewResultTimeout(task *Task, logs []string) Result

func (Result) ActualCwd

func (r Result) ActualCwd() string

func (Result) Command

func (r Result) Command() string

func (Result) Error

func (r Result) Error() error

func (Result) Logs

func (r Result) Logs() []string

func (Result) Name

func (r Result) Name() string

func (Result) Status

func (r Result) Status() Status

type Results

type Results []Result

func (Results) Len

func (r Results) Len() int

func (Results) Less

func (r Results) Less(i, j int) bool

func (Results) Swap

func (r Results) Swap(i, j int)

type Status

type Status string
const (
	StatusSkipped Status = "skipped"
	StatusSuccess Status = "success"
	StatusFailed  Status = "failed"
	StatusTimeout Status = "timeout"
)

func (Status) Priority

func (status Status) Priority() uint

type Task

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

func NewTask

func NewTask(name string, def config.Task) (*Task, error)

func (Task) ActualCwd

func (t Task) ActualCwd() string

func (Task) CommandString

func (t Task) CommandString() string

func (Task) Name

func (t Task) Name() string

func (Task) Run

func (t Task) Run(now time.Time) Result

func (Task) Timeout

func (t Task) Timeout() time.Duration

type TaskError

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

func NewTaskError

func NewTaskError(code ErrorCode, format string, previous error) *TaskError

func (TaskError) Code

func (e TaskError) Code() ErrorCode

func (TaskError) Error

func (e TaskError) Error() string

func (TaskError) Unwrap

func (e TaskError) Unwrap() error

type TaskInterface

type TaskInterface interface {
	Run(now time.Time) (result Result)
}

type TasksList

type TasksList []TaskInterface

func NewTasksList

func NewTasksList(tasks map[string]config.Task) (TasksList, error)

func (TasksList) Run

func (t TasksList) Run(now time.Time, parallel uint) Results

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL