kube

Documentation

Index

• func PodRequestsAndLimits(pod *corev1api.Pod) (reqs corev1api.ResourceList, limits corev1api.ResourceList)
• type Client
  • func NewKubeClient() (*Client, error)
  • func (c *Client) GetNodeResourceRequirements() (map[string]*NodeResourceRequirements, error)
• type NodeResourceRequirements
  • func (n *NodeResourceRequirements) CpuLimits() int64
  • func (n *NodeResourceRequirements) CpuReqs() int64
  • func (n *NodeResourceRequirements) FractionCpuLimits() float64
  • func (n *NodeResourceRequirements) FractionCpuReqs() float64
  • func (n *NodeResourceRequirements) FractionMemoryLimits() float64
  • func (n *NodeResourceRequirements) FractionMemoryReqs() float64
  • func (n *NodeResourceRequirements) MarshalJSON() ([]byte, error)
  • func (n *NodeResourceRequirements) MemoryLimits() int64
  • func (n *NodeResourceRequirements) MemoryReqs() int64
  • func (n *NodeResourceRequirements) RefreshTotals()
• type PodResourceRequirements

Functions

func PodRequestsAndLimits

func PodRequestsAndLimits(pod *corev1api.Pod) (reqs corev1api.ResourceList, limits corev1api.ResourceList)

PodRequestsAndLimits returns a dictionary of all defined resources summed up for all containers of the pod.

Types

type Client

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

func NewKubeClient

func NewKubeClient() (*Client, error)

func (*Client) GetNodeResourceRequirements

func (c *Client) GetNodeResourceRequirements() (map[string]*NodeResourceRequirements, error)

type NodeResourceRequirements

type NodeResourceRequirements struct {
	Name                  string
	IsRecommendedToSunset bool
	// extracted from ProviderID
	Region     string
	InstanceID string

	PodsResourceRequirements []*PodResourceRequirements
	AllocatableCpu           int64
	AllocatableMemory        int64
	// contains filtered or unexported fields
}

func (*NodeResourceRequirements) CpuLimits

func (n *NodeResourceRequirements) CpuLimits() int64

func (*NodeResourceRequirements) CpuReqs

func (n *NodeResourceRequirements) CpuReqs() int64

func (*NodeResourceRequirements) FractionCpuLimits

func (n *NodeResourceRequirements) FractionCpuLimits() float64

func (*NodeResourceRequirements) FractionCpuReqs

func (n *NodeResourceRequirements) FractionCpuReqs() float64

func (*NodeResourceRequirements) FractionMemoryLimits

func (n *NodeResourceRequirements) FractionMemoryLimits() float64

func (*NodeResourceRequirements) FractionMemoryReqs

func (n *NodeResourceRequirements) FractionMemoryReqs() float64

func (*NodeResourceRequirements) MarshalJSON

func (n *NodeResourceRequirements) MarshalJSON() ([]byte, error)

func (*NodeResourceRequirements) MemoryLimits

func (n *NodeResourceRequirements) MemoryLimits() int64

func (*NodeResourceRequirements) MemoryReqs

func (n *NodeResourceRequirements) MemoryReqs() int64

func (*NodeResourceRequirements) RefreshTotals

func (n *NodeResourceRequirements) RefreshTotals()

RefreshTotals recalculates total node requests and limits and their fractional representation need to be invoked every time when PodsResourceRequirements or AllocatableMemory or AllocatableCpu where changed

type PodResourceRequirements

type PodResourceRequirements struct {
	PodName      string `json:"podName"`
	CpuReqs      int64  `json:"cpuRequests"`
	CpuLimits    int64  `json:"cpuLimits"`
	MemoryReqs   int64  `json:"memoryRequests"`
	MemoryLimits int64  `json:"memoryLimits"`
}