guvnor.go

package guvnor

import (
	"github.com/docker/docker/client"
	"github.com/go-playground/validator/v10"
	"github.com/krystal/guvnor/caddy"
	"github.com/krystal/guvnor/state"
	"go.uber.org/zap"
)

const (
	serviceLabel    = "io.k.guvnor.service"
	processLabel    = "io.k.guvnor.process"
	taskLabel       = "io.k.guvnor.task"
	deploymentLabel = "io.k.guvnor.deployment"
	managedLabel    = "io.k.guvnor.managed"
	portLabel       = "io.k.guvnor.port"
)

type Engine struct {
	log      *zap.Logger
	docker   client.APIClient
	config   EngineConfig
	caddy    *caddy.Manager
	state    *state.FileBasedStore
	validate *validator.Validate
}

func NewEngine(log *zap.Logger, docker client.APIClient, cfg EngineConfig, validate *validator.Validate) *Engine {
	if validate == nil {
		validate = validator.New()
	}
	if log == nil {
		log = zap.NewNop()
	}

	return &Engine{
		log:    log,
		docker: docker,
		config: cfg,
		caddy: &caddy.Manager{
			Docker: docker,
			Log:    log.Named("caddy"),
			Config: cfg.Caddy,
			ContainerLabels: map[string]string{
				managedLabel: "1",
			},
			CaddyConfigurator: caddy.NewAdminAPIClient(
				log.Named("caddy").Named("client"),
			),
		},
		validate: validate,
		state: &state.FileBasedStore{
			RootPath: cfg.Paths.State,
			Log:      log.Named("state"),
		},
	}
}