worker

Documentation

Index

• type Polling
• type PoolConfig
• type Process
• type Worker
  • func New(logger *logger.Logger, config *PoolConfig) (*Worker, error)
  • func (w *Worker) SendJob(ctx context.Context, message interface{})
  • func (w *Worker) Start() error
  • func (w *Worker) Stop()
  • func (w *Worker) WithPolling(polling Polling) *Worker
  • func (w *Worker) WithProcess(process Process) *Worker

Types

type Polling

type Polling func(ctx context.Context, idx int32) error

type PoolConfig

type PoolConfig struct {
	NumProcess     int32
	NumPolling     int32
	PollingBackoff time.Duration
}

type Process

type Process func(ctx context.Context, message interface{}) error

type Worker

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

func New

func New(logger *logger.Logger, config *PoolConfig) (*Worker, error)

func (*Worker) SendJob

func (w *Worker) SendJob(ctx context.Context, message interface{})

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop()

func (*Worker) WithPolling

func (w *Worker) WithPolling(polling Polling) *Worker

func (*Worker) WithProcess

func (w *Worker) WithProcess(process Process) *Worker