master

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
  • func (ms *Master) PeriodicHealthCheck()
  • func (ms *Master) UpdateIMDInfo(ctx context.Context, in *rpc.IMDInfo) (*rpc.UpdateResult, error)
  • func (ms *Master) WorkerRegister(ctx context.Context, in *rpc.WorkerInfo) (*rpc.RegisterResult, error)
• type ReduceTaskInfo
  • func (mt *ReduceTaskInfo) SetState(state int)
• type WorkerInfo
  • func (w *WorkerInfo) Broken() bool
  • func (w *WorkerInfo) Health() bool
  • func (w *WorkerInfo) SetState(state int)

Constants

const (
	TASK_IDLE int = iota
	TASK_INPROGRESS
	TASK_COMPLETED
)

const (
	WORKER_IDLE int = iota
	WORKER_BUSY
	WORKER_UNKNOWN
)

Functions

func End

func End(workerIP string) bool

func Health

func Health(workerIP string) int

func Map

func Map(workerIP string, m *rpc.MapInfo) bool

func NewMaster

func NewMaster(nWorker int, nReduce int) rpc.MasterServer

func Reduce

func Reduce(workerIP string, m *rpc.ReduceInfo) bool

func StartMaster

func StartMaster(files []string, nWorker int, nReduce int, addr string)

Types

type FileInfo

type FileInfo struct {
	FileName string
	From     int
	To       int
}

type IMDInfo

type IMDInfo struct {
	IP       string
	FileName string
}

type MapTaskInfo

type MapTaskInfo struct {
	Files     []FileInfo
	TaskState int
	UUID      string
}

type Master

type Master struct {
	Workers     []WorkerInfo
	MapTasks    []MapTaskInfo
	ReduceTasks []ReduceTaskInfo

	rpc.UnimplementedMasterServer
	// contains filtered or unexported fields
}

func (*Master) PeriodicHealthCheck

func (ms *Master) PeriodicHealthCheck()

func (*Master) UpdateIMDInfo

func (ms *Master) UpdateIMDInfo(ctx context.Context, in *rpc.IMDInfo) (*rpc.UpdateResult, error)

func (*Master) WorkerRegister

func (ms *Master) WorkerRegister(ctx context.Context, in *rpc.WorkerInfo) (*rpc.RegisterResult, error)

type ReduceTaskInfo

type ReduceTaskInfo struct {
	IMDs      []IMDInfo
	TaskState int
	UUID      string
}

func (*ReduceTaskInfo) SetState

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

func (w *WorkerInfo) Broken() bool

func (*WorkerInfo) Health

func (w *WorkerInfo) Health() bool

func (*WorkerInfo) SetState

func (w *WorkerInfo) SetState(state int)