worker

Documentation

Index

• type Done
• type UpstreamWorker
  • func New(workerCount int, f WorkFunc) *UpstreamWorker
  • func (u *UpstreamWorker) Do(uris []string) error
  • func (u *UpstreamWorker) Responses() []Done
• type WorkFunc

Types

type Done

type Done struct {
	URI      string
	Response *response.Response
}

Done is a message sent when an upstream worker has completed

type UpstreamWorker

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

UpstreamWorker manages parallel upstream requests

func New

func New(workerCount int, f WorkFunc) *UpstreamWorker

New UpstreamWorker

func (*UpstreamWorker) Do

func (u *UpstreamWorker) Do(uris []string) error

Do runs the worker with the given uris

func (*UpstreamWorker) Responses

func (u *UpstreamWorker) Responses() []Done

Responses returns the responses from the upstream calls

type WorkFunc

type WorkFunc func(uri string) (*response.Response, error)

WorkFunc defines a function which is called when work is to be done