machine

Documentation

Index

• func CacheAndLoadImages(images []string) error
• func CacheImage(image, dst string) error
• func CacheImages(images []string, cacheDir string) error
• func CacheImagesForBootstrapper(imageRepository string, version string, clusterBootstrapper string) error
• func CommandRunner(h *host.Host) (bootstrapper.CommandRunner, error)
• func DeleteFromImageCacheDir(images []string) error
• func LoadImages(cmd bootstrapper.CommandRunner, images []string, cacheDir string) error
• func NewAPIClient() (libmachine.API, error)
• func NewRPCClient(storePath, certsDir string) libmachine.API
• func StartDriver()
• type CertGenerator
  • func (cg *CertGenerator) ValidateCertificate(addr string, authOptions *auth.Options) (bool, error)
• type ConnChecker
  • func (cc *ConnChecker) Check(h *host.Host, swarm bool) (string, *auth.Options, error)
• type LocalClient
  • func (api *LocalClient) Close() error
  • func (api *LocalClient) Create(h *host.Host) error
  • func (api *LocalClient) Load(name string) (*host.Host, error)
  • func (api *LocalClient) NewHost(driverName string, rawDriver []byte) (*host.Host, error)

Functions

func CacheAndLoadImages

func CacheAndLoadImages(images []string) error

CacheAndLoadImages caches and loads images

func CacheImage

func CacheImage(image, dst string) error

CacheImage caches an image

func CacheImages

func CacheImages(images []string, cacheDir string) error

CacheImages will cache images on the host

The cache directory currently caches images using the imagename_tag For example, k8s.gcr.io/kube-addon-manager:v6.5 would be stored at $CACHE_DIR/k8s.gcr.io/kube-addon-manager_v6.5

func CacheImagesForBootstrapper

func CacheImagesForBootstrapper(imageRepository string, version string, clusterBootstrapper string) error

CacheImagesForBootstrapper will cache images for a bootstrapper

func CommandRunner

func CommandRunner(h *host.Host) (bootstrapper.CommandRunner, error)

CommandRunner returns best available command runner for this host

func DeleteFromImageCacheDir

func DeleteFromImageCacheDir(images []string) error

DeleteFromImageCacheDir deletes images from the cache

func LoadImages

func LoadImages(cmd bootstrapper.CommandRunner, images []string, cacheDir string) error

LoadImages loads previously cached images into the container runtime

func NewAPIClient

func NewAPIClient() (libmachine.API, error)

NewAPIClient gets a new client.

func NewRPCClient

func NewRPCClient(storePath, certsDir string) libmachine.API

NewRPCClient gets a new client.

func StartDriver

func StartDriver()

StartDriver starts the driver

Types

type CertGenerator

type CertGenerator struct {
	cert.X509CertGenerator
}

CertGenerator is used to override the default machine CertGenerator with a longer timeout.

func (*CertGenerator) ValidateCertificate

func (cg *CertGenerator) ValidateCertificate(addr string, authOptions *auth.Options) (bool, error)

ValidateCertificate is a reimplementation of the default generator with a longer timeout.

type ConnChecker

type ConnChecker struct {
}

ConnChecker can check the connection

func (*ConnChecker) Check

func (cc *ConnChecker) Check(h *host.Host, swarm bool) (string, *auth.Options, error)

Check checks the connection

type LocalClient

type LocalClient struct {
	*persist.Filestore
	// contains filtered or unexported fields
}

LocalClient is a non-RPC implementation of the libmachine API

func (*LocalClient) Close

func (api *LocalClient) Close() error

Close closes the client

func (*LocalClient) Create

func (api *LocalClient) Create(h *host.Host) error

Create creates the host

func (*LocalClient) Load

func (api *LocalClient) Load(name string) (*host.Host, error)

Load a new client, creating driver

func (*LocalClient) NewHost

func (api *LocalClient) NewHost(driverName string, rawDriver []byte) (*host.Host, error)

NewHost creates a new Host