akeleton config and launch template

internal/config/config.go

@@ -0,0 +1,38 @@
+package config
+
+import (
+	"errors"
+	"fmt"
+	"time"
+
+	"github.com/jinzhu/configor"
+)
+
+type Config = struct {
+	LogLevel              string `default:"Info" env:"WOODPECKER_AUTOSCALER_LOGLEVEL"`
+	CheckInterval         int    `default:"15" env:"WOODPECKER_AUTOSCALER_CHECK_INTERVAL"`
+	LabelSelector         string `default:"uploadfilter24.eu/instance-role=Woodpecker" env:"WOODPECKER_AUTOSCALER_LABELSELECTOR"`
+	WoodpeckerInstance    string `default:"" env:"WOODPECKER_AUTOSCALER_WOODPECKER_INSTANCE"`
+	WoodpeckerAgentSecret string `default:"" env:"WOODPECKER_AUTOSCALER_WOODPECKER_AGENT_SECRET"`
+	Protocol              string `default:"http" env:"WOODPECKER_AUTOSCALER_PROTOCOL"`
+	HcloudToken           string `default:"" env:"WOODPECKER_AUTOSCALER_HCLOUD_TOKEN"`
+	InstanceType          string `default:"" env:"WOODPECKER_AUTOSCALER_INSTANCE_TYPE"`
+	Zone                  string `default:"" env:"WOODPECKER_AUTOSCALER_ZONE"`
+	DryRun                bool   `default:"false" env:"WOODPECKER_AUTOSCALER_DRY_RUN"`
+	SSHKey                string `default:"" env:"WOODPECKER_AUTOSCALER_SSH_KEY"`
+}
+
+func GenConfig() (cfg *Config, err error) {
+
+	cfg = &Config{}
+
+	err = configor.New(&configor.Config{
+		ENVPrefix:          "WOODPECKER_AUTOSCALER",
+		AutoReload:         true,
+		Silent:             true,
+		AutoReloadInterval: time.Minute}).Load(cfg, "config.json")
+	if err != nil {
+		return nil, errors.New(fmt.Sprintf("Error generating Config: %s", err.Error()))
+	}
+	return cfg, nil
+}

internal/health/healthcheck.go

@@ -0,0 +1,31 @@
+package health
+
+import (
+	"fmt"
+	"net/http"
+
+	"github.com/gorilla/mux"
+	log "github.com/sirupsen/logrus"
+)
+
+func StartHealthEndpoint() {
+	r := mux.NewRouter()
+	r.Use(mux.CORSMethodMiddleware(r))
+	r.HandleFunc("/health", send200).Methods(http.MethodGet)
+	err := http.ListenAndServe("0.0.0.0:8080", r)
+	if err != nil {
+		log.WithFields(log.Fields{
+			"Caller": "StartHealthEndpoint",
+		}).Error(fmt.Sprintf("Error creating health endpoint: %s", err.Error()))
+	}
+}
+
+func send200(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusOK)
+	_, err := w.Write([]byte{})
+	if err != nil {
+		log.WithFields(log.Fields{
+			"Caller": "send200",
+		}).Error(fmt.Sprintf("Error answering health endpoint: %s", err.Error()))
+	}
+}

internal/hetzner/hetzneragent.go

@@ -0,0 +1,55 @@
+package hetzner
+
+import (
+	"os"
+	"text/template"
+
+	"git.uploadfilter24.eu/covidnetes/woodpecker-autoscaler/internal/config"
+)
+
+var USER_DATA_TEMPLATE = `
+write_files:
+- content: |
+    # docker-compose.yml
+    version: '3'
+
+    services:
+
+      woodpecker-agent:
+        image: {{ .Image }}
+        command: agent
+        restart: always
+        volumes:
+          - /var/run/docker.sock:/var/run/docker.sock
+        environment:
+		{{- range $key, $val := .EnvConfig }}
+			- {{ $key }}: {{ $val }}
+	  	{{- end }}
+  path: /root/docker-compose.yml
+runcmd:
+- [ sh, -xc, "cd /root; docker run --rm --privileged multiarch/qemu-user-static --reset -p yes; docker compose up -d" ]
+`
+
+type UserDataConfig struct {
+	Image     string
+	EnvConfig map[string]string
+}
+
+func generateConfig(cfg *config.Config) {
+	envConfig := map[string]string{}
+	envConfig["WOODPECKER_SERVER"] = cfg.WoodpeckerInstance
+	envConfig["WOODPECKER_AGENT_SECRET"] = cfg.WoodpeckerAgentSecret
+	envConfig["WOODPECKER_FILTER_LABELS"] = cfg.LabelSelector
+	config := UserDataConfig{
+		Image:     "woodpeckerci/woodpecker-agent:latest",
+		EnvConfig: envConfig,
+	}
+	tmpl, err := template.New("test").Parse(USER_DATA_TEMPLATE)
+	if err != nil {
+		panic(err)
+	}
+	err = tmpl.Execute(os.Stdout, config)
+	if err != nil {
+		panic(err)
+	}
+}

internal/logging/logging.go

@@ -0,0 +1,28 @@
+package logging
+
+import (
+	"os"
+
+	"git.uploadfilter24.eu/covidnetes/woodpecker-autoscaler/internal/config"
+	log "github.com/sirupsen/logrus"
+)
+
+func ConfigureLogger(cfg *config.Config) {
+
+	switch cfg.LogLevel {
+	case "Debug":
+		log.SetLevel(log.DebugLevel)
+	case "Info":
+		log.SetLevel(log.InfoLevel)
+	case "Warn":
+		log.SetLevel(log.WarnLevel)
+	case "Error":
+		log.SetLevel(log.ErrorLevel)
+	default:
+		log.SetLevel(log.InfoLevel)
+		log.Warnf("Home: invalid log level supplied: '%s'", cfg.LogLevel)
+	}
+
+	log.SetFormatter(&log.JSONFormatter{})
+	log.SetOutput(os.Stdout)
+}

internal/woodpecker/metrics.go

@@ -0,0 +1,7 @@
+package woodpecker
+
+import "git.uploadfilter24.eu/covidnetes/woodpecker-autoscaler/internal/config"
+
+func GetPendingJobs(cfg *config.Config) {
+
+}