containerd

Documentation

Overview

This code has been taken from containerd repo to avoid large library import

Handler for containerd containers.

Index

• Variables
• func ContainerNameToContainerdID(name string) string
• func NewPlugin() container.Plugin
• func Register(factory info.MachineInfoFactory, fsInfo fs.FsInfo, ...) error
• type ContainerdClient
  • func Client(address, namespace string) (ContainerdClient, error)

Variables

var ArgContainerdEndpoint = flag.String("containerd", "/run/containerd/containerd.sock", "containerd endpoint")

var ArgContainerdNamespace = flag.String("containerd-namespace", "k8s.io", "containerd namespace")

var (
	ErrTaskIsInUnknownState = errors.New("containerd task is in unknown state") // used when process reported in containerd task is in Unknown State
)

Functions

func ContainerNameToContainerdID

func ContainerNameToContainerdID(name string) string

Returns the containerd ID from the full container name.

func NewPlugin

func NewPlugin() container.Plugin

NewPlugin returns an implementation of container.Plugin suitable for passing to container.RegisterPlugin()

func Register

func Register(factory info.MachineInfoFactory, fsInfo fs.FsInfo, includedMetrics container.MetricSet) error

Register root container before running this function!

Types

type ContainerdClient

type ContainerdClient interface {
	LoadContainer(ctx context.Context, id string) (*containers.Container, error)
	TaskPid(ctx context.Context, id string) (uint32, error)
	Version(ctx context.Context) (string, error)
	SnapshotMounts(ctx context.Context, snapshotter, key string) ([]*types.Mount, error)
	ContainerStatus(ctx context.Context, id string) (*criapi.ContainerStatus, error)
	ContainerStats(ctx context.Context, id string) (*criapi.ContainerStats, error)
}

func Client

func Client(address, namespace string) (ContainerdClient, error)

Client creates a containerd client