app

Documentation

Index

• Variables
• func DefaultBackendServicePort(kubeClient kubernetes.Interface) utils.ServicePort
• func IngressClassEnabled(client kubernetes.Interface) bool
• 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 PublishLockAvailabilityMetrics(lockName string, clusterType string)
• func RunHTTPServer(healthChecker func() context.HealthCheckResults)
• func RunSIGTERMHandler(closeStopCh func())

Variables

var (
	// LockAvailability tracks the how long has the container been running with the corresponding resource lock
	LockAvailability = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "lock_availability",
			Help: "Time in second since the container has been running with the corresponding resource lock",
		},
		[]string{"lock_name", "cluster_type"},
	)
)

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 IngressClassEnabled

func IngressClassEnabled(client kubernetes.Interface) bool

IngressClassEnabled returns whether the IngressClass API exists on the kubernetes cluster

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 NewKubeConfigForProtobuf

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

NewKubeConfigForProtobuf returns a Kubernetes client config that uses protobufs for given the command line settings.

func NewNamer

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

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

func NewStaticNamer

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 PublishLockAvailabilityMetrics

func PublishLockAvailabilityMetrics(lockName string, clusterType string)

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(closeStopCh func())