kubernetes/cmd/kubeadm/app/util/runtime/runtime.go

var defaultKnownCRISockets …

type ContainerRuntime …

type CRIRuntime …

const defaultTimeout …

// NewContainerRuntime sets up and returns a ContainerRuntime struct
func NewContainerRuntime(criSocket string) ContainerRuntime { … }

// SetImpl can be used to set the internal implementation for testing purposes.
func (runtime *CRIRuntime) SetImpl(impl impl) { … }

// Connect establishes a connection with the CRI runtime.
func (runtime *CRIRuntime) Connect() error { … }

// IsRunning checks if runtime is running.
func (runtime *CRIRuntime) IsRunning() error { … }

// ListKubeContainers lists running k8s CRI pods
func (runtime *CRIRuntime) ListKubeContainers() ([]string, error) { … }

// RemoveContainers removes running k8s pods
func (runtime *CRIRuntime) RemoveContainers(containers []string) error { … }

// PullImage pulls the image
func (runtime *CRIRuntime) PullImage(image string) (err error) { … }

// PullImagesInParallel pulls a list of images in parallel
func (runtime *CRIRuntime) PullImagesInParallel(images []string, ifNotPresent bool) error { … }

func defaultContext() (context.Context, context.CancelFunc) { … }

func pullImagesInParallelImpl(images []string, ifNotPresent bool,
	imageExistsFunc func(string) bool, pullImageFunc func(string) error) []error { … }

// ImageExists checks to see if the image exists on the system
func (runtime *CRIRuntime) ImageExists(image string) bool { … }

// detectCRISocketImpl is separated out only for test purposes, DON'T call it directly, use DetectCRISocket instead
func detectCRISocketImpl(isSocket func(string) bool, knownCRISockets []string) (string, error) { … }

// DetectCRISocket uses a list of known CRI sockets to detect one. If more than one or none is discovered, an error is returned.
func DetectCRISocket() (string, error) { … }

// SandboxImage returns the sandbox image used by the container runtime
func (runtime *CRIRuntime) SandboxImage() (string, error) { … }