serviceexternalip

Documentation

Index

• type ServiceExternalIPController
  • func NewServiceExternalIPController(nodeName string, nodeTransportInterface string, client kubernetes.Interface, ...) (*ServiceExternalIPController, error)
  • func (c *ServiceExternalIPController) GetServiceExternalIPStatus() []querier.ServiceExternalIPInfo
  • func (c *ServiceExternalIPController) Run(stopCh <-chan struct{})

Types

type ServiceExternalIPController

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

func NewServiceExternalIPController

func NewServiceExternalIPController(
	nodeName string,
	nodeTransportInterface string,
	client kubernetes.Interface,
	cluster memberlist.Interface,
	serviceInformer coreinformers.ServiceInformer,
	endpointsInformer coreinformers.EndpointsInformer,
) (*ServiceExternalIPController, error)

func (*ServiceExternalIPController) GetServiceExternalIPStatus

func (c *ServiceExternalIPController) GetServiceExternalIPStatus() []querier.ServiceExternalIPInfo

func (*ServiceExternalIPController) Run

func (c *ServiceExternalIPController) Run(stopCh <-chan struct{})

Run will create defaultWorkers workers (go routines) which will process the Service events from the workqueue.