Add top level Makefile for PAS repo

A top level Makefile with targets that can be used on each lower
level repo allows builds, tests and CI runs to be done across all
subprojects in this directory.

Co-authored-by: uniemimu <ukri.niemimuukko@intel.com>

Author: 2 people

Makefile

@@ -0,0 +1,9 @@
+TOPTARGETS := all clean image build test
+
+SUBDIRS := $(wildcard *-aware-scheduling/.)
+
+$(TOPTARGETS): $(SUBDIRS)
+$(SUBDIRS):
+	$(MAKE) -C $@ $(MAKECMDGOALS)
+
+.PHONY: $(TOPTARGETS) $(SUBDIRS)

extender/scheduler.go

@@ -1,4 +1,4 @@
-//Package extender extender logic contains code to respond call from the http endpoint.
+//Package extender contains types and logic to respond to requests from a Kubernetes http scheduler extender.
 package extender
 
 import (
@@ -90,13 +90,13 @@ func checkSymLinks(filename string) error {
 	return nil
 }
 
-// StartServer starts the HTTP server needed for extender.
+// StartServer starts the HTTP server needed for the scheduler extender.
 // It registers the handlers and checks for existing telemetry policies.
 func (m Server) StartServer(port string, certFile string, keyFile string, caFile string, unsafe bool) {
 	mx := http.NewServeMux()
 	mx.HandleFunc("/", handlerWithMiddleware(errorHandler))
-	mx.HandleFunc("/extender/prioritize", handlerWithMiddleware(m.Prioritize))
-	mx.HandleFunc("/extender/filter", handlerWithMiddleware(m.Filter))
+	mx.HandleFunc("/scheduler/prioritize", handlerWithMiddleware(m.Prioritize))
+	mx.HandleFunc("/scheduler/filter", handlerWithMiddleware(m.Filter))
 	var err error
 	if unsafe {
 		log.Printf("Extender Listening on HTTP  %v", port)

telemetry-aware-scheduling/cmd/main.go

@@ -32,7 +32,7 @@ func main() {
 	var kubeConfig, port, certFile, keyFile, caFile, syncPeriod string
 	var unsafe bool
 	flag.StringVar(&kubeConfig, "kubeConfig", "/root/.kube/config", "location of kubernetes config file")
-	flag.StringVar(&port, "port", "9001", "port on which the extender extender will listen")
+	flag.StringVar(&port, "port", "9001", "port on which the scheduler extender will listen")
 	flag.StringVar(&certFile, "cert", "/etc/kubernetes/pki/ca.crt", "cert file extender will use for authentication")
 	flag.StringVar(&keyFile, "key", "/etc/kubernetes/pki/ca.key", "key file extender will use for authentication")
 	flag.StringVar(&caFile, "cacert", "/etc/kubernetes/pki/ca.crt", "ca file extender will use for authentication")

telemetry-aware-scheduling/pkg/telemetryscheduler/scheduler_test.go

@@ -1,4 +1,4 @@
-//Logic for the scheduler extender - including the server it starts and prioritize + filter methods - is implemented in this package.
+//Tests for the scheduler extender - including the server it starts and prioritize + filter methods - is implemented in this package.
 package telemetryscheduler
 
 import (

telemetry-aware-scheduling/pkg/telemetryscheduler/telemetryscheduler.go

@@ -33,7 +33,7 @@ func NewMetricsExtender(newCache cache.Reader) MetricsExtender {
 	}
 }
 
-//Prioritize manages all prioritize requests from the extender extender.
+//Prioritize manages all prioritize requests from the scheduler extender.
 //It decodes the package, checks its policy, and performs error checking.
 //It then calls the prioritize logic and writes a response to the scheduler.
 func (m MetricsExtender) Prioritize(w http.ResponseWriter, r *http.Request) {