cluster

Documentation

Index

• Constants
• func NodeImages(ctx context.Context, client kubernetes.Interface, logger *log.Logger, ...) (map[string]map[string]struct{}, error)
• func NodesMissingImages(ctx context.Context, client kubernetes.Interface, logger *log.Logger, ...) ([]string, error)
• type NodeImagesJobOptions

Constants

const (
	// DefaultNodeImagesJobImage is the default image to use for the node images job
	// This image must have the docker CLI on the path
	DefaultNodeImagesJobImage = "docker.io/replicated/kurl-util:latest"
	// DefaultNodeImagesJobNamespace is the default namespace to use for the node images job
	DefaultNodeImagesJobNamespace = "kurl"
	// DefaultNodeImagesJobTimeout is the default timeout for the node images job
	// This timeout must be greater than 0
	DefaultNodeImagesJobTimeout = 120 * time.Second
)

Functions

func NodeImages

func NodeImages(ctx context.Context, client kubernetes.Interface, logger *log.Logger, opts NodeImagesJobOptions) (map[string]map[string]struct{}, error)

NodeImages returns a map of node names to maps of images present on that node. It will use node.Status.Images if it is likely comprehensive, otherwise it will fallback to run a job on all nodes if not.

func NodesMissingImages

func NodesMissingImages(ctx context.Context, client kubernetes.Interface, logger *log.Logger, images []string, nodeImagesOpts NodeImagesJobOptions) ([]string, error)

NodesMissingImages returns the list of nodes missing any one of the images in the provided list

Types

type NodeImagesJobOptions

type NodeImagesJobOptions struct {
	JobNamespace string
	JobImage     string
	Timeout      time.Duration
	TargetNode   string
	ExcludeNodes []string
	// contains filtered or unexported fields
}

NodeImagesJobOptions are options for the node images job