app

Documentation

Index

• Variables
• func DefaultBackendServicePort(kubeClient kubernetes.Interface, logger klog.Logger) utils.ServicePort
• func IngressClassEnabled(client kubernetes.Interface, logger klog.Logger) bool
• func NewGCEClient(logger klog.Logger) *gce.Cloud
• func NewKubeConfig(logger klog.Logger) (*rest.Config, error)
• func NewKubeConfigForProtobuf(logger klog.Logger) (*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, logger klog.Logger)
• func RunSIGTERMHandler(closeStopCh func(), logger klog.Logger)

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, logger klog.Logger) utils.ServicePort

DefaultBackendServicePort returns the ServicePort which will be used as the default backend for load balancers.

func IngressClassEnabled

func IngressClassEnabled(client kubernetes.Interface, logger klog.Logger) bool

IngressClassEnabled returns whether the IngressClass API exists on the kubernetes cluster

func NewGCEClient

func NewGCEClient(logger klog.Logger) *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(logger klog.Logger) (*rest.Config, error)

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

func NewKubeConfigForProtobuf

func NewKubeConfigForProtobuf(logger klog.Logger) (*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, logger klog.Logger) (*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, logger klog.Logger) (*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, logger klog.Logger)

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(), logger klog.Logger)