reporter

Documentation

Index

• type DummyHeadroomResourceManager
  • func (mgr *DummyHeadroomResourceManager) GetAllocatable() (apiresource.Quantity, error)
  • func (mgr *DummyHeadroomResourceManager) GetCapacity() (apiresource.Quantity, error)
  • func (mgr *DummyHeadroomResourceManager) GetNumaAllocatable() (map[int]apiresource.Quantity, error)
  • func (mgr *DummyHeadroomResourceManager) GetNumaCapacity() (map[int]apiresource.Quantity, error)
• type HeadroomReporter
  • func NewHeadroomReporter(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer, ...) (*HeadroomReporter, error)
  • func (r *HeadroomReporter) Run(ctx context.Context)
• type HeadroomResourceGetter
• type HeadroomResourceManager
• type PodResourceType
• type Reporter
  • func NewNodeMetricsReporter(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer, ...) (Reporter, error)

Types

type DummyHeadroomResourceManager

type DummyHeadroomResourceManager struct{}

func (*DummyHeadroomResourceManager) GetAllocatable

func (mgr *DummyHeadroomResourceManager) GetAllocatable() (apiresource.Quantity, error)

func (*DummyHeadroomResourceManager) GetCapacity

func (mgr *DummyHeadroomResourceManager) GetCapacity() (apiresource.Quantity, error)

func (*DummyHeadroomResourceManager) GetNumaAllocatable

func (mgr *DummyHeadroomResourceManager) GetNumaAllocatable() (map[int]apiresource.Quantity, error)

func (*DummyHeadroomResourceManager) GetNumaCapacity

func (mgr *DummyHeadroomResourceManager) GetNumaCapacity() (map[int]apiresource.Quantity, error)

type HeadroomReporter

type HeadroomReporter struct {
	skeleton.GenericPlugin
	HeadroomResourceGetter
}

func NewHeadroomReporter

func NewHeadroomReporter(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer,
	conf *config.Configuration, headroomAdvisor hmadvisor.ResourceAdvisor,
) (*HeadroomReporter, error)

NewHeadroomReporter returns a wrapper of headroom reporter plugins as headroom reporter

func (*HeadroomReporter) Run

func (r *HeadroomReporter) Run(ctx context.Context)

type HeadroomResourceGetter

type HeadroomResourceGetter interface {
	GetHeadroomResource(name v1.ResourceName) (HeadroomResourceManager, error)
}

type HeadroomResourceManager

type HeadroomResourceManager interface {
	manager.ResourceManager
	manager.NumaResourceManager
}

type PodResourceType

type PodResourceType string

const (
	Guaranteed PodResourceType = "guaranteed"
	BestEffort PodResourceType = "best-effort"
	Unknown    PodResourceType = "unknown"
)

type Reporter

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

Reporter is used to report resource

func NewNodeMetricsReporter

func NewNodeMetricsReporter(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer,
	metaReader metacache.MetaReader, conf *config.Configuration,
) (Reporter, error)

NewNodeMetricsReporter returns a wrapper of node metrics reporter