taskd

Documentation

Index

• Constants
• Variables
• func HasTask(taskID string) bool
• func Submit(cfg *task.Cfg) (*task.Task, error)
• func SubmitAndWait(cfg *task.Cfg) (*task.Task, error)
• func TrySubmit(cfg *task.Cfg) (*task.Task, bool, error)
• type Cfg
  • func NewCfg() *Cfg
• type Taskd
  • func New() *Taskd
  • func (td *Taskd) GetCfg() interface{}
  • func (td *Taskd) HasTask(taskID string) bool
  • func (td *Taskd) Init() error
  • func (td *Taskd) Start() error
  • func (td *Taskd) Stop() error
  • func (td *Taskd) Submit(taskCfg *task.Cfg) (*task.Task, error)
  • func (td *Taskd) SubmitAndWait(taskCfg *task.Cfg) (*task.Task, error)
  • func (td *Taskd) TrySubmit(taskCfg *task.Cfg) (*task.Task, bool, error)
  • func (td *Taskd) Type() interface{}

Constants

const (
	DefaultPoolSize  = 5
	DefaultQueueSize = 1024
)

const DaemonTypeTaskd boot.DaemonType = "taskd"

Variables

var (
	ErrStopping          = errors.New("stopping, reject")
	ErrTaskAlreadyExists = errors.New("task already exists")
)

Functions

func HasTask

func HasTask(taskID string) bool

func Submit

func Submit(cfg *task.Cfg) (*task.Task, error)

func SubmitAndWait

func SubmitAndWait(cfg *task.Cfg) (*task.Task, error)

func TrySubmit

func TrySubmit(cfg *task.Cfg) (*task.Task, bool, error)

Types

type Cfg

type Cfg struct {
	PoolSize  int `env:"TASK_POOL_SIZE"  flag-long:"task-pool-size"  yaml:"poolSize"  flag-description:"max number of workers in task pool"`
	QueueSize int `env:"TASK_QUEUE_SIZE" flag-long:"task-queue-size" yaml:"queueSize" flag-description:"max size of buffered task queue"`
}

func NewCfg

func NewCfg() *Cfg

type Taskd

type Taskd struct {
	runner.Runner
	*Cfg
	// contains filtered or unexported fields
}

func New

func New() *Taskd

func (*Taskd) GetCfg

func (td *Taskd) GetCfg() interface{}

func (*Taskd) HasTask

func (td *Taskd) HasTask(taskID string) bool

func (*Taskd) Init

func (td *Taskd) Init() error

func (*Taskd) Start

func (td *Taskd) Start() error

func (*Taskd) Stop

func (td *Taskd) Stop() error

func (*Taskd) Submit

func (td *Taskd) Submit(taskCfg *task.Cfg) (*task.Task, error)

func (*Taskd) SubmitAndWait

func (td *Taskd) SubmitAndWait(taskCfg *task.Cfg) (*task.Task, error)

func (*Taskd) TrySubmit

func (td *Taskd) TrySubmit(taskCfg *task.Cfg) (*task.Task, bool, error)

func (*Taskd) Type

func (td *Taskd) Type() interface{}