Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct { APIServer *server.APIServer // Provides rpcs for other nodes in the cluster // contains filtered or unexported fields }
The Worker object represents
func NewWorker ¶
func NewWorker( ctx context.Context, env serviceenv.ServiceEnv, pachClient *client.APIClient, pipelineInfo *pps.PipelineInfo, rootPath string, ) (*Worker, error)
NewWorker constructs a Worker object that provides all worker functionality:
- a master goroutine that attempts to obtain the master lock for the pipeline workers and direct jobs
- a worker goroutine that gets tasks from the master and processes them
- an api server that serves requests for status or cross-worker communication
- a driver that provides common functionality between the above components
Click to show internal directories.
Click to hide internal directories.