Versions in this module Expand all Collapse all v0 v0.9.7 Oct 10, 2017 Changes in this version + var DefaultClusterUID = "" + var DefaultFirewallName = "" + func ListAll(store cache.Store, selector labels.Selector, appendFn cache.AppendFunc) error + func NewFakeClusterManager(clusterName, firewallName string) *fakeClusterManager + func NewTaskQueue(syncFn func(string) error) *taskQueue + type ClusterManager struct + ClusterNamer *utils.Namer + func NewClusterManager(cloud *gce.GCECloud, namer *utils.Namer, ...) (*ClusterManager, error) + func (c *ClusterManager) Checkpoint(lbs []*loadbalancers.L7RuntimeInfo, nodeNames []string, ...) ([]*compute.InstanceGroup, error) + func (c *ClusterManager) EnsureInstanceGroupsAndPorts(servicePorts []backends.ServicePort) ([]*compute.InstanceGroup, error) + func (c *ClusterManager) GC(lbNames []string, nodePorts []backends.ServicePort) error + func (c *ClusterManager) Init(tr *GCETranslator) + func (c *ClusterManager) IsHealthy() (err error) + type ControllerContext struct + IngressInformer cache.SharedIndexInformer + NodeInformer cache.SharedIndexInformer + PodInformer cache.SharedIndexInformer + ServiceInformer cache.SharedIndexInformer + StopCh chan struct{} + func NewControllerContext(kubeClient kubernetes.Interface, namespace string, resyncPeriod time.Duration) *ControllerContext + func (ctx *ControllerContext) Start() + type GCETranslator struct + func (t *GCETranslator) GetProbe(port backends.ServicePort) (*api_v1.Probe, error) + func (t *GCETranslator) GetZoneForNode(name string) (string, error) + func (t *GCETranslator) ListZones() ([]string, error) + type LoadBalancerController struct + CloudClusterManager *ClusterManager + func NewLoadBalancerController(kubeClient kubernetes.Interface, ctx *ControllerContext, ...) (*LoadBalancerController, error) + func (lbc *LoadBalancerController) Run() + func (lbc *LoadBalancerController) Stop(deleteAll bool) error + type PodsByCreationTimestamp []*api_v1.Pod + func (o PodsByCreationTimestamp) Len() int + func (o PodsByCreationTimestamp) Less(i, j int) bool + func (o PodsByCreationTimestamp) Swap(i, j int) + type StoreToIngressLister struct + func (s *StoreToIngressLister) GetServiceIngress(svc *api_v1.Service) (ings []extensions.Ingress, err error) + func (s *StoreToIngressLister) ListAll() (ing extensions.IngressList, err error) + func (s *StoreToIngressLister) ListGCEIngresses() (ing extensions.IngressList, err error) + type StoreToNodeLister struct + type StoreToPodLister struct + func (s *StoreToPodLister) List(selector labels.Selector) (ret []*api_v1.Pod, err error) + type StoreToServiceLister struct
Go to main page