Task scheduler sends map intents to worker manager

main.go

@@ -42,7 +42,7 @@ func main() {
 	wm := workers.GetWorkerManager()
 	wm.Start()
 
-	ts := tasks.Start(taskRegistry)
+	ts := tasks.Start(taskRegistry, wm.MapTaskQueue)
 	ts.IntentQueue <- &newIntent
 
 	r := RegisterRoutes()

tasks/scheduler.go

@@ -17,7 +17,7 @@ type TaskScheduler struct {
 }
 
 // Start listening for intents originated by the API/scheduler
-func Start(taskRegistry map[string]TaskType) *TaskScheduler {
+func Start(taskRegistry map[string]TaskType, mapTaskQueue chan *Intent) *TaskScheduler {
 
 	// Create TaskScheduler
 	var ts = TaskScheduler{
@@ -38,6 +38,9 @@ func Start(taskRegistry map[string]TaskType) *TaskScheduler {
 				go ts.handleSetup(intent)
 			case "map":
 				fmt.Println("Map")
+				fmt.Println(mapTaskQueue)
+				mapTaskQueue <- intent
+				fmt.Println("qua")
 				// Handle map task
 			case "reduce":
 				fmt.Println("Reduce")

workers/manager.go

@@ -34,6 +34,7 @@ var wmSingleton = WorkerManager{
 	Workers:          make(map[string]Worker),
 	AvailableWorkers: make(chan Worker, 1024),
 	AllocatedWorkers: make(map[string][]Worker),
+	MapTaskQueue:     make(chan *tasks.Intent),
 	workersMutex:     sync.RWMutex{},
 	allocationMutex:  sync.RWMutex{},
 }