k8s

Documentation

Index

• func GetAddressFromService(service *apiv1.Service) string
• func GetAddresses(p *store.PodInfo, kubeClient *kubernetes.Clientset) ([]string, error)
• func GetPodDetails(kubeClient *kubernetes.Clientset) (*store.PodInfo, error)
• func IsManagedTLSSecret(secret *v12.Secret, ings []*v1.Ingress) bool
• func ListTLSSecrets(options TLSSecretParams, ings []*v1.Ingress) ([]*v12.Secret, error)
• func UpdateIngressStatus(kubeClient *kubernetes.Clientset, ing *networkingv1.Ingress, ...) (*networkingv1.Ingress, error)
• func WatchConfigMaps(options ConfigMapParams, funcs ConfigMapHandlers) cache.SharedIndexInformer
• func WatchIngresses(options IngressParams, funcs IngressHandlers) cache.SharedIndexInformer
• func WatchTLSSecrets(options TLSSecretParams, funcs TLSSecretHandlers) cache.SharedIndexInformer
• type ConfigMapHandlers
• type ConfigMapParams
• type IngressHandlers
• type IngressParams
• type TLSSecretHandlers
• type TLSSecretParams

Functions

func GetAddressFromService

func GetAddressFromService(service *apiv1.Service) string

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

func GetAddresses

func GetAddresses(p *store.PodInfo, kubeClient *kubernetes.Clientset) ([]string, error)

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

func GetPodDetails

func GetPodDetails(kubeClient *kubernetes.Clientset) (*store.PodInfo, error)

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

func IsManagedTLSSecret

func IsManagedTLSSecret(secret *v12.Secret, ings []*v1.Ingress) bool

func ListTLSSecrets

func ListTLSSecrets(options TLSSecretParams, ings []*v1.Ingress) ([]*v12.Secret, error)

func UpdateIngressStatus

func UpdateIngressStatus(kubeClient *kubernetes.Clientset, ing *networkingv1.Ingress, status []networkingv1.IngressLoadBalancerIngress) (*networkingv1.Ingress, error)

func WatchConfigMaps

func WatchConfigMaps(options ConfigMapParams, funcs ConfigMapHandlers) cache.SharedIndexInformer

func WatchIngresses

func WatchIngresses(options IngressParams, funcs IngressHandlers) cache.SharedIndexInformer

func WatchTLSSecrets

func WatchTLSSecrets(options TLSSecretParams, funcs TLSSecretHandlers) cache.SharedIndexInformer

Types

type ConfigMapHandlers

type ConfigMapHandlers struct {
	AddFunc    func(obj *v1.ConfigMap)
	UpdateFunc func(oldObj, newObj *v1.ConfigMap)
	DeleteFunc func(obj *v1.ConfigMap)
}

type ConfigMapParams

type ConfigMapParams struct {
	Namespace       string
	InformerFactory informers.SharedInformerFactory
	ConfigMapName   string
}

type IngressHandlers

type IngressHandlers struct {
	AddFunc    func(obj *networkingv1.Ingress)
	UpdateFunc func(oldObj, newObj *networkingv1.Ingress)
	DeleteFunc func(obj *networkingv1.Ingress)
}

type IngressParams

type IngressParams struct {
	InformerFactory   informers.SharedInformerFactory
	ClassName         string
	ClassNameRequired bool
}

type TLSSecretHandlers

type TLSSecretHandlers struct {
	AddFunc    func(obj *v12.Secret)
	UpdateFunc func(oldObj, newObj *v12.Secret)
	DeleteFunc func(obj *v12.Secret)
}

type TLSSecretParams

type TLSSecretParams struct {
	InformerFactory informers.SharedInformerFactory
}