more logging, at least for now
parent
d4dc516db1
commit
d2636d5eb1
|
@ -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())
|
||||
|
|
|
@ -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"`
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue