master

type MapTask struct {
	Cid     cid.Cid
	Retries int
}

type Master struct {
	Node               *core.IpfsNode
	RpcClient          *gorpc.Client
	MapFuncFilePath    string
	ReduceFuncFilePath string
	MapFuncFileCid     string
	ReduceFuncFileCid  string
	NoOfReducers       int
	MrOutputFile       string
	DataFileCid        string
	DataFileBlocks     []string

	MapStatus        Status
	BlockProviders   map[string][]string // datafileblock to peerid providers
	MapAllocation    map[string]string   // datafileblock to peerid allocated for map
	RMapAllocation   map[string]string   // reverse of map allocation
	MapOutput        map[string][]string // datafileblock to list of NoOfReducers cids for map output files
	ReduceStatus     Status
	ReduceOutput     map[int]string
	ReduceAllocation map[int]string   // number to peerid
	ReduceFileMap    map[int][]string // number to list of cids as per map output
	// contains filtered or unexported fields
}

type ReduceTask struct {
	Index   int
	Retries int
}

type Status struct {
	Complete int
	Total    int
}