controllers

package

v0.0.7 Latest Latest Go to latest Published: Jul 13, 2017 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bzub/kube-router

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type NetworkPolicyController
- func NewNetworkPolicyController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkPolicyController, error)
type NetworkRoutingController
- func NewNetworkRoutingController(clientset *kubernetes.Clientset, kubeRouterConfig *options.KubeRouterConfig) (*NetworkRoutingController, error)
type NetworkServicesController
- func NewNetworkServicesController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*NetworkServicesController, error)

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() 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 ¶ added in v0.0.5

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

func (*NetworkRoutingController) Cleanup ¶

func (nrc *NetworkRoutingController) Cleanup()

func (*NetworkRoutingController) OnNodeUpdate ¶ added in v0.0.5

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL