routing

Documentation

Index

• Constants
• type NetworkRoutingController
  • func NewNetworkRoutingController(clientset kubernetes.Interface, kubeRouterConfig *options.KubeRouterConfig, ...) (*NetworkRoutingController, error)
  • func (nrc *NetworkRoutingController) Cleanup()
  • func (nrc *NetworkRoutingController) OnEndpointsUpdate(obj interface{})
  • func (nrc *NetworkRoutingController) OnNodeUpdate(obj interface{})
  • func (nrc *NetworkRoutingController) OnServiceDelete(obj interface{})
  • func (nrc *NetworkRoutingController) OnServiceUpdate(obj interface{})
  • func (nrc *NetworkRoutingController) Run(healthChan chan<- *healthcheck.ControllerHeartbeat, stopCh <-chan struct{}, ...)

Constants

const (
	IFACE_NOT_FOUND = "Link not found"

	LeaderElectionRecordAnnotationKey = "control-plane.alpha.kubernetes.io/leader"
)

Types

type NetworkRoutingController

type NetworkRoutingController struct {
	MetricsEnabled bool

	NodeEventHandler      cache.ResourceEventHandler
	ServiceEventHandler   cache.ResourceEventHandler
	EndpointsEventHandler cache.ResourceEventHandler
	// contains filtered or unexported fields
}

NetworkRoutingController is struct to hold necessary information required by controller

func NewNetworkRoutingController

func NewNetworkRoutingController(clientset kubernetes.Interface,
	kubeRouterConfig *options.KubeRouterConfig,
	nodeInformer cache.SharedIndexInformer, svcInformer cache.SharedIndexInformer,
	epInformer cache.SharedIndexInformer) (*NetworkRoutingController, error)

NewNetworkRoutingController returns new NetworkRoutingController object

func (*NetworkRoutingController) Cleanup

func (nrc *NetworkRoutingController) Cleanup()

Cleanup performs the cleanup of configurations done

func (*NetworkRoutingController) OnEndpointsUpdate

func (nrc *NetworkRoutingController) OnEndpointsUpdate(obj interface{})

OnEndpointsUpdate handles the endpoint updates from the kubernetes API server

func (*NetworkRoutingController) OnNodeUpdate

func (nrc *NetworkRoutingController) OnNodeUpdate(obj interface{})

OnNodeUpdate Handle updates from Node watcher. Node watcher calls this method whenever there is new node is added or old node is deleted. So peer up with new node and drop peering from old node

func (*NetworkRoutingController) OnServiceDelete

func (nrc *NetworkRoutingController) OnServiceDelete(obj interface{})

OnServiceDelete handles the service delete updates from the kubernetes API server

func (*NetworkRoutingController) OnServiceUpdate

func (nrc *NetworkRoutingController) OnServiceUpdate(obj interface{})

OnServiceUpdate handles the service relates updates from the kubernetes API server

func (*NetworkRoutingController) Run

func (nrc *NetworkRoutingController) Run(healthChan chan<- *healthcheck.ControllerHeartbeat, stopCh <-chan struct{}, wg *sync.WaitGroup)

Run runs forever until we are notified on stop channel