connection

Documentation

Index

• type Controller
  • func New(connClient connClientset.Interface, kubeClient clientset.Interface, ...) *Controller
  • func (s *Controller) Run(stopCh <-chan struct{}, workers int)
  • func (s *Controller) ShutDown()

Types

type Controller

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

Controller keeps private link

func New

func New(
	connClient connClientset.Interface,
	kubeClient clientset.Interface,
	connInformer informers.ServiceConnectionInformer,
	svcIformer coreinformers.ServiceInformer,
	cfg config.Config,
	azCtx azure.AzContext,
	recorder record.EventRecorder,

) *Controller

New returns a new connection controller to keep sync private link connections

func (*Controller) Run

func (s *Controller) Run(stopCh <-chan struct{}, workers int)

Run starts the controller

func (*Controller) ShutDown

func (s *Controller) ShutDown()

ShutDown does cleanup when controller is terminated