pod

Documentation

Index

• Constants
• func EnsureContainerSystemCpuDir(cpuDir string, cpuCount int64) error
• func EnsureDir(dir string) error
• func EnsureFile(filename string, content string, mod string) error
• type CRI
  • func NewCRI(endpoint string, timeout time.Duration) (CRI, error)
• type CgroupUtil
  • func NewPodCgroupV1Util(parentPath string) CgroupUtil
• type ContainerCPU
  • func NewContainerCPU(ctrId string, ctrIdx int) *ContainerCPU
• type HostContainerCPU
  • func NewHostContainerCPU(hostIndex int) *HostContainerCPU
  • func (h *HostContainerCPU) DeleteContainer(ctrId string)
  • func (h *HostContainerCPU) HasContainer(ctrId string) bool
  • func (h *HostContainerCPU) InsertContainer(ctrId string, ctrIdx int)
• type HostContainerCPUMap
  • func NewHostContainerCPUMap(topo *hostapi.HostTopology, stateFile string) (*HostContainerCPUMap, error)
  • func (hm *HostContainerCPUMap) Delete(ctrId string) error
  • func (hm *HostContainerCPUMap) Get(ctrId string, ctrCpuIndex int) (int, error)
• type ListContainerOptions
• type ListPodOptions
• type RunContainersResponse

Constants

const (
	CGROUP_PATH_SYSFS = "/sys/fs/cgroup"
)

Functions

func EnsureContainerSystemCpuDir

func EnsureContainerSystemCpuDir(cpuDir string, cpuCount int64) error

func EnsureDir

func EnsureDir(dir string) error

func EnsureFile

func EnsureFile(filename string, content string, mod string) error

Types

type CRI

type CRI interface {
	Version(ctx context.Context) (*runtimeapi.VersionResponse, error)
	ListPods(ctx context.Context, opts ListPodOptions) ([]*runtimeapi.PodSandbox, error)
	RunPod(ctx context.Context, podConfig *runtimeapi.PodSandboxConfig, runtimeHandler string) (string, error)
	StopPod(ctx context.Context, req *runtimeapi.StopPodSandboxRequest) error
	RemovePod(ctx context.Context, podId string) error
	CreateContainer(ctx context.Context, podId string, podConfig *runtimeapi.PodSandboxConfig, ctrConfig *runtimeapi.ContainerConfig, withPull bool) (string, error)
	StartContainer(ctx context.Context, id string) error
	StopContainer(ctx context.Context, ctrId string, timeout int64) error
	RemoveContainer(ctx context.Context, ctrId string) error
	RunContainers(ctx context.Context, podConfig *runtimeapi.PodSandboxConfig, containerConfigs []*runtimeapi.ContainerConfig, runtimeHandler string) (*RunContainersResponse, error)
	ListContainers(ctx context.Context, opts ListContainerOptions) ([]*runtimeapi.Container, error)
	ContainerStatus(ctx context.Context, ctrId string) (*runtimeapi.ContainerStatusResponse, error)
	ListImages(ctx context.Context, filter *runtimeapi.ImageFilter) ([]*runtimeapi.Image, error)
	PullImage(ctx context.Context, req *runtimeapi.PullImageRequest) (*runtimeapi.PullImageResponse, error)
	ImageStatus(ctx context.Context, req *runtimeapi.ImageStatusRequest) (*runtimeapi.ImageStatusResponse, error)

	// lower layer client
	GetImageClient() runtimeapi.ImageServiceClient
	GetRuntimeClient() runtimeapi.RuntimeServiceClient
}

func NewCRI

func NewCRI(endpoint string, timeout time.Duration) (CRI, error)

type CgroupUtil

type CgroupUtil interface {
	SetMemoryLimitBytes(ctrId string, bytes int64) error
	SetCPUCfs(ctrId string, quota int64, period int64) error
	SetDevicesAllow(ctrId string, allows []string) error
	SetPidsMax(ctrId string, max int) error
}

func NewPodCgroupV1Util

func NewPodCgroupV1Util(parentPath string) CgroupUtil

type ContainerCPU

type ContainerCPU struct {
	ContainerId string `json:"container_id"`
	Index       int    `json:"index"`
}

func NewContainerCPU

func NewContainerCPU(ctrId string, ctrIdx int) *ContainerCPU

type HostContainerCPU

type HostContainerCPU struct {
	Index      int                        `json:"index"`
	Containers map[string][]*ContainerCPU `json:"containers"`
}

func NewHostContainerCPU

func NewHostContainerCPU(hostIndex int) *HostContainerCPU

func (*HostContainerCPU) DeleteContainer

func (h *HostContainerCPU) DeleteContainer(ctrId string)

func (*HostContainerCPU) HasContainer

func (h *HostContainerCPU) HasContainer(ctrId string) bool

func (*HostContainerCPU) InsertContainer

func (h *HostContainerCPU) InsertContainer(ctrId string, ctrIdx int)

type HostContainerCPUMap

type HostContainerCPUMap struct {
	Map map[string]*HostContainerCPU `json:"map"`
	// contains filtered or unexported fields
}

func NewHostContainerCPUMap

func NewHostContainerCPUMap(topo *hostapi.HostTopology, stateFile string) (*HostContainerCPUMap, error)

func (*HostContainerCPUMap) Delete

func (hm *HostContainerCPUMap) Delete(ctrId string) error

func (*HostContainerCPUMap) Get

func (hm *HostContainerCPUMap) Get(ctrId string, ctrCpuIndex int) (int, error)

type ListContainerOptions

type ListContainerOptions struct {
	// Id of container
	Id string
	// PodId of container
	PodId string
	// Regular expression pattern to match pod or container
	NameRegexp string
	// Regular expression pattern to match the pod namespace
	PodNamespaceRegexp string
	// State of the sandbox
	State string
	// Show verbose info for the sandbox
	Verbose bool
	// Labels are selectors for the sandbox
	Labels map[string]string
	// Image ued by the container
	Image string
}

type ListPodOptions

type ListPodOptions struct {
	Id    string
	State string
}

type RunContainersResponse

type RunContainersResponse struct {
	PodId        string   `json:"pod_id"`
	ContainerIds []string `json:"container_ids"`
}