controllers

Documentation

Index

• Constants
• type NetworkPolicyController
  • func NewNetworkPolicyController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkPolicyController, error)
  • func (npc *NetworkPolicyController) Cleanup()
  • func (npc *NetworkPolicyController) OnNamespaceUpdate(namespaceUpdate *watchers.NamespaceUpdate)
  • func (npc *NetworkPolicyController) OnNetworkPolicyUpdate(networkPolicyUpdate *watchers.NetworkPolicyUpdate)
  • func (npc *NetworkPolicyController) OnPodUpdate(podUpdate *watchers.PodUpdate)
  • func (npc *NetworkPolicyController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)
  • func (npc *NetworkPolicyController) Sync() error
• type NetworkRoutingController
  • func NewNetworkRoutingController(clientset *kubernetes.Clientset, kubeRouterConfig *options.KubeRouterConfig) (*NetworkRoutingController, error)
  • func (nrc *NetworkRoutingController) AdvertiseClusterIp(clusterIp string) error
  • func (nrc *NetworkRoutingController) Cleanup()
  • func (nrc *NetworkRoutingController) OnNodeUpdate(nodeUpdate *watchers.NodeUpdate)
  • func (nrc *NetworkRoutingController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)
• type NetworkServicesController
  • func NewNetworkServicesController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkServicesController, error)
  • func (nsc *NetworkServicesController) Cleanup()
  • func (nsc *NetworkServicesController) OnEndpointsUpdate(endpointsUpdate *watchers.EndpointsUpdate)
  • func (nsc *NetworkServicesController) OnServiceUpdate(serviceUpdate *watchers.ServiceUpdate)
  • func (nsc *NetworkServicesController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) error

Constants

const (
	KUBE_DUMMY_IF      = "kube-dummy-if"
	IFACE_NOT_FOUND    = "Link not found"
	IFACE_HAS_ADDR     = "file exists"
	IPVS_SERVER_EXISTS = "file exists"
)

Types

type NetworkPolicyController

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

func NewNetworkPolicyController

func NewNetworkPolicyController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkPolicyController, error)

func (*NetworkPolicyController) Cleanup

func (npc *NetworkPolicyController) Cleanup()

func (*NetworkPolicyController) OnNamespaceUpdate

func (npc *NetworkPolicyController) OnNamespaceUpdate(namespaceUpdate *watchers.NamespaceUpdate)

func (*NetworkPolicyController) OnNetworkPolicyUpdate

func (npc *NetworkPolicyController) OnNetworkPolicyUpdate(networkPolicyUpdate *watchers.NetworkPolicyUpdate)

func (*NetworkPolicyController) OnPodUpdate

func (npc *NetworkPolicyController) OnPodUpdate(podUpdate *watchers.PodUpdate)

func (*NetworkPolicyController) Run

func (npc *NetworkPolicyController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)

func (*NetworkPolicyController) Sync

func (npc *NetworkPolicyController) Sync() error

Sync synchronizes iptables to desired state of network policies

type NetworkRoutingController

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

func NewNetworkRoutingController

func NewNetworkRoutingController(clientset *kubernetes.Clientset, kubeRouterConfig *options.KubeRouterConfig) (*NetworkRoutingController, error)

func (*NetworkRoutingController) AdvertiseClusterIp

func (nrc *NetworkRoutingController) AdvertiseClusterIp(clusterIp string) error

func (*NetworkRoutingController) Cleanup

func (nrc *NetworkRoutingController) Cleanup()

func (*NetworkRoutingController) OnNodeUpdate

func (nrc *NetworkRoutingController) OnNodeUpdate(nodeUpdate *watchers.NodeUpdate)

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) Run

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

type NetworkServicesController

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

func NewNetworkServicesController

func NewNetworkServicesController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkServicesController, error)

func (*NetworkServicesController) Cleanup

func (nsc *NetworkServicesController) Cleanup()

clean up all the configurations (IPVS, iptables, links)

func (*NetworkServicesController) OnEndpointsUpdate

func (nsc *NetworkServicesController) OnEndpointsUpdate(endpointsUpdate *watchers.EndpointsUpdate)

handle change in endpoints update from the API server

func (*NetworkServicesController) OnServiceUpdate

func (nsc *NetworkServicesController) OnServiceUpdate(serviceUpdate *watchers.ServiceUpdate)

handle change in service update from the API server

func (*NetworkServicesController) Run

func (nsc *NetworkServicesController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) error

periodically sync ipvs configuration to reflect desired state of services and endpoints