controllers

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2017 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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

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

func (nrc *NetworkRoutingController) Cleanup()

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)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.