gotask

Documentation

Index

• type Handler
• type TaskCron
  • func New(client *clientv3.Client, prefix string) *TaskCron
  • func (tc *TaskCron) Add(spec, key, value string, taskTimeout int, handler Handler) (err error)
  • func (tc *TaskCron) Close()
  • func (tc *TaskCron) Remove(key, value string) error
  • func (tc *TaskCron) UpdateTime(key, value, spec string) error

Types

type Handler

type Handler func(key string, value interface{})

type TaskCron

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

func New

func New(client *clientv3.Client, prefix string) *TaskCron

func (*TaskCron) Add

func (tc *TaskCron) Add(spec, key, value string, taskTimeout int, handler Handler) (err error)

func (*TaskCron) Close

func (tc *TaskCron) Close()

func (*TaskCron) Remove

func (tc *TaskCron) Remove(key, value string) error

func (*TaskCron) UpdateTime

func (tc *TaskCron) UpdateTime(key, value, spec string) error