feat: add cloud provider disruption reasons (#1574)

kwok/cloudprovider/cloudprovider.go

@@ -64,6 +64,10 @@ func (c CloudProvider) Create(ctx context.Context, nodeClaim *v1.NodeClaim) (*v1
 	return c.toNodeClaim(node)
 }
 
+func (c CloudProvider) DisruptionReasons() []v1.DisruptionReason {
+	return nil
+}
+
 func (c CloudProvider) Delete(ctx context.Context, nodeClaim *v1.NodeClaim) error {
 	if err := c.kubeClient.Delete(ctx, nodeClaim); err != nil {
 		if errors.IsNotFound(err) {

pkg/cloudprovider/fake/cloudprovider.go

@@ -235,6 +235,10 @@ func (c *CloudProvider) GetInstanceTypes(_ context.Context, np *v1.NodePool) ([]
 	}, nil
 }
 
+func (c *CloudProvider) DisruptionReasons() []v1.DisruptionReason {
+	return nil
+}
+
 func (c *CloudProvider) Delete(_ context.Context, nc *v1.NodeClaim) error {
 	c.mu.Lock()
 	defer c.mu.Unlock()

pkg/cloudprovider/types.go

@@ -58,6 +58,9 @@ type CloudProvider interface {
 	// availability, the GetInstanceTypes method should always return all instance types,
 	// even those with no offerings available.
 	GetInstanceTypes(context.Context, *v1.NodePool) ([]*InstanceType, error)
+	// DisruptionReasons is for CloudProviders to hook into the Disruption Controller.
+	// Reasons will show up as StatusConditions on the NodeClaim.
+	DisruptionReasons() []v1.DisruptionReason
 	// IsDrifted returns whether a NodeClaim has drifted from the provisioning requirements
 	// it is tied to.
 	IsDrifted(context.Context, *v1.NodeClaim) (DriftReason, error)