ingress

Documentation

Overview

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

Index

• Constants
• Variables
• func ConvertIngressV1alpha3(ingress knetworking.Ingress, mesh *meshconfig.MeshConfig, domainSuffix string) config.Config
• func ConvertIngressVirtualService(ingress knetworking.Ingress, domainSuffix string, ...)
• func NewController(client kube.Client, meshWatcher mesh.Holder, options kubecontroller.Options) model.ConfigStoreController
• type StatusSyncer
  • func NewStatusSyncer(meshHolder mesh.Watcher, kc kubelib.Client) *StatusSyncer
  • func (s *StatusSyncer) Reconcile(key types.NamespacedName) error
  • func (s *StatusSyncer) Run(stopCh <-chan struct{})

Constants

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

Variables

var IngressNamespace = env.Register("K8S_INGRESS_NS", constants.IstioSystemNamespace,
	"The namespace where ingress controller runs, by default it is istio-system").Get()

Functions

func ConvertIngressV1alpha3

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

ConvertIngressV1alpha3 converts from ingress spec to Istio Gateway

func ConvertIngressVirtualService

func ConvertIngressVirtualService(ingress knetworking.Ingress, domainSuffix string,
	ingressByHost map[string]*config.Config, services kclient.Client[*corev1.Service],
)

ConvertIngressVirtualService converts from ingress spec to Istio VirtualServices

func NewController

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

NewController creates a new Kubernetes controller

Types

type StatusSyncer

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

StatusSyncer keeps the status IP in each Ingress resource updated

func NewStatusSyncer

func NewStatusSyncer(meshHolder mesh.Watcher, kc kubelib.Client) *StatusSyncer

NewStatusSyncer creates a new instance

func (*StatusSyncer) Reconcile

func (s *StatusSyncer) Reconcile(key types.NamespacedName) error

func (*StatusSyncer) Run

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

Run the syncer until stopCh is closed