asyncworker

Documentation

Index

• Constants
• Variables
• type AsyncWorker
• type AsyncWorkerImpl
  • func NewAsyncWorkerImpl(bcName string, e common.Engine, baseDB kvdb.Database) (*AsyncWorkerImpl, error)
  • func (aw *AsyncWorkerImpl) RegisterHandler(contract string, event string, handler common.TaskHandler)
  • func (aw *AsyncWorkerImpl) Start() (err error)
  • func (aw *AsyncWorkerImpl) Stop()
• type TaskContextImpl
  • func (tc *TaskContextImpl) ParseArgs(v interface{}) error
  • func (tc *TaskContextImpl) RetryTimes() int

Constants

const (
	FinishTablePrefix = "FT"
)

Variables

var (
	// ErrRetry从TaskHandler返回指示这次任务应该被重试
	ErrRetry = errors.New("retry task")
)

var (
	UnmarshalFunc = json.Unmarshal
)

Types

type AsyncWorker

type AsyncWorker interface {
	RegisterHandler(contract string, event string, handler func(ctx common.TaskContext) error)
}

type AsyncWorkerImpl

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

func NewAsyncWorkerImpl

func NewAsyncWorkerImpl(bcName string, e common.Engine, baseDB kvdb.Database) (*AsyncWorkerImpl, error)

func (*AsyncWorkerImpl) RegisterHandler

func (aw *AsyncWorkerImpl) RegisterHandler(contract string, event string, handler common.TaskHandler)

func (*AsyncWorkerImpl) Start

func (aw *AsyncWorkerImpl) Start() (err error)

func (*AsyncWorkerImpl) Stop

func (aw *AsyncWorkerImpl) Stop()

type TaskContextImpl

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

func (*TaskContextImpl) ParseArgs

func (tc *TaskContextImpl) ParseArgs(v interface{}) error

func (*TaskContextImpl) RetryTimes

func (tc *TaskContextImpl) RetryTimes() int