clusterstatus

Documentation

Index

• type Controller
  • func NewController(apiserverURL string, kubeClient kubernetes.Interface, ...) *Controller
  • func (c *Controller) GetClusterStatus() *clusterapi.ManagedClusterStatus
  • func (c *Controller) GetManagedClusterLabels(labelPrefixes []string) labels.Set
  • func (c *Controller) Run(ctx context.Context)

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller is a controller that collects cluster status

func NewController

func NewController(
	apiserverURL string,
	kubeClient kubernetes.Interface,
	metricClient *metricsv.Clientset,
	kubeInformerFactory informers.SharedInformerFactory,
	predictorAddress string,
	predictorDirectAccess, useMetricsServer bool,
	collectingPeriod metav1.Duration,
	heartbeatFrequency metav1.Duration,
	labelAggregateThreshold float32,
	kubeQPS float32,
	kubeBurst int32,
) *Controller

func (*Controller) GetClusterStatus

func (c *Controller) GetClusterStatus() *clusterapi.ManagedClusterStatus

func (*Controller) GetManagedClusterLabels

func (c *Controller) GetManagedClusterLabels(labelPrefixes []string) labels.Set

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)