worker

Documentation

Index

• Variables
• type DoWithCtx
• type ErrorHandler
• type IWorker
• type IWorkerMock
• type Job
  • func NewJob(do DoWithCtx, timeout time.Duration, eh ErrorHandler) *Job
• type Worker
  • func New(n int) *Worker
  • func (w *Worker) Push(job Job) error
  • func (w *Worker) Start()
  • func (w *Worker) Stop()
• type WorkerMock
  • func (mockRecv *WorkerMock) Push(job Job) error
  • func (mockRecv *WorkerMock) Start()
  • func (mockRecv *WorkerMock) Stop()
• type WorkerMockMock
  • func (mockRecv *WorkerMockMock) Push(job Job) error
  • func (mockRecv *WorkerMockMock) Start()
  • func (mockRecv *WorkerMockMock) Stop()

Variables

var (
	ErrWorkerIsStop = errors.New("Worker is stop")
	ErrNilJobDo     = errors.New("Job do field is nil")
)

错误

var DefaultWorker = New(defaultCount)

DefaultWorker 默认Wroker

Types

type DoWithCtx

type DoWithCtx func(ctx context.Context) error

type ErrorHandler

type ErrorHandler func(error)

ErrorHandler 错误处理方法

type IWorker

type IWorker interface {
	Push(job Job) error
	Start()
	Stop()
}

type IWorkerMock

type IWorkerMock interface {
	Push(job Job) error
	Start()
	Stop()
}

type Job

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

Job 工作

func NewJob

func NewJob(do DoWithCtx, timeout time.Duration, eh ErrorHandler) *Job

type Worker

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

Worker 工人

func New

func New(n int) *Worker

New 新建

func (*Worker) Push

func (w *Worker) Push(job Job) error

Push 添加

func (*Worker) Start

func (w *Worker) Start()

Start 开始

func (*Worker) Stop

func (w *Worker) Stop()

Stop 停止

type WorkerMock

type WorkerMock struct {
	PushFunc func(job Job) error

	StartFunc func()

	StopFunc func()
}

func (*WorkerMock) Push

func (mockRecv *WorkerMock) Push(job Job) error

func (*WorkerMock) Start

func (mockRecv *WorkerMock) Start()

func (*WorkerMock) Stop

func (mockRecv *WorkerMock) Stop()

type WorkerMockMock

type WorkerMockMock struct {
	PushFunc func(job Job) error

	StartFunc func()

	StopFunc func()
}

func (*WorkerMockMock) Push

func (mockRecv *WorkerMockMock) Push(job Job) error

func (*WorkerMockMock) Start

func (mockRecv *WorkerMockMock) Start()

func (*WorkerMockMock) Stop

func (mockRecv *WorkerMockMock) Stop()