Compare commits
No commits in common. "9ed5e3aea7453389ccf648c9fea4b748b85c611d" and "0e95590c200f66c659433db3700526d914843909" have entirely different histories.
9ed5e3aea7
...
0e95590c20
@ -5,4 +5,4 @@ kind: Kustomization
|
|||||||
images:
|
images:
|
||||||
- name: controller
|
- name: controller
|
||||||
newName: docker.io/desmo999r/formolcontroller
|
newName: docker.io/desmo999r/formolcontroller
|
||||||
newTag: v1.0.2
|
newTag: v0.5.1
|
||||||
|
|||||||
@ -209,6 +209,15 @@ 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{
|
||||||
@ -219,6 +228,7 @@ 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,
|
||||||
@ -227,26 +237,7 @@ 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
|
||||||
}
|
}
|
||||||
hasSidecar := func(podSpec *corev1.PodSpec) int {
|
if !hasSidecar(targetPodSpec) {
|
||||||
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