nodeslo

Documentation

Index

• Constants
• func Add(mgr ctrl.Manager) error
• func RegisterDefaultExtension(key string, ext interface{}) error
• func RegisterNodeSLOMergedExtender(name string, extender NodeSLOMergedPlugin) error
• func UnregisterDefaultExtension(key string)
• func UnregisterNodeSLOMergedExtender(name string)
• type NodeSLOMergedPlugin
• type NodeSLOReconciler
  • func (r *NodeSLOReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeSLOReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SLOCfg
  • func DefaultSLOCfg() SLOCfg
  • func (in *SLOCfg) DeepCopy() *SLOCfg
• type SLOCfgCache
• type SLOCfgHandlerForConfigMapEvent
  • func NewSLOCfgHandlerForConfigMapEvent(client client.Client, initCfg SLOCfg, recorder record.EventRecorder) *SLOCfgHandlerForConfigMapEvent
  • func (p *SLOCfgHandlerForConfigMapEvent) GetCfgCopy() *SLOCfg
  • func (p *SLOCfgHandlerForConfigMapEvent) IsCfgAvailable() bool

Constants

const Name = "nodeslo"

Functions

func Add

func Add(mgr ctrl.Manager) error

func RegisterDefaultExtension

func RegisterDefaultExtension(key string, ext interface{}) error

func RegisterNodeSLOMergedExtender

func RegisterNodeSLOMergedExtender(name string, extender NodeSLOMergedPlugin) error

func UnregisterDefaultExtension

func UnregisterDefaultExtension(key string)

func UnregisterNodeSLOMergedExtender

func UnregisterNodeSLOMergedExtender(name string)

Types

type NodeSLOMergedPlugin

type NodeSLOMergedPlugin interface {
	// calculate each extension cfg merged
	MergeNodeSLOExtension(oldCfgMap configuration.ExtensionCfgMap, configMap *corev1.ConfigMap, recorder record.EventRecorder) (configuration.ExtensionCfgMap, error)
	// get each extension config spec
	GetNodeSLOExtension(node *corev1.Node, cfg *configuration.ExtensionCfgMap) (string, interface{}, error)
}

type NodeSLOReconciler

type NodeSLOReconciler struct {
	client.Client

	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

NodeSLOReconciler reconciles a NodeSLO object

func (*NodeSLOReconciler) Reconcile

func (r *NodeSLOReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NodeSLOReconciler) SetupWithManager

func (r *NodeSLOReconciler) SetupWithManager(mgr ctrl.Manager) error

type SLOCfg

type SLOCfg struct {
	ThresholdCfgMerged   configuration.ResourceThresholdCfg `json:"thresholdCfgMerged,omitempty"`
	ResourceQOSCfgMerged configuration.ResourceQOSCfg       `json:"resourceQOSCfgMerged,omitempty"`
	CPUBurstCfgMerged    configuration.CPUBurstCfg          `json:"cpuBurstCfgMerged,omitempty"`
	SystemCfgMerged      configuration.SystemCfg            `json:"systemCfgMerged,omitempty"`
	HostAppCfgMerged     configuration.HostApplicationCfg   `json:"hostAppCfgMerged,omitempty"`
	ExtensionCfgMerged   configuration.ExtensionCfgMap      `json:"extensionCfgMerged,omitempty"` // for third-party extension
}

func DefaultSLOCfg

func DefaultSLOCfg() SLOCfg

func (*SLOCfg) DeepCopy

func (in *SLOCfg) DeepCopy() *SLOCfg

type SLOCfgCache

type SLOCfgCache interface {
	GetCfgCopy() *SLOCfg
	IsCfgAvailable() bool
}

type SLOCfgHandlerForConfigMapEvent

type SLOCfgHandlerForConfigMapEvent struct {
	config.EnqueueRequestForConfigMap

	Client client.Client
	// contains filtered or unexported fields
}

func NewSLOCfgHandlerForConfigMapEvent

func NewSLOCfgHandlerForConfigMapEvent(client client.Client, initCfg SLOCfg, recorder record.EventRecorder) *SLOCfgHandlerForConfigMapEvent

func (*SLOCfgHandlerForConfigMapEvent) GetCfgCopy

func (p *SLOCfgHandlerForConfigMapEvent) GetCfgCopy() *SLOCfg

func (*SLOCfgHandlerForConfigMapEvent) IsCfgAvailable

func (p *SLOCfgHandlerForConfigMapEvent) IsCfgAvailable() bool