Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions pkg/cloudinstances/cloud_instance_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,6 +88,7 @@ func (group *CloudInstanceGroup) AdjustNeedUpdate() {
if makeNotReady {
group.NeedUpdate = append(group.NeedUpdate, member)
member.Status = CloudInstanceStatusNeedsUpdate
fmt.Printf("InstanceGroup %s needs update: node %s has needs-update annotation\n", group.HumanName, member.Node.Name)
} else {
newReady = append(newReady, member)
}
Expand Down
1 change: 1 addition & 0 deletions pkg/resources/spotinst/resources.go
Original file line number Diff line number Diff line change
Expand Up @@ -380,6 +380,7 @@ func registerCloudInstances(instanceGroup *cloudinstances.CloudInstanceGroup, no
status := cloudinstances.CloudInstanceStatusUpToDate
if newInstanceGroupName != currentInstanceGroupName {
status = cloudinstances.CloudInstanceStatusNeedsUpdate
fmt.Printf("InstanceGroup %s needs update: instance %s was created before last group update\n", currentInstanceGroupName, instance.Id())
}
if _, err := instanceGroup.NewCloudInstance(
instance.Id(), status, nodeMap[instance.Id()]); err != nil {
Expand Down
2 changes: 2 additions & 0 deletions upup/pkg/fi/cloudup/awsup/aws_cloud.go
Original file line number Diff line number Diff line change
Expand Up @@ -1045,6 +1045,7 @@ func awsBuildCloudInstanceGroup(ctx context.Context, c AWSCloud, cluster *kops.C
}
instanceSeen[*id] = true
addCloudInstanceData(cm, instances[aws.ToString(id)])
fmt.Printf("InstanceGroup %s needs update: instance %s is detached\n", cg.HumanName, *id)
}
}

Expand All @@ -1070,6 +1071,7 @@ func buildCloudInstance(i autoscalingtypes.Instance, instances map[string]*ec2ty
status := cloudinstances.CloudInstanceStatusUpToDate
if newConfigName != currentConfigName {
status = cloudinstances.CloudInstanceStatusNeedsUpdate
fmt.Printf("InstanceGroup %s needs update: instance %s launch configuration is behind\n", cg.HumanName, id)
}
cm, err := cg.NewCloudInstance(id, status, nodeMap[id])
if err != nil {
Expand Down
1 change: 1 addition & 0 deletions upup/pkg/fi/cloudup/gce/instancegroups.go
Original file line number Diff line number Diff line change
Expand Up @@ -231,6 +231,7 @@ func GetCloudGroups(c GCECloud, cluster *kops.Cluster, instancegroups []*kops.In
g.Ready = append(g.Ready, cm)
} else {
g.NeedUpdate = append(g.NeedUpdate, cm)
fmt.Printf("InstanceGroup %s needs update: instance %s instance template is behind\n", g.HumanName, cm.ID)
}
}

Expand Down
1 change: 1 addition & 0 deletions upup/pkg/fi/cloudup/hetzner/cloud.go
Original file line number Diff line number Diff line change
Expand Up @@ -376,6 +376,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 needs update: server %s has %s label\n", cloudInstanceGroup.HumanName, server.Name, TagKubernetesInstanceNeedsUpdate)
}

id := strconv.FormatInt(server.ID, 10)
Expand Down
1 change: 1 addition & 0 deletions upup/pkg/fi/cloudup/openstack/server_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,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 needs update: instance %s generation mismatch or in error state\n", cg.HumanName, instance.ID)
}
cm, err := cg.NewCloudInstance(instance.ID, status, nodeMap[instance.ID])
if err != nil {
Expand Down
1 change: 1 addition & 0 deletions upup/pkg/fi/cloudup/scaleway/cloud.go
Original file line number Diff line number Diff line change
Expand Up @@ -399,6 +399,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 needs update: server %s has %s tag\n", cloudInstanceGroup.HumanName, server.Name, TagNeedsUpdate)
}
}
cloudInstance, err := cloudInstanceGroup.NewCloudInstance(server.ID, status, nodeMap[server.ID])
Expand Down