monitor

Documentation

Index

• Variables
• type DiscretWork
• type MonitoredWorker
  • func (mw *MonitoredWorker) GetId() string
  • func (mw *MonitoredWorker) GetProgress() model.DownloadProgress
  • func (mw *MonitoredWorker) GetState() State
  • func (mw *MonitoredWorker) ResetProgress()
  • func (mw *MonitoredWorker) Restart(ctx context.Context) error
  • func (mw *MonitoredWorker) Start(ctx context.Context) error
  • func (mw *MonitoredWorker) Stop(ctx context.Context) error
• type State
  • func (s State) Int() int
  • func (s State) String() string
• type WorkerPool
  • func NewWorkerPool() *WorkerPool
  • func (wp *WorkerPool) AfterComplete(fn func(context.Context) error)
  • func (wp *WorkerPool) AppendWork(iv *MonitoredWorker)
  • func (wp *WorkerPool) Completed() bool
  • func (wp *WorkerPool) GetAllProgress() []model.DownloadProgress
  • func (wp *WorkerPool) ResetAllProgress()
  • func (wp *WorkerPool) RestartAll() []error
  • func (wp *WorkerPool) StartAll() []error
  • func (wp *WorkerPool) State() State
  • func (wp *WorkerPool) StopAll() []error

Variables

var (
	ErrRunCompletedJob   = errors.New("error: try run completed job")
	ErrRunRunningJob     = errors.New("error: try run running job")
	ErrStopNonRunningJob = errors.New("error: imposible stop non running job")
	ErrContextCancelled  = errors.New("context cancelled")
)

var States = map[State]string{
	Stopped:   `Stopped`,
	Running:   `Running`,
	Failed:    `Failed`,
	Completed: `Completed`,
}

Types

type DiscretWork

type DiscretWork interface {
	DoWork(context.Context) (bool, error)
	GetProgress() model.DownloadProgress
	BeforeRun(context.Context) error
	AfterStop() error
	IsPartialDownload() bool
	ResetProgress()
}

type MonitoredWorker

type MonitoredWorker struct {
	Itw DiscretWork
	// contains filtered or unexported fields
}

func (*MonitoredWorker) GetId

func (mw *MonitoredWorker) GetId() string

func (*MonitoredWorker) GetProgress

func (mw *MonitoredWorker) GetProgress() model.DownloadProgress

func (*MonitoredWorker) GetState

func (mw *MonitoredWorker) GetState() State

func (*MonitoredWorker) ResetProgress

func (mw *MonitoredWorker) ResetProgress()

func (*MonitoredWorker) Restart

func (mw *MonitoredWorker) Restart(ctx context.Context) error

func (*MonitoredWorker) Start

func (mw *MonitoredWorker) Start(ctx context.Context) error

func (*MonitoredWorker) Stop

func (mw *MonitoredWorker) Stop(ctx context.Context) error

type State

type State int

const (
	Stopped State = iota
	Running
	Failed
	Completed
)

func (State) Int

func (s State) Int() int

func (State) String

func (s State) String() string

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool() *WorkerPool

func (*WorkerPool) AfterComplete

func (wp *WorkerPool) AfterComplete(fn func(context.Context) error)

func (*WorkerPool) AppendWork

func (wp *WorkerPool) AppendWork(iv *MonitoredWorker)

func (*WorkerPool) Completed

func (wp *WorkerPool) Completed() bool

func (*WorkerPool) GetAllProgress

func (wp *WorkerPool) GetAllProgress() []model.DownloadProgress

func (*WorkerPool) ResetAllProgress

func (wp *WorkerPool) ResetAllProgress()

func (*WorkerPool) RestartAll

func (wp *WorkerPool) RestartAll() []error

func (*WorkerPool) StartAll

func (wp *WorkerPool) StartAll() []error

func (*WorkerPool) State

func (wp *WorkerPool) State() State

func (*WorkerPool) StopAll

func (wp *WorkerPool) StopAll() []error