Hands-On Software Engineering with Golang

Running a new job

After the end user starts the master's gRPC server, they can request a new job execution by invoking the master's RunJob method, the signature of which is as follows:

func (m *Master) RunJob(ctx context.Context, minWorkers int, workerAcquireTimeout time.Duration) error {
    // implementation omitted
}

Because the worker requirements generally vary depending on the algorithm to be executed, the end user must specify, in advance, the minimum number of workers required for the job as well as a timeout for acquiring the required workers.

If the number of workers is not important from the user's perspective, they can specify a zero value for the minWorkers argument. Doing so serves as a hint to the master to either select all workers ...