INNER CODE UNIT · Go

createTunnelResource

inlets/inlets-operator · controller.go:590

func createTunnelResource(service *corev1.Service, c *Controller) error {
	name := service.Name + "-tunnel"
	namespace := service.Namespace

	tunnels := c.operatorclientset.OperatorV1alpha1().
		Tunnels(service.ObjectMeta.Namespace)

	ops := metav1.GetOptions{}

	found, err := tunnels.Get(context.Background(), name, ops)

	// Create Tunnel CR
	if errors.IsNotFound(err) {

		if !manageService(*c, *service) {
			return nil
		}

View source record →