engine

Documentation

Index

• Constants
• func ValidateOutputPathFileMode(fileMode os.FileMode) error
• type ContainerdContainerEngine
  • func (e *ContainerdContainerEngine) CopyFromContainer(ctx context.Context, c *cri.Container, src, dst string) error
  • func (e *ContainerdContainerEngine) CopyToContainer(ctx context.Context, c *cri.Container, src, dst string) error
  • func (e *ContainerdContainerEngine) Exec(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecResult, error)
  • func (e *ContainerdContainerEngine) ExecAsync(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecAsyncResult, error)
  • func (e *ContainerdContainerEngine) GetContainerDetail(ctx context.Context, cid string) (*cri.EngineDetailContainer, error)
  • func (e *ContainerdContainerEngine) Init() error
  • func (e *ContainerdContainerEngine) ListAllContainers(ctx context.Context) ([]*cri.EngineSimpleContainer, error)
  • func (e *ContainerdContainerEngine) Supports(feature cri.ContainerEngineFeature) bool
  • func (e *ContainerdContainerEngine) Type() string
• type DockerContainerEngine
  • func (e *DockerContainerEngine) CopyFromContainer(ctx context.Context, c *cri.Container, src, dst string) error
  • func (e *DockerContainerEngine) CopyToContainer(ctx context.Context, c *cri.Container, src, dst string) error
  • func (e *DockerContainerEngine) Exec(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecResult, error)
  • func (e *DockerContainerEngine) ExecAsync(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecAsyncResult, error)
  • func (e *DockerContainerEngine) GetContainerDetail(ctx context.Context, cid string) (*cri.EngineDetailContainer, error)
  • func (e *DockerContainerEngine) Init() error
  • func (e *DockerContainerEngine) ListAllContainers(ctx context.Context) ([]*cri.EngineSimpleContainer, error)
  • func (e *DockerContainerEngine) Supports(feature cri.ContainerEngineFeature) bool
  • func (e *DockerContainerEngine) Type() string
• type OOMManager
  • func NewOOMManager(i cri.Interface, client *dockersdk.Client) *OOMManager
  • func (m *OOMManager) Start()
  • func (m *OOMManager) Stop()

Constants

const (
	IDLength = 64
)

Functions

func ValidateOutputPathFileMode

func ValidateOutputPathFileMode(fileMode os.FileMode) error

Types

type ContainerdContainerEngine

type ContainerdContainerEngine struct {
	Client *containerd.Client
	// contains filtered or unexported fields
}

ContainerdContainerEngine Containerd container engine

func (*ContainerdContainerEngine) CopyFromContainer

func (e *ContainerdContainerEngine) CopyFromContainer(ctx context.Context, c *cri.Container, src, dst string) error

func (*ContainerdContainerEngine) CopyToContainer

func (e *ContainerdContainerEngine) CopyToContainer(ctx context.Context, c *cri.Container, src, dst string) error

func (*ContainerdContainerEngine) Exec

func (e *ContainerdContainerEngine) Exec(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecResult, error)

func (*ContainerdContainerEngine) ExecAsync

func (e *ContainerdContainerEngine) ExecAsync(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecAsyncResult, error)

func (*ContainerdContainerEngine) GetContainerDetail

func (e *ContainerdContainerEngine) GetContainerDetail(ctx context.Context, cid string) (*cri.EngineDetailContainer, error)

func (*ContainerdContainerEngine) Init

func (e *ContainerdContainerEngine) Init() error

func (*ContainerdContainerEngine) ListAllContainers

func (e *ContainerdContainerEngine) ListAllContainers(ctx context.Context) ([]*cri.EngineSimpleContainer, error)

func (*ContainerdContainerEngine) Supports

func (e *ContainerdContainerEngine) Supports(feature cri.ContainerEngineFeature) bool

func (*ContainerdContainerEngine) Type

func (e *ContainerdContainerEngine) Type() string

type DockerContainerEngine

type DockerContainerEngine struct {
	Client *dockersdk.Client
	// contains filtered or unexported fields
}

DockerContainerEngine Docker container engine

func (*DockerContainerEngine) CopyFromContainer

func (e *DockerContainerEngine) CopyFromContainer(ctx context.Context, c *cri.Container, src, dst string) error

func (*DockerContainerEngine) CopyToContainer

func (e *DockerContainerEngine) CopyToContainer(ctx context.Context, c *cri.Container, src, dst string) error

func (*DockerContainerEngine) Exec

func (e *DockerContainerEngine) Exec(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecResult, error)

func (*DockerContainerEngine) ExecAsync

func (e *DockerContainerEngine) ExecAsync(ctx context.Context, c *cri.Container, req cri.ExecRequest) (cri.ExecAsyncResult, error)

func (*DockerContainerEngine) GetContainerDetail

func (e *DockerContainerEngine) GetContainerDetail(ctx context.Context, cid string) (*cri.EngineDetailContainer, error)

func (*DockerContainerEngine) Init

func (e *DockerContainerEngine) Init() error

func (*DockerContainerEngine) ListAllContainers

func (e *DockerContainerEngine) ListAllContainers(ctx context.Context) ([]*cri.EngineSimpleContainer, error)

func (*DockerContainerEngine) Supports

func (e *DockerContainerEngine) Supports(feature cri.ContainerEngineFeature) bool

func (*DockerContainerEngine) Type

func (e *DockerContainerEngine) Type() string

type OOMManager

type OOMManager struct {
	CRI    cri.Interface
	Client *dockersdk.Client
	// contains filtered or unexported fields
}

func NewOOMManager

func NewOOMManager(i cri.Interface, client *dockersdk.Client) *OOMManager

func (*OOMManager) Start

func (m *OOMManager) Start()

func (*OOMManager) Stop

func (m *OOMManager) Stop()