mirror of
https://github.com/cloudnative-pg/plugin-barman-cloud.git
synced 2026-01-12 05:33:11 +01:00
13e3fab268
This patch enables the barman-cloud plugin to function with an operator that is structurally identical to CNPG but works with a different API group. It achieves this through lenient decoding of the provided CNPG resources and injecting the detected GVK into the sidecar, enabling it to correctly encode and decode the Kubernetes resources. Signed-off-by: Leonardo Cecchi <leonardo.cecchi@enterprisedb.com> Signed-off-by: Marco Nenciarini <marco.nenciarini@enterprisedb.com> Co-authored-by: Marco Nenciarini <marco.nenciarini@enterprisedb.com>
40 lines
1.1 KiB
Go
40 lines
1.1 KiB
Go
package operator
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/utils/ptr"
|
|
)
|
|
|
|
// setOwnerReference explicitly set the owner reference between an
|
|
// owner object and a controller one.
|
|
//
|
|
// Important: this function won't use any registered scheme and will
|
|
// fail unless the metadata has been correctly set into the owner
|
|
// object.
|
|
func setOwnerReference(owner, controlled metav1.Object) error {
|
|
ro, ok := owner.(runtime.Object)
|
|
if !ok {
|
|
return fmt.Errorf("%T is not a runtime.Object, cannot call setOwnerReference", owner)
|
|
}
|
|
|
|
if len(ro.DeepCopyObject().GetObjectKind().GroupVersionKind().Group) == 0 {
|
|
return fmt.Errorf("%T metadata have not been set, cannot call setOwnerReference", owner)
|
|
}
|
|
|
|
controlled.SetOwnerReferences([]metav1.OwnerReference{
|
|
{
|
|
APIVersion: ro.GetObjectKind().GroupVersionKind().GroupVersion().String(),
|
|
Kind: ro.GetObjectKind().GroupVersionKind().Kind,
|
|
Name: owner.GetName(),
|
|
UID: owner.GetUID(),
|
|
BlockOwnerDeletion: ptr.To(true),
|
|
Controller: ptr.To(true),
|
|
},
|
|
})
|
|
|
|
return nil
|
|
}
|