worker

README

worker

Пакет worker реализует воркера в системе распределённой сборки. Воркер ходит с heartbeat-ами к координатору, получает с него джобы, выполняет их и посылает результаты назад на координатор.

Основная функциональность воркера тестируется интеграционными тестами из пакета disttest.

Documentation

Index

• type Worker
  • func New(workerID api.WorkerID, coordinatorEndpoint string, log *zap.Logger, ...) *Worker
  • func (w *Worker) Run(ctx context.Context) error
  • func (w *Worker) ServeHTTP(rw http.ResponseWriter, r *http.Request)

Types

type Worker

type Worker struct {
}

func New

func New(
	workerID api.WorkerID,
	coordinatorEndpoint string,
	log *zap.Logger,
	fileCache *filecache.Cache,
	artifacts *artifact.Cache,
) *Worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error

func (*Worker) ServeHTTP

func (w *Worker) ServeHTTP(rw http.ResponseWriter, r *http.Request)