handler

Documentation

Index

• Constants
• Variables
• func GetContainerdEndpoint() string
• func GetContainerdEndpoint2() string
• func GetDockerEndpoint() string
• func GetPouchEndpoint() string
• type ContainerRuntimeHandler
  • func NewContainerdRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)
  • func NewDockerRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)
  • func NewFakeRuntimeHandler() ContainerRuntimeHandler
  • func NewPouchRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)
• 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 PouchRuntimeHandler
  • func (c *PouchRuntimeHandler) StopContainer(containerID string, timeout int64) error
  • func (c *PouchRuntimeHandler) UpdateContainerResources(containerID string, opts UpdateOptions) error
• type UpdateOptions

Constants

const (
	PouchEndpointSubFilepath = "pouchcri.sock"
)

Variables

var GetDockerClient = createDockerClient // for test

var (
	GrpcDial = grpc.DialContext // for test
)

Functions

func GetContainerdEndpoint

func GetContainerdEndpoint() string

func GetContainerdEndpoint2

func GetContainerdEndpoint2() string

func GetDockerEndpoint

func GetDockerEndpoint() string

func GetPouchEndpoint

func GetPouchEndpoint() string

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

func NewPouchRuntimeHandler

func NewPouchRuntimeHandler(endpoint string) (ContainerRuntimeHandler, error)

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 PouchRuntimeHandler

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

func (*PouchRuntimeHandler) StopContainer

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

func (*PouchRuntimeHandler) UpdateContainerResources

func (c *PouchRuntimeHandler) 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
}