workers

Documentation

Overview

Package workers common structure for selina workers

Index

• Variables
• func ATProcessCancel(w selina.Worker) error
• func ATProcessCloseInput(w selina.Worker) error
• func ATProcessCloseOutput(w selina.Worker) error

Variables

var ErrNotTerminatedOnCloseInput = errors.New("not terminate on closed input")

ErrNotTerminatedOnCloseInput worker.Process does not finish when input channel is closed

var ErrOutputNotClosed = errors.New("output channel is not closed")

ErrOutputNotClosed worker.Process does not close output channel

var ErrProcessIgnoreCtx = errors.New("ignored context.Done")

ErrProcessIgnoreCtx worker.Process does not terminate when context is canceled

Functions

func ATProcessCancel

func ATProcessCancel(w selina.Worker) error

ATProcessCancel a worker must terminate and return context.Canceled when context is canceled

func ATProcessCloseInput

func ATProcessCloseInput(w selina.Worker) error

ATProcessCloseInput a worker must finish its job and return nil when input chanel (<-chan []byte )is closed

func ATProcessCloseOutput

func ATProcessCloseOutput(w selina.Worker) error

ATProcessCloseOutput a worker must close its output channel on exit