containerruntime

Documentation

Index

• Constants
• func NewContainerdClient() (*containerd.Client, error)
• type ContainerUtility
  • func (c *ContainerUtility) CloseClientConnection()
  • func (c *ContainerUtility) CreateContainer(ctx context.Context, containerName string, containerImage string) (containerd.Container, error)
  • func (c *ContainerUtility) DestroyContainersInNamespace(ctx context.Context, namespace string) error
  • func (c *ContainerUtility) DestroyContainersInNamespacesList(ctx context.Context, namespaces []string) error
  • func (c *ContainerUtility) EnsureContainerDestroyed(ctx context.Context, containerName string, timeoutStr string) error
  • func (c *ContainerUtility) EnsureContainerStoppedOrNonExistent(ctx context.Context, containerName string) error
  • func (c *ContainerUtility) EnsureContainersDestroyed(ctx context.Context, containers []containerd.Container, timeoutStr string) error
  • func (c *ContainerUtility) EnsureFreshContainerRunning(ctx context.Context, containerName string, containerImage string) error
  • func (c *ContainerUtility) GetContainerWithGivenName(ctx context.Context, containerName string) (containerd.Container, error)
  • func (c *ContainerUtility) GetContainersInNamespace(ctx context.Context, namespace string) ([]containerd.Container, error)
  • func (c *ContainerUtility) RemoveContainer(ctx context.Context, container containerd.Container, force bool) error
  • func (c *ContainerUtility) StopContainer(ctx context.Context, container containerd.Container, timeoutStr string) error
• type ContainerUtils
  • func NewContainerUtil() (ContainerUtils, error)
• type ImageUtility
  • func (i *ImageUtility) LoadImagesFromDir(ctx context.Context, imageDir string, namespace string) error
  • func (i *ImageUtility) LoadImagesFromFile(ctx context.Context, fileName string) error
• type ImageUtils
  • func NewImageUtil() ImageUtils

Constants

const TimeOut = "10s"

Functions

func NewContainerdClient

func NewContainerdClient() (*containerd.Client, error)

Types

type ContainerUtility

type ContainerUtility struct {
	Service string
	Socket  string
	Client  *containerd.Client
	// contains filtered or unexported fields
}

func (*ContainerUtility) CloseClientConnection

func (c *ContainerUtility) CloseClientConnection()

func (*ContainerUtility) CreateContainer

func (c *ContainerUtility) CreateContainer(ctx context.Context, containerName string, containerImage string) (containerd.Container, error)

func (*ContainerUtility) DestroyContainersInNamespace

func (c *ContainerUtility) DestroyContainersInNamespace(ctx context.Context, namespace string) error

func (*ContainerUtility) DestroyContainersInNamespacesList

func (c *ContainerUtility) DestroyContainersInNamespacesList(ctx context.Context, namespaces []string) error

func (*ContainerUtility) EnsureContainerDestroyed

func (c *ContainerUtility) EnsureContainerDestroyed(ctx context.Context, containerName string, timeoutStr string) error

func (*ContainerUtility) EnsureContainerStoppedOrNonExistent

func (c *ContainerUtility) EnsureContainerStoppedOrNonExistent(ctx context.Context, containerName string) error

func (*ContainerUtility) EnsureContainersDestroyed

func (c *ContainerUtility) EnsureContainersDestroyed(ctx context.Context, containers []containerd.Container, timeoutStr string) error

func (*ContainerUtility) EnsureFreshContainerRunning

func (c *ContainerUtility) EnsureFreshContainerRunning(ctx context.Context, containerName string, containerImage string) error

func (*ContainerUtility) GetContainerWithGivenName

func (c *ContainerUtility) GetContainerWithGivenName(ctx context.Context, containerName string) (containerd.Container, error)

func (*ContainerUtility) GetContainersInNamespace

func (c *ContainerUtility) GetContainersInNamespace(ctx context.Context, namespace string) ([]containerd.Container, error)

func (*ContainerUtility) RemoveContainer

func (c *ContainerUtility) RemoveContainer(ctx context.Context, container containerd.Container, force bool) error

func (*ContainerUtility) StopContainer

func (c *ContainerUtility) StopContainer(ctx context.Context, container containerd.Container, timeoutStr string) error

type ContainerUtils

type ContainerUtils interface {
	EnsureFreshContainerRunning(context.Context, string, string) error
	EnsureContainerDestroyed(context.Context, string, string) error
	EnsureContainersDestroyed(ctx context.Context, containers []containerd.Container, timeoutStr string) error
	EnsureContainerStoppedOrNonExistent(context.Context, string) error
	GetContainersInNamespace(ctx context.Context, namespace string) ([]containerd.Container, error)
	GetContainerWithGivenName(ctx context.Context, containerName string) (containerd.Container, error)
	DestroyContainersInNamespace(ctx context.Context, namespace string) error
	DestroyContainersInNamespacesList(ctx context.Context, namespaces []string) error
	CreateContainer(ctx context.Context, containerName string, containerImage string) (containerd.Container, error)
	RemoveContainer(ctx context.Context, container containerd.Container, force bool) error
	StopContainer(ctx context.Context, container containerd.Container, timeoutStr string) error
	CloseClientConnection()
}

func NewContainerUtil

func NewContainerUtil() (ContainerUtils, error)

type ImageUtility

type ImageUtility struct{}

func (*ImageUtility) LoadImagesFromDir

func (i *ImageUtility) LoadImagesFromDir(ctx context.Context, imageDir string, namespace string) error

LoadImagesFromDir loads images from all tar files in the given directory to container runtime with given namespace

func (*ImageUtility) LoadImagesFromFile

func (i *ImageUtility) LoadImagesFromFile(ctx context.Context, fileName string) error

LoadImagesFromFile loads images from given tar file to container runtime

type ImageUtils

type ImageUtils interface {
	LoadImagesFromDir(context.Context, string, string) error
	LoadImagesFromFile(context.Context, string) error
}

func NewImageUtil

func NewImageUtil() ImageUtils