INNER CODE UNIT · Go

NewNginxController

gravitational/workshop · crd/controller/controller.go:44

func NewNginxController(
	kubeClient coreclient.Interface,
	nginxClient nginxclient.Interface,
	podInformer coreinformer.PodInformer,
	nginxInformer nginxinformer.NginxInformer,
) (*nginxController, error) {
	controller := &nginxController{
		queue: workqueue.NewNamedRateLimitingQueue(
			workqueue.DefaultControllerRateLimiter(), "Nginxes"),
		nginxClient:   nginxClient,
		nginxInformer: nginxInformer,
		nginxLister:   nginxInformer.Lister(),
		kubeClient:    kubeClient,
		podLister:     podInformer.Lister(),
	}

	// Register an event handler that fires an event every time a new
	// custom Nginx resource is created in the cluster.

View source record →