task

Documentation

Index

• Constants
• func Init(conf *conf.Conf)
• func Put(meta Meta, param Any, action func(*Task))
• func Wait(meta Meta, params []Any, action func(*Task, *Lock) error)
• func WaitN(meta Meta, n int, action func(*Task, *Lock) error)
• type Any
• type Lock
  • func (lock *Lock) Lock() func()
  • func (lock *Lock) Locks(cb func())
  • func (lock *Lock) RLock() func()
• type Meta
• type Pool
  • func New(conf *conf.Conf) *Pool
  • func (pool *Pool) Close()
  • func (pool *Pool) Put(meta Meta, params Any, action func(*Task))
  • func (pool *Pool) Wait(meta Meta, args []Any, action func(*Task, *Lock) error)
  • func (pool *Pool) WaitN(meta Meta, n int, action func(*Task, *Lock) error)
• type Task
  • func (task *Task) Context() context.Context
  • func (task *Task) Info() string
  • func (task *Task) Pool() *Pool
  • func (task *Task) Run(ctx context.Context)
  • func (task *Task) TaskId() int64
  • func (task *Task) WorkId() int64
• type Work
  • func (work *Work) Info() string
  • func (work *Work) Run(ctx context.Context)

Constants

const (
	StatusPrepare = iota
	StatusProcess
	StatusCancel
	StatusFinish
)

const POOL = "pool"

const TASK = "task"

const WORK = "work"

Functions

func Init

func Init(conf *conf.Conf)

func Put

func Put(meta Meta, param Any, action func(*Task))

func Wait

func Wait(meta Meta, params []Any, action func(*Task, *Lock) error)

func WaitN

func WaitN(meta Meta, n int, action func(*Task, *Lock) error)

Types

type Any

type Any = interface{}

type Lock

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

func (*Lock) Lock

func (lock *Lock) Lock() func()

func (*Lock) Locks

func (lock *Lock) Locks(cb func())

func (*Lock) RLock

func (lock *Lock) RLock() func()

type Meta

type Meta struct {
	Prefix   string
	FileLine string
}

type Pool

type Pool struct {
	Logger func(...Any)
	// contains filtered or unexported fields
}

func New

func New(conf *conf.Conf) *Pool

func (*Pool) Close

func (pool *Pool) Close()

func (*Pool) Put

func (pool *Pool) Put(meta Meta, params Any, action func(*Task))

func (*Pool) Wait

func (pool *Pool) Wait(meta Meta, args []Any, action func(*Task, *Lock) error)

func (*Pool) WaitN

func (pool *Pool) WaitN(meta Meta, n int, action func(*Task, *Lock) error)

type Task

type Task struct {
	Action func(*Task)
	Params Any
	Meta   Meta

	Error  Any
	Status int

	PrepareTime time.Time
	ProcessTime time.Time
	FinishTime  time.Time

	Logger func(...Any)
	// contains filtered or unexported fields
}

func (*Task) Context

func (task *Task) Context() context.Context

func (*Task) Info

func (task *Task) Info() string

func (*Task) Pool

func (task *Task) Pool() *Pool

func (*Task) Run

func (task *Task) Run(ctx context.Context)

func (*Task) TaskId

func (task *Task) TaskId() int64

func (*Task) WorkId

func (task *Task) WorkId() int64

type Work

type Work struct {
	Logger func(...Any)
	// contains filtered or unexported fields
}

func (*Work) Info

func (work *Work) Info() string

func (*Work) Run

func (work *Work) Run(ctx context.Context)