app

Documentation

Index

• func DefaultBackendServicePortID(kubeClient kubernetes.Interface) utils.ServicePortID
• func NewGCEClient() *gce.Cloud
• func NewKubeConfig() (*rest.Config, error)
• func NewNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*utils.Namer, error)
• func NewStaticNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*utils.Namer, error)
• func RunHTTPServer(healthChecker func() context.HealthCheckResults)
• func RunSIGTERMHandler(lbc *controller.LoadBalancerController, deleteAll bool)

Functions

func DefaultBackendServicePortID

func DefaultBackendServicePortID(kubeClient kubernetes.Interface) utils.ServicePortID

DefaultBackendServicePortID returns the tuple of service namespace/name and port which will be used as the default backend for load balancers.

func NewGCEClient

func NewGCEClient() *gce.Cloud

NewGCEClient returns a client to the GCE environment. This will block until a valid configuration file can be read.

func NewKubeConfig

func NewKubeConfig() (*rest.Config, error)

NewKubeConfig returns a Kubernetes client config given the command line settings.

func NewNamer

func NewNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*utils.Namer, error)

NewNamer returns a new naming policy given the state of the cluster.

func NewStaticNamer

func NewStaticNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*utils.Namer, error)

NewStaticNamer returns a new naming policy given a snapshot of cluster state. Note that this implementation does not dynamically change the naming policy based on changes in cluster state.

func RunHTTPServer

func RunHTTPServer(healthChecker func() context.HealthCheckResults)

RunHTTPServer starts an HTTP server. `healthChecker` returns a mapping of component/controller name to the result of its healthcheck.

func RunSIGTERMHandler

func RunSIGTERMHandler(lbc *controller.LoadBalancerController, deleteAll bool)