Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7b465eaa66 | ||
|
|
a077d6deb2 |
@ -127,7 +127,6 @@ spec:
|
|||||||
type: array
|
type: array
|
||||||
required:
|
required:
|
||||||
- name
|
- name
|
||||||
- sharePath
|
|
||||||
type: object
|
type: object
|
||||||
type: array
|
type: array
|
||||||
retry:
|
retry:
|
||||||
@ -146,7 +145,6 @@ spec:
|
|||||||
required:
|
required:
|
||||||
- backupType
|
- backupType
|
||||||
- containers
|
- containers
|
||||||
- retry
|
|
||||||
- targetKind
|
- targetKind
|
||||||
- targetName
|
- targetName
|
||||||
type: object
|
type: object
|
||||||
|
|||||||
@ -5,4 +5,4 @@ kind: Kustomization
|
|||||||
images:
|
images:
|
||||||
- name: controller
|
- name: controller
|
||||||
newName: docker.io/desmo999r/formolcontroller
|
newName: docker.io/desmo999r/formolcontroller
|
||||||
newTag: v0.5.1
|
newTag: v1.0.2
|
||||||
|
|||||||
@ -112,12 +112,8 @@ rules:
|
|||||||
resources:
|
resources:
|
||||||
- secrets
|
- secrets
|
||||||
verbs:
|
verbs:
|
||||||
- create
|
|
||||||
- delete
|
|
||||||
- get
|
- get
|
||||||
- list
|
- list
|
||||||
- patch
|
|
||||||
- update
|
|
||||||
- watch
|
- watch
|
||||||
- apiGroups:
|
- apiGroups:
|
||||||
- ""
|
- ""
|
||||||
|
|||||||
@ -209,15 +209,6 @@ func (r *BackupConfigurationReconciler) DeleteSidecar(backupConf formolv1alpha1.
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func hasSidecar(podSpec *corev1.PodSpec) bool {
|
|
||||||
for _, container := range podSpec.Containers {
|
|
||||||
if container.Name == formolv1alpha1.SIDECARCONTAINER_NAME {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *BackupConfigurationReconciler) addSidecar(backupConf formolv1alpha1.BackupConfiguration, target formolv1alpha1.Target) (err error) {
|
func (r *BackupConfigurationReconciler) addSidecar(backupConf formolv1alpha1.BackupConfiguration, target formolv1alpha1.Target) (err error) {
|
||||||
repo := formolv1alpha1.Repo{}
|
repo := formolv1alpha1.Repo{}
|
||||||
if err = r.Get(r.Context, client.ObjectKey{
|
if err = r.Get(r.Context, client.ObjectKey{
|
||||||
@ -228,7 +219,6 @@ func (r *BackupConfigurationReconciler) addSidecar(backupConf formolv1alpha1.Bac
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
r.Log.V(1).Info("Got Repository", "repo", repo)
|
r.Log.V(1).Info("Got Repository", "repo", repo)
|
||||||
sidecar := formolv1alpha1.GetSidecar(backupConf, target)
|
|
||||||
targetObject, targetPodSpec := formolv1alpha1.GetTargetObjects(target.TargetKind)
|
targetObject, targetPodSpec := formolv1alpha1.GetTargetObjects(target.TargetKind)
|
||||||
if err := r.Get(r.Context, client.ObjectKey{
|
if err := r.Get(r.Context, client.ObjectKey{
|
||||||
Namespace: backupConf.Namespace,
|
Namespace: backupConf.Namespace,
|
||||||
@ -237,7 +227,26 @@ func (r *BackupConfigurationReconciler) addSidecar(backupConf formolv1alpha1.Bac
|
|||||||
r.Log.Error(err, "cannot get target", "target", target.TargetName)
|
r.Log.Error(err, "cannot get target", "target", target.TargetName)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if !hasSidecar(targetPodSpec) {
|
hasSidecar := func(podSpec *corev1.PodSpec) int {
|
||||||
|
for i, container := range podSpec.Containers {
|
||||||
|
if container.Name == formolv1alpha1.SIDECARCONTAINER_NAME {
|
||||||
|
return i
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return -1
|
||||||
|
}
|
||||||
|
if res := hasSidecar(targetPodSpec); res != -1 {
|
||||||
|
if targetPodSpec.Containers[res].Image != backupConf.Spec.Image {
|
||||||
|
r.Log.V(0).Info("New sidecar image. Updating pod", "old", targetPodSpec.Containers[res].Image, "new", backupConf.Spec.Image)
|
||||||
|
targetPodSpec.Containers[res].Image = backupConf.Spec.Image
|
||||||
|
if err = r.Update(r.Context, targetObject); err != nil {
|
||||||
|
r.Log.Error(err, "unable to update targetObject", "targetObject", targetObject)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
sidecar := formolv1alpha1.GetSidecar(backupConf, target)
|
||||||
if err = r.createSidecarRBAC(targetPodSpec); err != nil {
|
if err = r.createSidecarRBAC(targetPodSpec); err != nil {
|
||||||
r.Log.Error(err, "unable to create RBAC for the sidecar container")
|
r.Log.Error(err, "unable to create RBAC for the sidecar container")
|
||||||
return
|
return
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user