handler

Documentation

Index

• Variables
• type ContainerRuntimeHandler
  • func NewContainerdRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)
  • func NewDockerRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)
  • func NewFakeRuntimeHandler() ContainerRuntimeHandler
• type ContainerdRuntimeHandler
  • func (c *ContainerdRuntimeHandler) StopContainer(containerID string, timeout int64) error
  • func (c *ContainerdRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error
• type DockerRuntimeHandler
  • func (d *DockerRuntimeHandler) StopContainer(containerID string, timeout int64) error
  • func (d *DockerRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error
• type FakeRuntimeHandler
  • func (f *FakeRuntimeHandler) SetFakeContainers(containers []*testing.FakeContainer)
  • func (f *FakeRuntimeHandler) StopContainer(containerID string, timeout int64) error
  • func (f *FakeRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error
• type UpdateOptions

Variables

var (
	ContainerdEndpoint1 = filepath.Join(system.Conf.VarRunRootDir, "containerd.sock")
	ContainerdEndpoint2 = filepath.Join(system.Conf.VarRunRootDir, "containerd/containerd.sock")

	GrpcDial = grpc.DialContext // for test
)

var (
	DockerEndpoint = filepath.Join(system.Conf.VarRunRootDir, "docker.sock")
)

var GetDockerClient = createDockerClient // for test

Types

type ContainerRuntimeHandler

type ContainerRuntimeHandler interface {
	StopContainer(containerID string, timeout int64) error
	UpdateContainerResources(containerID string, opts UpdateOptions) error
}

func NewContainerdRuntimeHandler

func NewContainerdRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)

func NewDockerRuntimeHandler

func NewDockerRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)

func NewFakeRuntimeHandler

func NewFakeRuntimeHandler() ContainerRuntimeHandler

type ContainerdRuntimeHandler

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

func (*ContainerdRuntimeHandler) StopContainer

func (c *ContainerdRuntimeHandler) StopContainer(containerID string, timeout int64) error

func (*ContainerdRuntimeHandler) UpdateContainerResources

func (c *ContainerdRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error

type DockerRuntimeHandler

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

func (*DockerRuntimeHandler) StopContainer

func (d *DockerRuntimeHandler) StopContainer(containerID string, timeout int64) error

func (*DockerRuntimeHandler) UpdateContainerResources

func (d *DockerRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error

type FakeRuntimeHandler

type FakeRuntimeHandler struct {
	PodMetas map[string]*statesinformer.PodMeta
	// contains filtered or unexported fields
}

func (*FakeRuntimeHandler) SetFakeContainers

func (f *FakeRuntimeHandler) SetFakeContainers(containers []*testing.FakeContainer)

func (*FakeRuntimeHandler) StopContainer

func (f *FakeRuntimeHandler) StopContainer(containerID string, timeout int64) error

func (*FakeRuntimeHandler) UpdateContainerResources

func (f *FakeRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error

type UpdateOptions

type UpdateOptions struct {
	// CPU CFS (Completely Fair Scheduler) period. Default: 0 (not specified).
	CPUPeriod int64
	// CPU CFS (Completely Fair Scheduler) quota. Default: 0 (not specified).
	CPUQuota int64
	// CPU shares (relative weight vs. other containers). Default: 0 (not specified).
	CPUShares int64
	// Memory limit in bytes. Default: 0 (not specified).
	MemoryLimitInBytes int64
	// OOMScoreAdj adjusts the oom-killer score. Default: 0 (not specified).
	OomScoreAdj int64
	// CpuSetCpus constrains the allowed set of logical CPUs. Default: "" (not specified).
	CpusetCpus string
	// CpuSetMems constrains the allowed set of memory nodes. Default: "" (not specified).
	CpusetMems string
	// SpecAnnotationFilePath is the file path to specAnnotations. In JSON|Yaml format.
	SpecAnnotationFilePath string
}