service.go

package operatorclient

import (
	"context"
	"fmt"

	v1 "k8s.io/api/core/v1"
	apierrors "k8s.io/apimachinery/pkg/api/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/types"
	acv1 "k8s.io/client-go/applyconfigurations/core/v1"
	"k8s.io/klog"
)

// ApplyService applies the Service.
func (c *Client) ApplyService(applyConfig *acv1.ServiceApplyConfiguration, applyOptions metav1.ApplyOptions) (*v1.Service, error) {
	return c.CoreV1().Services(*applyConfig.Namespace).Apply(context.TODO(), applyConfig, applyOptions)
}

// CreateService creates the Service or Updates if it already exists.
func (c *Client) CreateService(ig *v1.Service) (*v1.Service, error) {
	createdService, err := c.CoreV1().Services(ig.GetNamespace()).Create(context.TODO(), ig, metav1.CreateOptions{})
	if apierrors.IsAlreadyExists(err) {
		return c.UpdateService(ig)
	}
	return createdService, err
}

// GetService returns the existing Service.
func (c *Client) GetService(namespace, name string) (*v1.Service, error) {
	return c.CoreV1().Services(namespace).Get(context.TODO(), name, metav1.GetOptions{})
}

// DeleteService deletes the Service.
func (c *Client) DeleteService(namespace, name string, options *metav1.DeleteOptions) error {
	return c.CoreV1().Services(namespace).Delete(context.TODO(), name, *options)
}

// UpdateService will update the given Service resource.
func (c *Client) UpdateService(service *v1.Service) (*v1.Service, error) {
	klog.V(4).Infof("[UPDATE Service]: %s", service.GetName())
	old, err := c.GetService(service.GetNamespace(), service.GetName())
	if err != nil {
		return nil, err
	}
	normalized, err := cloneAndNormalizeObject(old)
	if err != nil {
		return nil, fmt.Errorf("failed to normalize existing Service resource for patch: %w", err)
	}
	if service.Spec.ClusterIP == old.Spec.ClusterIP {
		// Support updating to manifests that specify a
		// ClusterIP when its value is the same as that of the
		// existing Service.
		service = service.DeepCopy()
		service.Spec.ClusterIP = ""
	}
	patchBytes, err := createPatch(normalized, service)
	if err != nil {
		return nil, fmt.Errorf("error creating patch for Service: %v", err)
	}
	return c.CoreV1().Services(service.GetNamespace()).Patch(context.TODO(), service.GetName(), types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{})
}