skeletal code

manager/manager.go

@@ -0,0 +1,30 @@
+package manager
+
+import (
+	"fmt"
+
+	"github.com/golang-collections/collections/queue"
+	"github.com/google/uuid"
+	"github.com/tork/task"
+)
+
+type Manager struct {
+	Pending       queue.Queue
+	TaskDB        map[string][]task.Task
+	EventDB       map[string][]task.TaskEvent
+	Workers       []string
+	WorkerTaskMap map[string][]uuid.UUID
+	TaskWorkerMap map[uuid.UUID]string
+}
+
+func (m *Manager) SelectWorker() {
+	fmt.Println("I will select an appropriate worker")
+}
+
+func (m *Manager) UpdateTasks() {
+	fmt.Println("I will update tasks")
+}
+
+func (m *Manager) SendWork() {
+	fmt.Println("I will send work to workers")
+}

node/node.go

@@ -0,0 +1,13 @@
+package node
+
+type Node struct {
+	Name            string
+	IP              string
+	Cores           int
+	Memory          int
+	MemoryAllocated int
+	Disk            int
+	DiskAllocated   int
+	Role            string
+	TaskCount       int
+}

scheduler/scheduler.go

@@ -0,0 +1,7 @@
+package scheduler
+
+type Scheduler interface {
+	SelectCandidateNodes()
+	Score()
+	Pick()
+}

worker/worker.go

@@ -1,6 +1,8 @@
 package worker
 
 import (
+	"fmt"
+
 	"github.com/golang-collections/collections/queue"
 	"github.com/google/uuid"
 	"github.com/tork/task"
@@ -9,6 +11,22 @@ import (
 type Worker struct {
 	Name      string
 	Queue     queue.Queue
-	Db        map[uuid.UUID]task.Task
+	DB        map[uuid.UUID]task.Task
 	TaskCount int
 }
+
+func (w *Worker) CollectStats() {
+	fmt.Println("I will collect stats")
+}
+
+func (w *Worker) RunTask() {
+	fmt.Println("I will start or stop a task")
+}
+
+func (w *Worker) StartTask() {
+	fmt.Println("I will start a task")
+}
+
+func (w *Worker) StopTask() {
+	fmt.Println("I will stop a task")
+}