Run method starts the ingress controller.

cleanKey strips all special characters that are not supported by kubernetes names and converts them to a '.'. sequences like '.*.' are also converted

AddIngress adds an ingress to the store. It updates the element at the given index if it is unique.

NewStore returns a new store that keeps track of K8S resources needed by the controller.

isControllerIngress check if the ingress object can be controlled by us

writeFile writes a secret to a .pem file on disk.

IngressHandler Converts redirect annotations to static_response handler

IngressHandler Add a reverse proxy handler to the route

List returns all keys that match prefix.

PluckIngress removes the ingress passed in as an argument from the stores list of ingresses.

Plugins return a sorted array of plugin instances. Sort is made following these rules: - Plugins specified in the order slice will always go first (in

lessLoadBalancerIngress is a sorting function for ingress hostnames.

updateIngStatuses starts a queue and adds all monitored ingresses to update their status source address to the on that the ingress controller is runni

watchTLSSecrets Start listening to TLS secrets if at least one ingress needs it. It will sync the CertFolder with TLS secrets

Delete deletes the value at the given key.

Exists returns true if key exists in fs.

GetAddressFromService returns the IP address or the name of a node in the cluster

GetAddresses gets the ip address or name of the node in the cluster that the ingress controller is running on.

GetPodDetails returns runtime information about the pod: name, namespace and IP of the node where it is running

Load retrieves the value at the given key.

Shutdown stops the caddy controller.

Stat returns information about key.

createApiserverClient creates a new Kubernetes REST client. We assume the controller runs inside Kubernetes and use the in-cluster config.

handleErrs reports errors received from queue actions. goland:noinspection GoUnusedParameter

ingressSliceEqual determines if the ingress source matches the ingress controller's.

Copied from https://github.com/kubernetes/kubernetes/pull/95179

Copied from https://github.com/caddyserver/caddy/blob/21af88fefc9a8239a024f635f1c6fdd9defd7eb7/modules/caddyhttp/reverseproxy/reverseproxy.go#L270-L28

processNextItem determines if there is an ingress item in the event queue and processes it.

reloadCaddy generate a caddy config from controller's store

runUpdate updates the ingress status field.

sliceToLoadBalancerIngress converts a slice of IP and/or hostnames to LoadBalancerIngress

syncStatus ensures that the ingress source address points to this ingress controller's IP address.

CertMagicStorage returns a certmagic storage type to be used by caddy.

GlobalHandler in IngressSortPlugin tries to sort routes to have the less conflict. It only supports basic conflicts for now. It doesn't support multi

IngressHandler Generate matchers for the route.

IngressHandler Converts rewrite annotations to rewrite handler

Provisions the SecretStorage instance.

Store saves value at key. More than certs and keys are stored by certmagic in secrets.