task

Documentation

Index

• type SimpleWorkerTask
• type Task
  • func NewTask(url, request string, wait bool) *Task
  • func (t *Task) IsSyncRequest() bool
  • func (t *Task) PostProcess()
  • func (t *Task) Receive(client *http.Client) int
  • func (t *Task) String() string
• type WorkerTask

Types

type SimpleWorkerTask

type SimpleWorkerTask struct {
	Task
}

SimpleWorkerTask - Just a simple http get

type Task

type Task struct {
	ID      int
	URL     string
	Request string // GET, POST, ...

	Response []byte // response
	// contains filtered or unexported fields
}

Task - describes the task a worker has to execute

func NewTask

func NewTask(url, request string, wait bool) *Task

NewTask -

func (*Task) IsSyncRequest

func (t *Task) IsSyncRequest() bool

IsSyncRequest -

func (*Task) PostProcess

func (t *Task) PostProcess()

PostProcess -

func (*Task) Receive

func (t *Task) Receive(client *http.Client) int

Receive -

func (*Task) String

func (t *Task) String() string

type WorkerTask

type WorkerTask interface {
	Receive(client *http.Client) int // receive http request
	PostProcess()                    // process received request if sync request
	IsSyncRequest() bool
}

WorkerTask -