Function TestWarmPoolOnlyRoll

pkg/instancegroups/instancegroups_test.go:30–68

(t *testing.T)

)

func TestWarmPoolOnlyRoll(t *testing.T) {
	ctx := context.Background()
	c, cloud := getTestSetup()

	groupName := "warmPoolOnly"
	instanceID := "node-1"

	groups := make(map[string]*cloudinstances.CloudInstanceGroup)
	makeGroup(groups, c.K8sClient, cloud, groupName, kopsapi.InstanceGroupRoleNode, 0, 0)

	group := groups[groupName]
	group.MinSize = 0
	group.MaxSize = 10

	maxSurge := intstr.FromString("25%")

	group.InstanceGroup.Spec.RollingUpdate = &kopsapi.RollingUpdate{
		MaxSurge: &maxSurge,
	}

	cloud.Autoscaling().AttachInstances(ctx, &autoscaling.AttachInstancesInput{
		AutoScalingGroupName: &groupName,
		InstanceIds:          []string{instanceID},
	})

	instance, err := group.NewCloudInstance("node-1", cloudinstances.CloudInstanceStatusNeedsUpdate, nil)
	if err != nil {
		t.Fatalf("could not create cloud instance: %v", err)
	}

	instance.State = cloudinstances.WarmPool

	{
		err := c.rollingUpdateInstanceGroup(ctx, group, 0*time.Second)
		if err != nil {
			t.Fatalf("could not roll instance group: %v", err)
		}
	}
}