feat: write log when marking InstanceGroup node as needs update

pkg/cloudinstances/cloud_instance_group.go

@@ -88,6 +88,7 @@ func (group *CloudInstanceGroup) AdjustNeedUpdate() {
  if makeNotReady {
  group.NeedUpdate = append(group.NeedUpdate, member)
  member.Status = CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s node %s has needs-update annotation\n", group.HumanName, member.Node.Name)
  } else {
  newReady = append(newReady, member)
  }

upup/pkg/fi/cloudup/awsup/aws_cloud.go

@@ -970,6 +970,7 @@ func buildKarpenterGroup(c AWSCloud, cluster *kops.Cluster, ig *kops.InstanceGro
  status = cloudinstances.CloudInstanceStatusUpToDate
  } else {
  status = cloudinstances.CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s node %s launch configuration is behind\n", karpenterGroup.HumanName, id)
  }
  cloudInstance, _ := karpenterGroup.NewCloudInstance(id, status, nodeMap[id])
  addCloudInstanceData(cloudInstance, instance)
@@ -1256,6 +1257,7 @@ func buildCloudInstance(i *autoscaling.Instance, instances map[string]*ec2.Insta
  status := cloudinstances.CloudInstanceStatusUpToDate
  if newConfigName != currentConfigName {
  status = cloudinstances.CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s node %s launch configuration is behind\n", cg.HumanName, id)
  }
  cm, err := cg.NewCloudInstance(id, status, nodeMap[id])
  if err != nil {

upup/pkg/fi/cloudup/gce/instancegroups.go

@@ -189,8 +189,10 @@ func getCloudGroups(c GCECloud, cluster *kops.Cluster, instancegroups []*kops.In
 
  if i.Version != nil && latestInstanceTemplate == i.Version.InstanceTemplate {
  g.Ready = append(g.Ready, cm)
+ fmt.Printf("InstanceGroup %s nodes launch templates are NOT behind\n", cm.CloudInstanceGroup.HumanName)
  } else {
  g.NeedUpdate = append(g.NeedUpdate, cm)
+ fmt.Printf("InstanceGroup %s nodes launch templates are behind\n", cm.CloudInstanceGroup.HumanName)
  }
  }
 

upup/pkg/fi/cloudup/hetzner/cloud.go

@@ -371,6 +371,7 @@ func buildCloudInstanceGroup(ig *kops.InstanceGroup, sg []*hcloud.Server, nodeMa
  status := cloudinstances.CloudInstanceStatusUpToDate
  if _, ok := server.Labels[TagKubernetesInstanceNeedsUpdate]; ok {
  status = cloudinstances.CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s node %s has %s label\n", cloudInstanceGroup.HumanName, server.Name, server.Labels[TagKubernetesInstanceNeedsUpdate])
  }
 
  id := strconv.Itoa(server.ID)

upup/pkg/fi/cloudup/openstack/server_group.go

@@ -113,6 +113,7 @@ func osBuildCloudInstanceGroup(c OpenstackCloud, cluster *kops.Cluster, ig *kops
  status := cloudinstances.CloudInstanceStatusUpToDate
  if generationName != observedName || instance.Status == errorStatus {
  status = cloudinstances.CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s instance %s generationName and observedName mismatch or instance in error\n", cg.HumanName, instance.ID)
  }
  cm, err := cg.NewCloudInstance(instance.ID, status, nodeMap[instance.ID])
  if err != nil {

upup/pkg/fi/cloudup/scaleway/cloud.go

@@ -398,6 +398,7 @@ func buildCloudGroup(s *scwCloudImplementation, ig *kops.InstanceGroup, sg []*in
  for _, tag := range server.Tags {
  if tag == TagNeedsUpdate {
  status = cloudinstances.CloudInstanceStatusNeedsUpdate
+ fmt.Printf("InstanceGroup %s node %s has tag %s\n", cloudInstanceGroup.HumanName, server.Name, tag)
  }
  }
  cloudInstance, err := cloudInstanceGroup.NewCloudInstance(server.ID, status, nodeMap[server.ID])