package ingress

import "istio.io/istio/pilot/pkg/config/kube/ingress"

Package ingress provides a read-only view of Kubernetes ingress resources as an ingress rule configuration type store

Index ¶

• Constants
• func ConvertIngressV1alpha3(ingress v1beta1.Ingress, mesh *meshconfig.MeshConfig, domainSuffix string) config.Config
• func ConvertIngressVirtualService(ingress v1beta1.Ingress, domainSuffix string, ingressByHost map[string]*config.Config, serviceLister listerv1.ServiceLister)
• func EncodeIngressRuleName(ingressName string, ruleNum, pathNum int) string
• func NetworkingIngressAvailable(client kubernetes.Interface) bool
• func NewController(client kube.Client, meshWatcher mesh.Holder, options kubecontroller.Options) model.ConfigStoreCache
• type StatusSyncer
• func NewStatusSyncer(meshHolder mesh.Holder, client kubelib.Client) *StatusSyncer
• func (s *StatusSyncer) Run(stopCh <-chan struct{})

Package Files ¶

controller.go conversion.go status.go

Constants ¶

const (
    IstioIngressController = "istio.io/ingress-controller"
)

func ConvertIngressV1alpha3 ¶ Uses

func ConvertIngressV1alpha3(ingress v1beta1.Ingress, mesh *meshconfig.MeshConfig, domainSuffix string) config.Config

ConvertIngressV1alpha3 converts from ingress spec to Istio Gateway

func ConvertIngressVirtualService ¶ Uses

func ConvertIngressVirtualService(ingress v1beta1.Ingress, domainSuffix string, ingressByHost map[string]*config.Config, serviceLister listerv1.ServiceLister)

ConvertIngressVirtualService converts from ingress spec to Istio VirtualServices

func EncodeIngressRuleName ¶ Uses

func EncodeIngressRuleName(ingressName string, ruleNum, pathNum int) string

EncodeIngressRuleName encodes an ingress rule name for a given ingress resource name, as well as the position of the rule and path specified within it, counting from 1. ruleNum == pathNum == 0 indicates the default backend specified for an ingress.

func NetworkingIngressAvailable ¶ Uses

func NetworkingIngressAvailable(client kubernetes.Interface) bool

Check if the "networking" group Ingress is available. Implementation borrowed from ingress-nginx

func NewController ¶ Uses

func NewController(client kube.Client, meshWatcher mesh.Holder,
    options kubecontroller.Options) model.ConfigStoreCache

NewController creates a new Kubernetes controller

type StatusSyncer ¶ Uses

type StatusSyncer struct {
    // contains filtered or unexported fields
}

StatusSyncer keeps the status IP in each Ingress resource updated

func NewStatusSyncer ¶ Uses

func NewStatusSyncer(meshHolder mesh.Holder, client kubelib.Client) *StatusSyncer

NewStatusSyncer creates a new instance

func (*StatusSyncer) Run ¶ Uses

func (s *StatusSyncer) Run(stopCh <-chan struct{})

Run the syncer until stopCh is closed