images

Documentation

Overview

Package images is responsible for pulling images into and removing images from worker nodes

Index

• Constants
• type ImageManager
  • func NewImageManager(workqueue workqueue.RateLimitingInterface, ...) (*ImageManager, coreinformers.PodInformer)
  • func (m *ImageManager) Run(stopCh <-chan struct{}) error
• type ImageWorkRequest
• type ImageWorkResult
• type WorkQueueKey
• type WorkType

Constants

const (
	// ImageWorkResultStatusSucceeded means image pull/delete succeeded
	ImageWorkResultStatusSucceeded = "succeeded"
	// ImageWorkResultStatusFailed means image pull/delete failed
	ImageWorkResultStatusFailed = "failed"
	// ImageWorkResultStatusJobCreated means job for image pull/delete created
	ImageWorkResultStatusJobCreated = "jobcreated"
	//ImageWorkResultStatusAlreadyPulled  means image is already present in the node
	ImageWorkResultStatusAlreadyPulled = "alreadypulled"
	//ImageWorkResultStatusUnknown  means status of image pull/delete unknown
	ImageWorkResultStatusUnknown = "unknown"
)

Types

type ImageManager

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

ImageManager provides the functionalities for pulling and deleting images

func NewImageManager

func NewImageManager(
	workqueue workqueue.RateLimitingInterface,
	imageworkqueue workqueue.RateLimitingInterface,
	kubeclientset kubernetes.Interface,
	namespace string,
	imagePullDeadlineDuration time.Duration,
	criClientImage, busyboxImage, imagePullPolicy, serviceAccountName string,
	imageDeleteJobHostNetwork bool,
	jobPriorityClassName string,
	canDeleteJob bool,
	criSocketPath string) (*ImageManager, coreinformers.PodInformer)

NewImageManager returns a new image manager object

func (*ImageManager) Run

func (m *ImageManager) Run(stopCh <-chan struct{}) error

Run starts the Image Manager go routine

type ImageWorkRequest

type ImageWorkRequest struct {
	Image                   string
	ForceFullCache          bool
	Node                    *corev1.Node
	ContainerRuntimeVersion string
	WorkType                WorkType
	Imagecache              *fledgedv1alpha3.ImageCache
}

ImageWorkRequest has image name, node name, work type and imagecache

type ImageWorkResult

type ImageWorkResult struct {
	ImageWorkRequest ImageWorkRequest
	Status           string
	Reason           string
	Message          string
}

ImageWorkResult stores the result of pulling and deleting image

type WorkQueueKey

type WorkQueueKey struct {
	WorkType      WorkType
	ObjKey        string
	Status        *map[string]ImageWorkResult
	OldImageCache *fledgedv1alpha3.ImageCache
}

WorkQueueKey is an item in the sync handler's work queue

type WorkType

type WorkType string

WorkType refers to type of work to be done by sync handler

const (
	ImageCacheCreate       WorkType = "create"
	ImageCacheUpdate       WorkType = "update"
	ImageCacheDelete       WorkType = "delete"
	ImageCacheStatusUpdate WorkType = "statusupdate"
	ImageCacheRefresh      WorkType = "refresh"
	ImageCachePurge        WorkType = "purge"
)

Work types