worker

Documentation

Index

• type Rely
• type Worker
  • func New(id int64, rely Rely) *Worker
  • func (w *Worker) Serve()
• type Writer
  • func (w *Writer) Write(p []byte) (n int, err error)

Types

type Rely

type Rely interface {
	Context() context.Context
	GetChannel() <-chan *db.Task
	DeleteWorker(*Worker)
	WorkerStatus(w *Worker, str string)
	ExitWithError(e error)
	WriteStatus(n int64, net bool)
	Block() utils.Size
	Finish() <-chan struct{}

	GetRequest() (req *http.Request, e error)
	Do(req *http.Request) (resp *http.Response, e error)
}

type Worker

type Worker struct {
	ID int64
	// contains filtered or unexported fields
}

func New

func New(id int64, rely Rely) *Worker

func (*Worker) Serve

func (w *Worker) Serve()

type Writer

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

func (*Writer) Write

func (w *Writer) Write(p []byte) (n int, err error)