Documentation
¶
Index ¶
- Constants
- func End(workerIP string) bool
- func Health(workerIP string) int
- func Map(workerIP string, m *rpc.MapInfo) bool
- func NewMaster(nWorker int, nReduce int) rpc.MasterServer
- func Reduce(workerIP string, m *rpc.ReduceInfo) bool
- func StartMaster(files []string, nWorker int, nReduce int, addr string)
- type FileInfo
- type IMDInfo
- type MapTaskInfo
- type Master
- type ReduceTaskInfo
- type WorkerInfo
Constants ¶
View Source
const ( TASK_IDLE int = iota TASK_INPROGRESS TASK_COMPLETED )
View Source
const ( WORKER_IDLE int = iota WORKER_BUSY WORKER_UNKNOWN )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MapTaskInfo ¶
type Master ¶
type Master struct { Workers []WorkerInfo MapTasks []MapTaskInfo ReduceTasks []ReduceTaskInfo rpc.UnimplementedMasterServer // contains filtered or unexported fields }
func (*Master) PeriodicHealthCheck ¶ added in v1.0.0
func (ms *Master) PeriodicHealthCheck()
func (*Master) UpdateIMDInfo ¶
func (*Master) WorkerRegister ¶
func (ms *Master) WorkerRegister(ctx context.Context, in *rpc.WorkerInfo) (*rpc.RegisterResult, error)
type ReduceTaskInfo ¶
func (*ReduceTaskInfo) SetState ¶ added in v1.0.0
func (mt *ReduceTaskInfo) SetState(state int)
type WorkerInfo ¶
type WorkerInfo struct { UUID string IP string WorkerState int // contains filtered or unexported fields }
func (*WorkerInfo) Broken ¶ added in v1.0.0
func (w *WorkerInfo) Broken() bool
func (*WorkerInfo) Health ¶ added in v1.0.0
func (w *WorkerInfo) Health() bool
func (*WorkerInfo) SetState ¶ added in v1.0.0
func (w *WorkerInfo) SetState(state int)
Click to show internal directories.
Click to hide internal directories.