reporter

Documentation

Index

• type OvercommitManager
• type OvercommitRatioReporter
  • func NewOvercommitRatioReporter(emitter metrics.MetricEmitter, conf *config.Configuration, ...) (OvercommitRatioReporter, error)
• type OvercommitRatioReporterPlugin
  • func (o *OvercommitRatioReporterPlugin) GetReportContent(_ context.Context, _ *v1alpha1.Empty) (*v1alpha1.GetReportContentResponse, error)
  • func (o *OvercommitRatioReporterPlugin) ListAndWatchReportContent(_ *v1alpha1.Empty, ...) error
  • func (o *OvercommitRatioReporterPlugin) Name() string
  • func (o *OvercommitRatioReporterPlugin) Start() (err error)
  • func (o *OvercommitRatioReporterPlugin) Stop() error

Types

type OvercommitManager

type OvercommitManager interface {
	GetOvercommitRatio() (map[v1.ResourceName]float64, error)
}

type OvercommitRatioReporter

type OvercommitRatioReporter interface {
	Run(ctx context.Context)
}

OvercommitRatioReporter report node overcommitment ratio calculated by agent

func NewOvercommitRatioReporter

func NewOvercommitRatioReporter(
	emitter metrics.MetricEmitter,
	conf *config.Configuration,
	manager OvercommitManager,
	metaServer *metaserver.MetaServer,
) (OvercommitRatioReporter, error)

type OvercommitRatioReporterPlugin

type OvercommitRatioReporterPlugin struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*OvercommitRatioReporterPlugin) GetReportContent

func (o *OvercommitRatioReporterPlugin) GetReportContent(_ context.Context, _ *v1alpha1.Empty) (*v1alpha1.GetReportContentResponse, error)

GetReportContent get overcommitment ratio from manager directly. Since the metrics collected by Manager are already an average within a time period, we expect a faster response to node load fluctuations to avoid excessive overcommit of online resources.

func (*OvercommitRatioReporterPlugin) ListAndWatchReportContent

func (o *OvercommitRatioReporterPlugin) ListAndWatchReportContent(_ *v1alpha1.Empty, server v1alpha1.ReporterPlugin_ListAndWatchReportContentServer) error

func (*OvercommitRatioReporterPlugin) Name

func (o *OvercommitRatioReporterPlugin) Name() string

func (*OvercommitRatioReporterPlugin) Start

func (o *OvercommitRatioReporterPlugin) Start() (err error)

func (*OvercommitRatioReporterPlugin) Stop

func (o *OvercommitRatioReporterPlugin) Stop() error