tasktracer

Documentation

Index

• type TaskListener
  • func (tl *TaskListener) CloseChan()
  • func (tl *TaskListener) WaitFor(ctx context.Context, tid string) error
• type TaskTracer
  • func NewTaskTracer(redis *drivers.RedisPool, tracerchan string) *TaskTracer
  • func (tc *TaskTracer) FailTask(tid string, info string) bool
  • func (tc *TaskTracer) FinishTask(tid string) bool
  • func (tc *TaskTracer) NewListener(ctx context.Context) *TaskListener
  • func (tc *TaskTracer) NewTask(tid string) error
  • func (tc *TaskTracer) NewTaskByNum(tid string, tasknum uint) error
  • func (tc *TaskTracer) NewTaskGroup(params map[string]string, tasknum uint) (string, bool, error)
  • func (tc *TaskTracer) RemoveTaskGroup(tid string) error

Types

type TaskListener

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

func (*TaskListener) CloseChan

func (tl *TaskListener) CloseChan()

func (*TaskListener) WaitFor

func (tl *TaskListener) WaitFor(ctx context.Context, tid string) error

type TaskTracer

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

func NewTaskTracer

func NewTaskTracer(redis *drivers.RedisPool, tracerchan string) *TaskTracer

func (*TaskTracer) FailTask

func (tc *TaskTracer) FailTask(tid string, info string) bool

func (*TaskTracer) FinishTask

func (tc *TaskTracer) FinishTask(tid string) bool

func (*TaskTracer) NewListener

func (tc *TaskTracer) NewListener(ctx context.Context) *TaskListener

func (*TaskTracer) NewTask

func (tc *TaskTracer) NewTask(tid string) error

func (*TaskTracer) NewTaskByNum

func (tc *TaskTracer) NewTaskByNum(tid string, tasknum uint) error

func (*TaskTracer) NewTaskGroup

func (tc *TaskTracer) NewTaskGroup(params map[string]string, tasknum uint) (string, bool, error)

func (*TaskTracer) RemoveTaskGroup

func (tc *TaskTracer) RemoveTaskGroup(tid string) error