xworker

Documentation

Index

• func InitPool() (topErr error)
• type ConsumerFunc
• type WorkerBasic
  • func NewWorker(c ...ConsumerFunc) *WorkerBasic
  • func (w *WorkerBasic) RegisterWorker(c ...ConsumerFunc)
  • func (w *WorkerBasic) Run() error
  • func (w *WorkerBasic) Stop() error

Functions

func InitPool

func InitPool() (topErr error)

Types

type ConsumerFunc

type ConsumerFunc interface {
	Serve(context.Context) error
	GetName() string
	Init()
}

type WorkerBasic

type WorkerBasic struct {
	CancelFunc context.CancelFunc
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(c ...ConsumerFunc) *WorkerBasic

func (*WorkerBasic) RegisterWorker

func (w *WorkerBasic) RegisterWorker(c ...ConsumerFunc)

func (*WorkerBasic) Run

func (w *WorkerBasic) Run() error

func (*WorkerBasic) Stop

func (w *WorkerBasic) Stop() error