worker

Documentation

Index

• func HTTPInit()
• type Config
• type HTTPWorker
  • func (worker *HTTPWorker) NewWorker() Worker
  • func (worker *HTTPWorker) Work(job jobqueue.Job) *jobqueue.Result
• type Worker

Functions

func HTTPInit

func HTTPInit()

HTTPInit initializes global parameters of HTTP workers by configuration values.

Configuration keys prefixed by "dispatch_" are considered.

Types

type Config

type Config interface {
	NewWorker() Worker
}

Config is an interface of a builder of Worker.

type HTTPWorker

type HTTPWorker struct {
	UserAgent string
	Logger    *zerolog.Logger
}

HTTPWorker is a worker which handles a job as an HTTP POST request to the URL specified by the job.

func (*HTTPWorker) NewWorker

func (worker *HTTPWorker) NewWorker() Worker

NewWorker creates a new HTTP worker instance which inherits the configurations of the current one.

func (*HTTPWorker) Work

func (worker *HTTPWorker) Work(job jobqueue.Job) *jobqueue.Result

Work makes a POST request to job.URL and returns the result.

type Worker

type Worker interface {
	Work(job jobqueue.Job) *jobqueue.Result
}

Worker is an interface of a worker which handles a dispatched job.