resources

Documentation

Index

• Constants
• func PatchPodResourceLimitList(pod *corev1.Pod, resourceList *corev1.ResourceList)
• func RequestBitflowResourceLimitByNode(node *corev1.Node, conf *config.Config) float64
• type NodeInfo
  • func (nodeInfo *NodeInfo) GetCurrentResourceList(initSize, spawning int, factor float64) *corev1.ResourceList
  • func (nodeInfo *NodeInfo) String() string
• type ResourceAssigner
  • func (res *ResourceAssigner) AssignResources(pod *corev1.Pod, node *corev1.Node) *corev1.ResourceList
  • func (res *ResourceAssigner) AssignResourcesNodeImplicit(pod *corev1.Pod) *corev1.ResourceList
  • func (res *ResourceAssigner) GetCurrentResources(node *corev1.Node) *corev1.ResourceList
  • func (res *ResourceAssigner) RequestNodeInfo(node *corev1.Node, podName string) NodeInfo

Constants

const (
	MBytes = 1024 * 1024
	GBytes = 1024 * MBytes
)

Functions

func PatchPodResourceLimitList

func PatchPodResourceLimitList(pod *corev1.Pod, resourceList *corev1.ResourceList)

func RequestBitflowResourceLimitByNode

func RequestBitflowResourceLimitByNode(node *corev1.Node, conf *config.Config) float64

Types

type NodeInfo

type NodeInfo struct {
	NumberOfBitflowContainers int
	TotalResourceLimit        float64
	AllocatableResources      corev1.ResourceList
}

func (*NodeInfo) GetCurrentResourceList

func (nodeInfo *NodeInfo) GetCurrentResourceList(initSize, spawning int, factor float64) *corev1.ResourceList

func (*NodeInfo) String

func (nodeInfo *NodeInfo) String() string

type ResourceAssigner

type ResourceAssigner struct {
	Client     client.Client
	Config     *config.Config
	Respawning *common.RespawningPods
	Namespace  string
	PodLabels  map[string]string
}

func (*ResourceAssigner) AssignResources

func (res *ResourceAssigner) AssignResources(pod *corev1.Pod, node *corev1.Node) *corev1.ResourceList

func (*ResourceAssigner) AssignResourcesNodeImplicit

func (res *ResourceAssigner) AssignResourcesNodeImplicit(pod *corev1.Pod) *corev1.ResourceList

AssignResourcesNodeImplicit: Assumes the pod was once already deployed and still includes information about the former node on which this pod was placed

func (*ResourceAssigner) GetCurrentResources

func (res *ResourceAssigner) GetCurrentResources(node *corev1.Node) *corev1.ResourceList

func (*ResourceAssigner) RequestNodeInfo

func (res *ResourceAssigner) RequestNodeInfo(node *corev1.Node, podName string) NodeInfo