resource

Documentation

Index

• Constants
• type NodeResourceManager
  • func NewNodeResourceManager(client clientset.Interface, nodeName string, ...) *NodeResourceManager
  • func (o *NodeResourceManager) BuildNodeStatus(tsp *predictionapi.TimeSeriesPrediction, node *v1.Node)
  • func (o *NodeResourceManager) FindTargetNode(tsp *predictionapi.TimeSeriesPrediction, addresses []v1.NodeAddress) (bool, error)
  • func (o *NodeResourceManager) Name() string
  • func (o *NodeResourceManager) Run(stop <-chan struct{})
  • func (o *NodeResourceManager) UpdateNodeResource()
• type PodResourceManager
  • func NewPodResourceManager(client clientset.Interface, nodeName string, ...) *PodResourceManager
  • func (o *PodResourceManager) Name() string
  • func (o *PodResourceManager) Run(stop <-chan struct{})

Constants

const (
	MinDeltaRatio     = 0.1
	StateExpiration   = 1 * time.Minute
	TspUpdateInterval = 20 * time.Second
)

Types

type NodeResourceManager

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

func NewNodeResourceManager

func NewNodeResourceManager(client clientset.Interface, nodeName string, podInformer coreinformers.PodInformer, nodeInformer coreinformers.NodeInformer,
	tspInformer predictionv1.TimeSeriesPredictionInformer, runtimeEndpoint string, stateChann chan map[string][]common.TimeSeries) *NodeResourceManager

func (*NodeResourceManager) BuildNodeStatus

func (o *NodeResourceManager) BuildNodeStatus(tsp *predictionapi.TimeSeriesPrediction, node *v1.Node)

func (*NodeResourceManager) FindTargetNode

func (o *NodeResourceManager) FindTargetNode(tsp *predictionapi.TimeSeriesPrediction, addresses []v1.NodeAddress) (bool, error)

func (*NodeResourceManager) Name

func (o *NodeResourceManager) Name() string

func (*NodeResourceManager) Run

func (o *NodeResourceManager) Run(stop <-chan struct{})

func (*NodeResourceManager) UpdateNodeResource

func (o *NodeResourceManager) UpdateNodeResource()

type PodResourceManager

type PodResourceManager struct {
	cadvisor.Manager
	// contains filtered or unexported fields
}

func NewPodResourceManager

func NewPodResourceManager(client clientset.Interface, nodeName string, podInformer coreinformers.PodInformer,
	runtimeEndpoint string, stateChann chan map[string][]common.TimeSeries, cadvisorManager cadvisor.Manager) *PodResourceManager

func (*PodResourceManager) Name

func (o *PodResourceManager) Name() string

func (*PodResourceManager) Run

func (o *PodResourceManager) Run(stop <-chan struct{})