Apply New Ingress Controller Rule

func (c *client) ConnectHostnameToDeployment(ctx context.Context, directive ctypes.ConnectHostnameToDeploymentDirective) error {
    ingressName := directive.Hostname
    ns := builder.LidNS(directive.LeaseID)
    rules := ingressRules(directive.Hostname, directive.ServiceName, directive.ServicePort)

    foundEntry, err := c.kc.NetworkingV1().Ingresses(ns).Get(ctx, ingressName, metav1.GetOptions{})
    metricsutils.IncCounterVecWithLabelValuesFiltered(kubeCallsCounter, "ingresses-get", err, kubeErrors.IsNotFound)

    labels := make(map[string]string)
    labels[builder.AkashManagedLabelName] = "true"
    builder.AppendLeaseLabels(directive.LeaseID, labels)

    ingressClassName := akashIngressClassName
    obj := &netv1.Ingress{
        ObjectMeta: metav1.ObjectMeta{
            Name:        ingressName,
            Labels:      labels,
            Annotations: kubeNginxIngressAnnotations(directive),
        },
        Spec: netv1.IngressSpec{
            IngressClassName: &ingressClassName,
            Rules:            rules,
        },
    }

    switch {
    case err == nil:
        obj.ResourceVersion = foundEntry.ResourceVersion
        _, err = c.kc.NetworkingV1().Ingresses(ns).Update(ctx, obj, metav1.UpdateOptions{})
        metricsutils.IncCounterVecWithLabelValues(kubeCallsCounter, "networking-ingresses-update", err)
    case kubeErrors.IsNotFound(err):
        _, err = c.kc.NetworkingV1().Ingresses(ns).Create(ctx, obj, metav1.CreateOptions{})
        metricsutils.IncCounterVecWithLabelValues(kubeCallsCounter, "networking-ingresses-create", err)
    }

    return err
}