cgroup

Documentation

Index

• func AddContainerIDToCache(pid uint64, containerID string)
• func GetAliveContainers() (map[string]bool, error)
• func GetContainerID(cGroupID, pid uint64, withCGroupID bool) (string, error)
• func GetContainerIDFromPID(pid uint64) (string, error)
• func Init() (*[]corev1.Pod, error)
• func ParseContainerIDFromPodStatus(containerID string) string
• type CCgroupStatHandler
  • func NewCGroupStatManager(pid int) (CCgroupStatHandler, error)
• type CCgroupV1StatManager
  • func (c CCgroupV1StatManager) SetCGroupStat(containerID string, cgroupStatMap map[string]*types.UInt64StatCollection) error
• type CCgroupV2StatManager
  • func (c CCgroupV2StatManager) SetCGroupStat(containerID string, cgroupStatMap map[string]*types.UInt64StatCollection) error
• type ContainerInfo
  • func GetContainerInfo(cGroupID, pid uint64, withCGroupID bool) (*ContainerInfo, error)

Functions

func AddContainerIDToCache

func AddContainerIDToCache(pid uint64, containerID string)

AddContainerIDToCache add the container id to cache using the pid as the key

func GetAliveContainers

func GetAliveContainers() (map[string]bool, error)

GetAliveContainers returns alive pod map

func GetContainerID

func GetContainerID(cGroupID, pid uint64, withCGroupID bool) (string, error)

func GetContainerIDFromPID

func GetContainerIDFromPID(pid uint64) (string, error)

GetContainerIDFromPID find the container ID using the process PID

func Init

func Init() (*[]corev1.Pod, error)

func ParseContainerIDFromPodStatus

func ParseContainerIDFromPodStatus(containerID string) string

Types

type CCgroupStatHandler

type CCgroupStatHandler interface {
	SetCGroupStat(containerID string, CgroupStatMap map[string]*types.UInt64StatCollection) error
}

func NewCGroupStatManager

func NewCGroupStatManager(pid int) (CCgroupStatHandler, error)

NewCGroupStatManager creates a new cgroup stat object that can return the current metrics of the cgroup To avoid casting of interfaces, the CCgroupStatHandler has a handler for cgroup V1 or V2. See comments here: https://github.com/sustainable-computing-io/kepler/pull/609#discussion_r1155043868

type CCgroupV1StatManager

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

func (CCgroupV1StatManager) SetCGroupStat

func (c CCgroupV1StatManager) SetCGroupStat(containerID string, cgroupStatMap map[string]*types.UInt64StatCollection) error

type CCgroupV2StatManager

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

func (CCgroupV2StatManager) SetCGroupStat

func (c CCgroupV2StatManager) SetCGroupStat(containerID string, cgroupStatMap map[string]*types.UInt64StatCollection) error

type ContainerInfo

type ContainerInfo struct {
	ContainerID   string
	ContainerName string
	PodName       string
	Namespace     string
}

func GetContainerInfo

func GetContainerInfo(cGroupID, pid uint64, withCGroupID bool) (*ContainerInfo, error)