tasks

Documentation

Index

• Constants
• type ExecOptions
• type Tasks
  • func NewTasks() *Tasks
  • func (ts *Tasks) AddTask(t ...*task.Task)
  • func (ts *Tasks) CountPtid(ptid string) int64
  • func (ts *Tasks) Execute(options ExecOptions) error

Constants

const (
	STATUS_OK = iota
	STATUS_SKIP
	STATUS_ERROR
)

Types

type ExecOptions

type ExecOptions struct {
	Concurrency   uint
	SilentMainBar bool
	SilentSubBar  bool
	SkipError     bool
}

type Tasks

type Tasks struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTasks

func NewTasks() *Tasks

func (*Tasks) AddTask

func (ts *Tasks) AddTask(t ...*task.Task)

func (*Tasks) CountPtid

func (ts *Tasks) CountPtid(ptid string) int64

func (*Tasks) Execute

func (ts *Tasks) Execute(options ExecOptions) error

* Pull Image: [ERROR] * + host=10.0.0.1 image=opencurvedocker/curvefs 1/1 [OK] * + host=10.0.0.2 image=opencurvedocker/curvefs 1/2 [OK] * + host=10.0.0.3 image=opencurvedocker/curvefs 1/10 [ERROR] * + host=10.0.0.1 image=opencurvedocker/curvefs 10/10 [OK] * + host=10.0.0.2 image=opencurvedocker/curvefs 10/10 [OK] * + host=10.0.0.3 image=opencurvedocker/curvefs 1/10 [OK]