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")
	ErrClosed = errors.New("async handlers are closed")
)

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)
	QueueLen() int
}

type MsgHandler

type MsgHandler = func(msg IMsg) error