worker

Documentation

Index

• Variables
• func IsErrFull(err error) bool
• type IMsg
• type IWorkerPool
• type MsgHandler

Variables

var ErrFull = errors.New("worker queue is full, make it larger in the config.")

Functions

func IsErrFull

func IsErrFull(err error) bool

Types

type IMsg

type IMsg interface {
	ID() uint64
	Headers() map[string]string
	Body() string
}

type IWorkerPool

type IWorkerPool interface {
	TryPut(task IMsg) error
	Start()
	Stop()
	AddHandler(msgType string, handler MsgHandler)
	DelHandler(msgType string)
}

type MsgHandler

type MsgHandler = func(msg IMsg) error