Documentation
¶
Index ¶
- func GetNodeWithName(name string, nodes []*v1.Node) *v1.Node
- type Client
- func (c Client) GetExecutionTime(pod string) int32
- func (c *Client) GetFreeMemoryNode(name string) (float64, error)
- func (c *Client) GetFreeMemoryOfNodes() (monitoring.NodeFreeMemMap, error)
- func (c *Client) GetPodMemories(node string) (monitoring.PodMemMap, error)
- func (c Client) GetPodMemorySlope(node, name, time, slopeWindow string) (float64, error)
- func (c Client) GetRuntime(pod string) int32
- func (c Client) GetRuntimePercentage(pod string) float64
- func (c *Client) UpdateNodeMetrics(metrics map[string]node.Metrics)
- func (c *Client) UpdatePodMetric(podname string, pd pod.Metrics)
- func (c *Client) UpdatePodMetrics(pods map[string]pod.Metrics)
- type Memorizer
- type MigrationSubmitter
- func NewSubmitter(controller monitoring.ControllerI) *MigrationSubmitter
- func NewSubmitterWithJobs(controller monitoring.ControllerI, jobs []jobparser.PodMemory) *MigrationSubmitter
- func NewSubmitterWithJobsWithEndTime(controller monitoring.ControllerI, jobs []jobparser.PodMemory, ...) *MigrationSubmitter
- func NewSubmitterWithJobsWithEndTimeFactory(controller monitoring.ControllerI, jobs []jobparser.PodMemory, ...) *MigrationSubmitter
- type Unscheduler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct { UsedMemoryMap map[string]int64 // key: nodeName TotalMemoryMap map[string]int64 // key: nodeName PodMemoryMap map[string]monitoring.PodMemMap // key: nodeName PodRuntime map[string]int32 // key: podName PodExecution map[string]int32 // key: podName PodMemorizer map[string]*Memorizer[monitoring.PodMemMap] MemoInterval int }
func NewClientWithMemoStep ¶
func (Client) GetExecutionTime ¶
func (*Client) GetFreeMemoryOfNodes ¶
func (c *Client) GetFreeMemoryOfNodes() (monitoring.NodeFreeMemMap, error)
func (*Client) GetPodMemories ¶
func (c *Client) GetPodMemories(node string) (monitoring.PodMemMap, error)
in Gb
func (Client) GetPodMemorySlope ¶
func (Client) GetRuntime ¶
func (Client) GetRuntimePercentage ¶
func (*Client) UpdateNodeMetrics ¶
type Memorizer ¶
type MigrationSubmitter ¶
type MigrationSubmitter struct {
// contains filtered or unexported fields
}
func NewSubmitter ¶
func NewSubmitter(controller monitoring.ControllerI) *MigrationSubmitter
func NewSubmitterWithJobs ¶
func NewSubmitterWithJobs(controller monitoring.ControllerI, jobs []jobparser.PodMemory) *MigrationSubmitter
func NewSubmitterWithJobsWithEndTime ¶
func NewSubmitterWithJobsWithEndTime(controller monitoring.ControllerI, jobs []jobparser.PodMemory, endTime time.Time) *MigrationSubmitter
func NewSubmitterWithJobsWithEndTimeFactory ¶
func NewSubmitterWithJobsWithEndTimeFactory(controller monitoring.ControllerI, jobs []jobparser.PodMemory, endTime time.Time, factory jobparser.PodFactory, checker monitoring.MigrationCheckerI) *MigrationSubmitter
Click to show internal directories.
Click to hide internal directories.