runner

Documentation

Index

• Constants
• type ErrorHandlerTask
  • func NewErrorHandlerTask(runner *TaskRunner, errorHandler func(te *TaskError)) *ErrorHandlerTask
  • func (e *ErrorHandlerTask) Name() string
  • func (e *ErrorHandlerTask) Start() error
  • func (e *ErrorHandlerTask) Stop() error
• type StartTask
  • func (e *StartTask) Name() string
  • func (e *StartTask) Start() error
  • func (e *StartTask) Stop() error
• type Task
• type TaskError
• type TaskRunner
  • func NewRunner() *TaskRunner
  • func (tr *TaskRunner) AddErrorHandler(errorHandler func(te *TaskError))
  • func (tr *TaskRunner) AddTask(task Task)
  • func (tr *TaskRunner) Shutdown()
  • func (tr *TaskRunner) Start()
  • func (tr *TaskRunner) StartAndWait()
  • func (tr *TaskRunner) Wait() error

Constants

const MaximumPendingTasks = 1000

Types

type ErrorHandlerTask

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

func NewErrorHandlerTask

func NewErrorHandlerTask(runner *TaskRunner, errorHandler func(te *TaskError)) *ErrorHandlerTask

func (*ErrorHandlerTask) Name

func (e *ErrorHandlerTask) Name() string

func (*ErrorHandlerTask) Start

func (e *ErrorHandlerTask) Start() error

func (*ErrorHandlerTask) Stop

func (e *ErrorHandlerTask) Stop() error

type StartTask

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

func (*StartTask) Name

func (e *StartTask) Name() string

func (*StartTask) Start

func (e *StartTask) Start() error

func (*StartTask) Stop

func (e *StartTask) Stop() error

type Task

type Task interface {
	Name() string
	Start() error
	Stop() error
}

type TaskError

type TaskError struct {
	Task *Task
	Err  error
}

type TaskRunner

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

func NewRunner

func NewRunner() *TaskRunner

func (*TaskRunner) AddErrorHandler

func (tr *TaskRunner) AddErrorHandler(errorHandler func(te *TaskError))

func (*TaskRunner) AddTask

func (tr *TaskRunner) AddTask(task Task)

func (*TaskRunner) Shutdown

func (tr *TaskRunner) Shutdown()

func (*TaskRunner) Start

func (tr *TaskRunner) Start()

func (*TaskRunner) StartAndWait

func (tr *TaskRunner) StartAndWait()

func (*TaskRunner) Wait

func (tr *TaskRunner) Wait() error