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.
91 lines
2.8 KiB
Go
91 lines
2.8 KiB
Go
// Copyright (c) Faye Amacker. All rights reserved.
|
|
// Licensed under the MIT License. See LICENSE in the project root for license information.
|
|
|
|
package cbor
|
|
|
|
import (
|
|
"errors"
|
|
)
|
|
|
|
// ByteString represents CBOR byte string (major type 2). ByteString can be used
|
|
// when using a Go []byte is not possible or convenient. For example, Go doesn't
|
|
// allow []byte as map key, so ByteString can be used to support data formats
|
|
// having CBOR map with byte string keys. ByteString can also be used to
|
|
// encode invalid UTF-8 string as CBOR byte string.
|
|
// See DecOption.MapKeyByteStringMode for more details.
|
|
type ByteString string
|
|
|
|
// Bytes returns bytes representing ByteString.
|
|
func (bs ByteString) Bytes() []byte {
|
|
return []byte(bs)
|
|
}
|
|
|
|
// MarshalCBOR encodes ByteString as CBOR byte string (major type 2).
|
|
func (bs ByteString) MarshalCBOR() ([]byte, error) {
|
|
e := getEncodeBuffer()
|
|
defer putEncodeBuffer(e)
|
|
|
|
// Encode length
|
|
encodeHead(e, byte(cborTypeByteString), uint64(len(bs)))
|
|
|
|
// Encode data
|
|
buf := make([]byte, e.Len()+len(bs))
|
|
n := copy(buf, e.Bytes())
|
|
copy(buf[n:], bs)
|
|
|
|
return buf, nil
|
|
}
|
|
|
|
// UnmarshalCBOR decodes CBOR byte string (major type 2) to ByteString.
|
|
// Decoding CBOR null and CBOR undefined sets ByteString to be empty.
|
|
//
|
|
// Deprecated: No longer used by this codec; kept for compatibility
|
|
// with user apps that directly call this function.
|
|
func (bs *ByteString) UnmarshalCBOR(data []byte) error {
|
|
if bs == nil {
|
|
return errors.New("cbor.ByteString: UnmarshalCBOR on nil pointer")
|
|
}
|
|
|
|
d := decoder{data: data, dm: defaultDecMode}
|
|
|
|
// Check well-formedness of CBOR data item.
|
|
// ByteString.UnmarshalCBOR() is exported, so
|
|
// the codec needs to support same behavior for:
|
|
// - Unmarshal(data, *ByteString)
|
|
// - ByteString.UnmarshalCBOR(data)
|
|
err := d.wellformed(false, false)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return bs.unmarshalCBOR(data)
|
|
}
|
|
|
|
// unmarshalCBOR decodes CBOR byte string (major type 2) to ByteString.
|
|
// Decoding CBOR null and CBOR undefined sets ByteString to be empty.
|
|
// This function assumes data is well-formed, and does not perform bounds checking.
|
|
// This function is called by Unmarshal().
|
|
func (bs *ByteString) unmarshalCBOR(data []byte) error {
|
|
if bs == nil {
|
|
return errors.New("cbor.ByteString: UnmarshalCBOR on nil pointer")
|
|
}
|
|
|
|
// Decoding CBOR null and CBOR undefined to ByteString resets data.
|
|
// This behavior is similar to decoding CBOR null and CBOR undefined to []byte.
|
|
if len(data) == 1 && (data[0] == 0xf6 || data[0] == 0xf7) {
|
|
*bs = ""
|
|
return nil
|
|
}
|
|
|
|
d := decoder{data: data, dm: defaultDecMode}
|
|
|
|
// Check if CBOR data type is byte string
|
|
if typ := d.nextCBORType(); typ != cborTypeByteString {
|
|
return &UnmarshalTypeError{CBORType: typ.String(), GoType: typeByteString.String()}
|
|
}
|
|
|
|
b, _ := d.parseByteString()
|
|
*bs = ByteString(b)
|
|
return nil
|
|
}
|