unkin-agent
9da206dc7c
PVCs and CloudNativePG Clusters need S3 buckets and backup schedules
provisioned consistently. This operator watches the
backups.unkin.net/{schedule,destination} annotations on those objects and
provisions everything needed to back them up, with no new CRDs.
- Add a PVC controller that provisions cephrgw ObjectStoreUser/Bucket/BucketAccess,
auto-generates a restic repo-password Secret and creates a k8up Schedule scoped
to the PVC via spec.backup.volumes[].persistentVolumeClaim.claimName.
- Add a CNPG Cluster controller that provisions the same bucket stack, idempotently
patches spec.backup.barmanObjectStore (leaving a user-set destinationPath alone
with a Warning event) and creates a ScheduledBackup.
- Resolve destinations through a ConfigMap lookup table; requeue until the
BucketAccess is Ready before creating schedule resources; own-reference created
resources and retain bucket data by default.
- Add schedule-mapping helpers (k8up 5-field/shortcut pass-through, CNPG 6-field
seconds-first) and deterministic, length-bounded name derivation.
- Add unit tests (schedule mapping, name derivation, destination resolution) and
envtest controller tests for both paths, wiring the external CRDs into envtest.
- Add kubebuilder-generated RBAC, a Dockerfile (distroless/nonroot), Woodpecker
lint/test/build pipelines and a tag-triggered image push to the artifactapi
docker-internal registry, plus a version-bump Makefile and deploy manifests.
51 lines
1.4 KiB
Go
51 lines
1.4 KiB
Go
package restful
|
|
|
|
import (
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
type mime struct {
|
|
media string
|
|
quality float64
|
|
}
|
|
|
|
// insertMime adds a mime to a list and keeps it sorted by quality.
|
|
func insertMime(l []mime, e mime) []mime {
|
|
for i, each := range l {
|
|
// if current mime has lower quality then insert before
|
|
if e.quality > each.quality {
|
|
left := append([]mime{}, l[0:i]...)
|
|
return append(append(left, e), l[i:]...)
|
|
}
|
|
}
|
|
return append(l, e)
|
|
}
|
|
|
|
const qFactorWeightingKey = "q"
|
|
|
|
// sortedMimes returns a list of mime sorted (desc) by its specified quality.
|
|
// e.g. text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3
|
|
func sortedMimes(accept string) (sorted []mime) {
|
|
for _, each := range strings.Split(accept, ",") {
|
|
typeAndQuality := strings.Split(strings.Trim(each, " "), ";")
|
|
if len(typeAndQuality) == 1 {
|
|
sorted = insertMime(sorted, mime{typeAndQuality[0], 1.0})
|
|
} else {
|
|
// take factor
|
|
qAndWeight := strings.Split(typeAndQuality[1], "=")
|
|
if len(qAndWeight) == 2 && strings.Trim(qAndWeight[0], " ") == qFactorWeightingKey {
|
|
f, err := strconv.ParseFloat(qAndWeight[1], 64)
|
|
if err != nil {
|
|
traceLogger.Printf("unable to parse quality in %s, %v", each, err)
|
|
} else {
|
|
sorted = insertMime(sorted, mime{typeAndQuality[0], f})
|
|
}
|
|
} else {
|
|
sorted = insertMime(sorted, mime{typeAndQuality[0], 1.0})
|
|
}
|
|
}
|
|
}
|
|
return
|
|
}
|