feat: initial implementation

Signed-off-by: Andrew Rynhard <andrew@andrewrynhard.com>

Author: andrewrynhard

.gitignore

@@ -0,0 +1,2 @@
+hack/config/env.yaml
+talos-controller-manager

Dockerfile

@@ -0,0 +1,5 @@
+FROM scratch
+COPY --from=docker.io/autonomy/ca-certificates:febbf49 / /
+COPY --from=docker.io/autonomy/fhs:febbf49 / /
+COPY ./talos-controller-manager /talos-controller-manager
+ENTRYPOINT [ "/talos-controller-manager" ]

LICENSE

@@ -0,0 +1,21 @@
+all: manager container
+
+manager: generate
+	CGO_ENABLED=0 go build .
+
+.PHONY: generate
+generate: # Generate code.
+	controller-gen object:headerFile=./hack/boilerplate.go.txt paths="./..."
+
+container: # Build a container image.
+	docker build --tag docker.io/andrewrynhard/talos-controller-manager .
+
+.PHONY: manifests
+manifests: # Generate manifests e.g. CRD, RBAC etc.
+	controller-gen rbac:roleName=talos-controller-manager-role crd paths="./..." output:rbac:artifacts:config=hack/config/rbac output:crd:artifacts:config=hack/config/crd
+
+deploy: manifests # Deploy controller-manager to a cluster.
+	kubectl apply -k hack/config
+
+destroy: # Remove controller-manager from a cluster.
+	kubectl delete -k hack/config

Makefile

@@ -1 +1,47 @@
-# talos-operator
+# talos-controller-manager
+
+## Getting Started
+
+```bash
+kubectl label node -l node-role.kubernetes.io/master='' v1alpha1.upgrade.talos.dev/pool=serial-latest
+kubectl label node -l node-role.kubernetes.io/worker='' v1alpha1.upgrade.talos.dev/pool=concurrent-latest
+```
+
+```bash
+export TOKEN=<token>
+cat <<EOF >./hack/config/env.yaml
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: talos-controller-manager
+spec:
+  template:
+    spec:
+      containers:
+        - name: talos-controller-manager
+          env:
+            - name: TALOS_TOKEN
+              value: $TOKEN
+EOF
+```
+
+```bash
+make deploy
+```
+
+```bash
+kubectl get pods -n talos-system
+```
+
+```bash
+kubectl apply -f hack/config/examples/pool.yaml
+```
+
+```bash
+kubectl logs -n talos-system -f $(kubectl get lease -n talos-system talos-controller-manager -o jsonpath='{.spec.holderIdentity}')
+```
+
+## TODO
+
+- Upgrade window
+- Explicit version (takes precedence over `channel`)

README.md

@@ -0,0 +1,24 @@
+/*
+Copyright 2019 Talos Systems, Inc..
+*/
+
+// Package v1alpha1 contains API Schema definitions for the pool v1alpha1 API group
+// +kubebuilder:object:generate=true
+// +groupName=upgrade.talos.dev
+package v1alpha1
+
+import (
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"sigs.k8s.io/controller-runtime/pkg/scheme"
+)
+
+var (
+	// GroupVersion is group version used to register these objects
+	GroupVersion = schema.GroupVersion{Group: "upgrade.talos.dev", Version: "v1alpha1"}
+
+	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
+	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}
+
+	// AddToScheme adds the types in this group-version to the given scheme.
+	AddToScheme = SchemeBuilder.AddToScheme
+)

api/v1alpha1/groupversion_info.go

@@ -0,0 +1,56 @@
+/*
+Copyright 2019 Talos Systems, Inc..
+*/
+
+package v1alpha1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// NOTE: json tags are required.  Any new fields you add must have json tags for the fields to be serialized.
+
+// PoolSpec defines the desired state of Pool
+type PoolSpec struct {
+	Name          string           `json:"name,omitempty"`
+	Channel       string           `json:"channel,omitempty"`
+	Registry      string           `json:"registry,omitempty"`
+	Repository    string           `json:"repository,omitempty"`
+	Concurrency   int              `json:"concurrency,omitempty"`
+	FailurePolicy string           `json:"onFailure,omitempty"`
+	CheckInterval *metav1.Duration `json:"checkInterval,omitempty"`
+}
+
+// PoolStatus defines the observed state of Pool
+type PoolStatus struct {
+	Size       int    `json:"size,omitempty"`
+	InProgress string `json:"inProgess,omitempty"`
+}
+
+// +kubebuilder:object:root=true
+
+// Pool is the Schema for the pools API
+// +kubebuilder:printcolumn:name="Channel",type="string",JSONPath=".spec.channel",description="the pool's upgrade channel"
+// +kubebuilder:printcolumn:name="Size",type="integer",JSONPath=".status.size",description="the number of nodes in the pool"
+// +kubebuilder:printcolumn:name="Concurrency",type="string",JSONPath=".spec.concurrency",description="the pool's maximum number of concurrent upgrades"
+// +kubebuilder:printcolumn:name="In Progress",type="string",JSONPath=".status.inProgess",description="the nodes in the pool that are currently in progress of upgrading"
+type Pool struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec   PoolSpec   `json:"spec,omitempty"`
+	Status PoolStatus `json:"status,omitempty"`
+}
+
+// +kubebuilder:object:root=true
+
+// PoolList contains a list of Pool
+type PoolList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []Pool `json:"items"`
+}
+
+func init() {
+	SchemeBuilder.Register(&Pool{}, &PoolList{})
+}

api/v1alpha1/pool_types.go

@@ -0,0 +1,33 @@
+module github.com/talos-systems/talos-controller-manager
+
+go 1.13
+
+require (
+	github.com/blang/semver v3.5.0+incompatible
+	github.com/docker/distribution v2.7.1+incompatible
+	github.com/docker/go-metrics v0.0.1 // indirect
+	github.com/docker/libtrust v0.0.0-20160708172513-aabc10ec26b7 // indirect
+	github.com/go-logr/logr v0.1.0
+	github.com/golang/groupcache v0.0.0-20191027212112-611e8accdfc9 // indirect
+	github.com/gorilla/mux v1.7.3 // indirect
+	github.com/hashicorp/go-multierror v1.0.0
+	github.com/hashicorp/golang-lru v0.5.3 // indirect
+	github.com/imdario/mergo v0.3.8 // indirect
+	github.com/kubernetes-incubator/bootkube v0.14.1-0.20190731222813-f0fc1bdb404d // indirect
+	github.com/onsi/ginkgo v1.10.1
+	github.com/onsi/gomega v1.7.0
+	github.com/opencontainers/go-digest v1.0.0-rc1
+	github.com/pkg/errors v0.8.1
+	github.com/prometheus/client_golang v1.2.1 // indirect
+	github.com/talos-systems/talos v0.3.0-alpha.9.0.20191129203523-ad2f2574d7e7
+	golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e
+	golang.org/x/time v0.0.0-20191024005414-555d28b269f0 // indirect
+	golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898 // indirect
+	google.golang.org/appengine v1.6.5 // indirect
+	google.golang.org/grpc v1.25.1
+	k8s.io/api v0.0.0-20191109101513-0171b7c15da1
+	k8s.io/apiextensions-apiserver v0.0.0-20191108071732-08c66a398f44 // indirect
+	k8s.io/apimachinery v0.0.0-20191111054156-6eb29fdf75dc
+	k8s.io/client-go v0.0.0-20191108070106-f8f007fd456c
+	sigs.k8s.io/controller-runtime v0.3.1-0.20191105233659-81842d0e78f7
+)