Documentation
¶
Index ¶
- func DefaultBackendServicePort(kubeClient kubernetes.Interface) utils.ServicePort
- func NewGCEClient() *gce.Cloud
- func NewKubeConfig() (*rest.Config, error)
- func NewKubeConfigForProtobuf() (*rest.Config, error)
- func NewNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*namer.Namer, error)
- func NewStaticNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*namer.Namer, error)
- func RunHTTPServer(healthChecker func() context.HealthCheckResults)
- func RunSIGTERMHandler(lbc *controller.LoadBalancerController, deleteAll bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultBackendServicePort ¶
func DefaultBackendServicePort(kubeClient kubernetes.Interface) utils.ServicePort
DefaultBackendServicePort returns the ServicePort which will be used as the default backend for load balancers.
func NewGCEClient ¶
NewGCEClient returns a client to the GCE environment. This will block until a valid configuration file can be read.
func NewKubeConfig ¶ added in v1.2.2
NewKubeConfig returns a Kubernetes client config given the command line settings.
func NewKubeConfigForProtobuf ¶ added in v1.7.4
NewKubeConfigForProtobuf returns a Kubernetes client config that uses protobufs for given the command line settings.
func NewStaticNamer ¶ added in v1.6.0
func NewStaticNamer(kubeClient kubernetes.Interface, clusterName, fwName string) (*namer.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)
Types ¶
This section is empty.
Source Files