metricsadapter

Documentation

Index

• Variables
• type MetricsAdapter
  • func NewMetricsAdapter(controller *MetricsController, ...) *MetricsAdapter
• type MetricsController
  • func NewMetricsController(stopCh <-chan struct{}, restConfig *rest.Config, ...) *MetricsController
• type MetricsServer
  • func NewMetricsServer(controller *MetricsController, metricsAdapter *MetricsAdapter) *MetricsServer
  • func (m *MetricsServer) StartServer(stopCh <-chan struct{}) error

Variables

var (
	// NamespacesGVR is the gvr of namespaces
	NamespacesGVR = corev1.SchemeGroupVersion.WithResource("namespaces")
)

Types

type MetricsAdapter

type MetricsAdapter struct {
	basecmd.AdapterBase

	*provider.ResourceMetricsProvider
}

MetricsAdapter is a metrics adapter to provider native metrics, custom metrics and external metrics

func NewMetricsAdapter

func NewMetricsAdapter(controller *MetricsController, customMetricsAdapterServerOptions *options.CustomMetricsAdapterServerOptions) *MetricsAdapter

NewMetricsAdapter creates a new metrics adapter

type MetricsController

type MetricsController struct {
	InformerFactory       informerfactory.SharedInformerFactory
	ClusterLister         clusterlister.ClusterLister
	InformerManager       genericmanager.MultiClusterInformerManager
	TypedInformerManager  typedmanager.MultiClusterInformerManager
	MultiClusterDiscovery multiclient.MultiClusterDiscoveryInterface
	// contains filtered or unexported fields
}

MetricsController is a controller for metrics, control the lifecycle of multi-clusters informer

func NewMetricsController

func NewMetricsController(stopCh <-chan struct{}, restConfig *rest.Config, factory informerfactory.SharedInformerFactory, kubeFactory informers.SharedInformerFactory, clusterClientOption *util.ClientOption) *MetricsController

NewMetricsController creates a new metrics controller

type MetricsServer

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

MetricsServer is a metrics server

func NewMetricsServer

func NewMetricsServer(controller *MetricsController, metricsAdapter *MetricsAdapter) *MetricsServer

NewMetricsServer creates a new metrics server

func (*MetricsServer) StartServer

func (m *MetricsServer) StartServer(stopCh <-chan struct{}) error

StartServer starts the metrics server