Merge pull request #2 from AVENTER-UG/dev

add: suppress offers if every service are running.

changelog.md

@@ -29,6 +29,7 @@
 - Add mesos-cli plugin
 - Mesos-CLI: Show all running M3s frameworks
 - Mesos-CLI: Get kubeconfig from a selected running m3s
+- Add supress offers if every services are running
 
 ## v0.0.4
 

mesos/mesos.go

@@ -112,6 +112,7 @@ func Subscribe() error {
 		case mesosproto.Event_HEARTBEAT:
 			// K3S API Server Heatbeat
 			K3SHeartbeat()
+			suppressFramework()
 		case mesosproto.Event_OFFERS:
 			restartFailedContainer()
 			logrus.Debug("Offer Got: ", event.Offers.Offers[0].GetID())
@@ -221,6 +222,20 @@ func restartFailedContainer() {
 	}
 }
 
+// if all Tasks are running, suppress framework offers
+func suppressFramework() {
+	if config.ETCDCount == config.ETCDMax &&
+		config.K3SServerCount == config.K3SServerMax &&
+		config.K3SAgentCount == config.K3SAgentMax {
+
+		logrus.Info("Framework Suppress")
+		suppress := &mesosproto.Call{
+			Type: mesosproto.Call_SUPPRESS,
+		}
+		Call(suppress)
+	}
+}
+
 /*
 	default:
 		// tell mesos he dont have to offer again until we ask