controllers

Mar 17, 2018

Changes in this version

+ type ControllerHeartbeat struct

+ Component string

+ LastHeartBeat time.Time

+ type HealthController struct

+ Config *options.KubeRouterConfig

+ HTTPEnabled bool

+ HealthPort uint16

+ Status HealthStats

+ func NewHealthController(config *options.KubeRouterConfig) (*HealthController, error)

+ func (hc *HealthController) CheckHealth() bool

+ func (hc *HealthController) HandleHeartbeat(beat *ControllerHeartbeat)

+ func (hc *HealthController) Handler(w http.ResponseWriter, req *http.Request)

+ func (hc *HealthController) Run(healthChan <-chan *ControllerHeartbeat, stopCh <-chan struct{}, ...) error

+ type HealthStats struct

+ Healthy bool

+ MetricsControllerAlive time.Time

+ NetworkPolicyControllerAlive time.Time

+ NetworkRoutingControllerAlive time.Time

+ NetworkServicesControllerAlive time.Time

+ type MetricsController struct

+ MetricsPath string

+ MetricsPort uint16

+ func NewMetricsController(clientset *kubernetes.Clientset, config *options.KubeRouterConfig) (*MetricsController, error)

+ func (mc *MetricsController) Run(healthChan chan<- *ControllerHeartbeat, stopCh <-chan struct{}, ...) error

type NetworkPolicyController

+ MetricsEnabled bool

type NetworkRoutingController

+ MetricsEnabled bool

type NetworkServicesController

+ MetricsEnabled bool

Nov 1, 2017

Changes in this version

+ const IFACE_HAS_NO_ADDR

+ const KUBE_TUNNEL_IF

Jul 11, 2017

Changes in this version

type NetworkRoutingController

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

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

Apr 26, 2017

Changes in this version

+ const IFACE_HAS_ADDR

+ const IFACE_NOT_FOUND

+ const IPVS_SERVER_EXISTS

+ const KUBE_DUMMY_IF

+ type NetworkPolicyController struct

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

+ type NetworkRoutingController struct

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

+ func (nrc *NetworkRoutingController) Cleanup()

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

+ type NetworkServicesController struct

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