controller

Documentation

Index

• Variables
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, istioclientset istio.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Variables

var (
	// Controller.ingressClass is expected as the value
	IngressClassAnnotation = "kubernetes.io/ingress.class"
	// boolean is expected for the value
	IgnoreAnnotation = "ingress.statcan.gc.ca/ignore"
	// Comma seperated list of Gateways in <namespace>/<name> format
	GatewaysAnnotation = "ingress.statcan.gc.ca/gateways"
	// The value verified in IngressClass.spec.controller
	IngressIstioController = "ingress.statcan.gc.ca/ingress-istio-controller"
)

Types

type Controller

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

Controller responds to new resources and applies the necessary configuration

func NewController

func NewController(
	kubeclientset kubernetes.Interface,
	istioclientset istio.Interface,
	clusterDomain string,
	defaultGateway string,
	scopedGateways bool,
	ingressClass string,
	defaultWeight int,
	ingressesInformer networkinginformers.IngressInformer,
	ingressClassesInformer networkinginformers.IngressClassInformer,
	servicesInformer corev1informers.ServiceInformer,
	virtualServicesInformer istionetworkinginformers.VirtualServiceInformer,
	gatewaysInformer istionetworkinginformers.GatewayInformer) *Controller

NewController creates a new Controller object.

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Run runs the controller.