qosaware

Documentation

Index

• Constants
• func NewQoSAwarePlugin(pluginName string, conf *config.Configuration, extraConf interface{}, ...) (plugin.SysAdvisorPlugin, error)
• type QoSAwarePlugin
  • func (qap *QoSAwarePlugin) Init() error
  • func (qap *QoSAwarePlugin) Name() string
  • func (qap *QoSAwarePlugin) Run(ctx context.Context)

Constants

const (
	// MetricsNamePlugQoSAwareHearBeat is the heartbeat metrics of qos aware plugin
	MetricsNamePlugQoSAwareHearBeat = "plugin_qosaware_heartbeat"
)

Functions

func NewQoSAwarePlugin

func NewQoSAwarePlugin(pluginName string, conf *config.Configuration, extraConf interface{}, emitterPool metricspool.MetricsEmitterPool,
	metaServer *metaserver.MetaServer, metaCache metacache.MetaCache,
) (plugin.SysAdvisorPlugin, error)

NewQoSAwarePlugin creates a qos aware plugin with the specified config

Types

type QoSAwarePlugin

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

QoSAwarePlugin calculates node headroom and updates resource provision value suggestions using different algorithms configured by user. Resource headroom data will be reported by the reporter and provision result will be sync to QRM plugin by gRPC. To take different resource dimensions into consideration, implement calculators or algorithms for each resource and register them to qos aware plugin.

func (*QoSAwarePlugin) Init

func (qap *QoSAwarePlugin) Init() error

Init initializes the qos aware plugin

func (*QoSAwarePlugin) Name

func (qap *QoSAwarePlugin) Name() string

Name returns the name of qos aware plugin

func (*QoSAwarePlugin) Run

func (qap *QoSAwarePlugin) Run(ctx context.Context)

Run starts the qos aware plugin, which periodically inspects cpu usage and takes measures.