Hands-On Software Engineering with Golang

The master job coordinator

In this section, we will explore the implementation of the job coordinator component that is responsible for orchestrating the execution of a distributed graph computation job on the master node.

In a similar fashion to how the worker job coordinator was implemented, we will start by defining a configuration struct to hold the necessary details for creating a new coordinator instance and then proceed to define the masterJobCoordinator type:

type masterJobCoordinatorConfig struct {
    jobDetails job.Details
    workers    []*remoteWorkerStream
    jobRunner  job.Runner
    serializer Serializer
    logger     *logrus.Entry
}

type masterJobCoordinator struct {
    jobCtx       context.Context
    cancelJobCtx func() barrier *masterStepBarrier partRange ...