localworker

Documentation

Index

• Constants
• type Msg
  • func NewMsg(id uint64, headers map[string]string, body string) *Msg
  • func (m *Msg) Body() string
  • func (m *Msg) Headers() map[string]string
  • func (m *Msg) ID() uint64
• type WorkerPool
  • func NewWorkerPool(queueSize, sleep, workerCount int, logger *zap.SugaredLogger) *WorkerPool
  • func (wp *WorkerPool) AddHandler(msgType string, handler worker.MsgHandler)
  • func (wp *WorkerPool) DelHandler(msgType string)
  • func (wp *WorkerPool) QueueLen() int
  • func (wp *WorkerPool) Start()
  • func (wp *WorkerPool) Stop()
  • func (wp *WorkerPool) TryPut(task worker.IMsg) error

Constants

const (
	MsgTypeKey = "msg-type"
)

Types

type Msg

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

func NewMsg

func NewMsg(id uint64, headers map[string]string, body string) *Msg

func (*Msg) Body

func (m *Msg) Body() string

func (*Msg) Headers

func (m *Msg) Headers() map[string]string

func (*Msg) ID

func (m *Msg) ID() uint64

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool(queueSize, sleep, workerCount int, logger *zap.SugaredLogger) *WorkerPool

func (*WorkerPool) AddHandler

func (wp *WorkerPool) AddHandler(msgType string, handler worker.MsgHandler)

func (*WorkerPool) DelHandler

func (wp *WorkerPool) DelHandler(msgType string)

func (*WorkerPool) QueueLen

func (wp *WorkerPool) QueueLen() int

func (*WorkerPool) Start

func (wp *WorkerPool) Start()

func (*WorkerPool) Stop

func (wp *WorkerPool) Stop()

func (*WorkerPool) TryPut

func (wp *WorkerPool) TryPut(task worker.IMsg) error