master

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IDLE int = iota
	INPROGRESS
	COMPLETED
)

Variables

This section is empty.

Functions

func End 

func End(workerIP string) bool

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) 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
}

type WorkerInfo 

type WorkerInfo struct {
	UUID        string
	IP          string
	WorkerState int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.