workerpoolhttp

Mar 21, 2022

Changes in this version

+ var OptsRequiredErr = errors.New("opts required")

+ type Job struct

+ Handler http.Handler

+ R *http.Request

+ W http.ResponseWriter

+ type Queue struct

+ func NewQueue(opts *QueueOptions) (*Queue, error)

+ func (q *Queue) AddJob(job *Job)

+ func (q *Queue) Close()

+ func (q *Queue) GetQueue() chan *Job

+ func (q *Queue) Handler(handler http.Handler) http.Handler

+ type QueueOptions struct

+ OverflowCode int

+ OverflowMsg proto.Message

+ OverflowMsgJson []byte

+ OverflowMsgProto []byte

+ QueueSize int

+ Timeout time.Duration

+ type Worker struct

+ func NewWorker(queue chan *Job) *Worker

+ func (w *Worker) Run()