diff --git a/provider/kubernetes/kubernetes.go b/provider/kubernetes/kubernetes.go index bee2bd49..212e834e 100644 --- a/provider/kubernetes/kubernetes.go +++ b/provider/kubernetes/kubernetes.go @@ -196,18 +196,34 @@ func (p *Provider) impactedDeployments(repo *types.Repository) ([]*v1beta1.Deplo if !ok { continue } - policy := types.ParsePolicy(policyStr) + log.WithFields(log.Fields{ + "labels": labels, + "name": deployment.Name, + "namespace": deployment.Namespace, + "policy": policy, + }).Info("provider.kubernetes: keel policy found, checking deployment...") + for idx, c := range deployment.Spec.Template.Spec.Containers { // Remove version if any containerImageName := versionreg.ReplaceAllString(c.Image, "") + + log.WithFields(log.Fields{ + "name": deployment.Name, + "namespace": deployment.Namespace, + "parsed_image_name": containerImageName, + "target_image_name": repo.Name, + "target_tag": repo.Tag, + "policy": policy, + "image": c.Image, + }).Info("provider.kubernetes: checking image") + if containerImageName != repo.Name { continue } currentVersion, err := version.GetVersionFromImageName(c.Image) - if err != nil { log.WithFields(log.Fields{ "error": err, @@ -217,6 +233,15 @@ func (p *Provider) impactedDeployments(repo *types.Repository) ([]*v1beta1.Deplo continue } + log.WithFields(log.Fields{ + "labels": labels, + "name": deployment.Name, + "namespace": deployment.Namespace, + "image": c.Image, + "current_version": currentVersion.String(), + "policy": policy, + }).Info("provider.kubernetes: current image version") + shouldUpdate, err := version.ShouldUpdate(currentVersion, newVersion, policy) if err != nil { log.WithFields(log.Fields{ @@ -228,6 +253,17 @@ func (p *Provider) impactedDeployments(repo *types.Repository) ([]*v1beta1.Deplo continue } + log.WithFields(log.Fields{ + "labels": labels, + "name": deployment.Name, + "namespace": deployment.Namespace, + "image": c.Image, + "current_version": currentVersion.String(), + "new_version": newVersion.String(), + "policy": policy, + "should_update": shouldUpdate, + }).Info("provider.kubernetes: checked version, deciding whether to update") + if shouldUpdate { // updating image c.Image = fmt.Sprintf("%s:%s", containerImageName, newVersion.String()) diff --git a/types/types.go b/types/types.go index c6178f41..c0aa0c2b 100644 --- a/types/types.go +++ b/types/types.go @@ -16,7 +16,6 @@ type Repository struct { type Event struct { Repository Repository `json:"repository,omitempty"` - Pusher string `json:"pusher,omitempty"` CreatedAt time.Time `json:"createdAt,omitempty"` }