goseg/rectify/rectify.go

package rectify
// this package is for watching the event bus and rectifying mismatches
// between the desired and actual state

import (
	"fmt"
	"goseg/broadcast"
	"goseg/docker"
	"log/slog"
	"os"
)

var (
	logger = slog.New(slog.NewJSONHandler(os.Stdout, nil))
)

func HandleDockerEvents() {
	for {
		event := <-docker.EventBus
		switch event.Type {
		case "container_stopped":
			logger.Info(fmt.Sprintf("Docker event: container stopped"))
		default:
			logger.Info(fmt.Sprintf("Docker event: %s",event.Type))
		}
		broadcast.BroadcastToClients()
	}
}