cluster

Documentation

Index

• Constants
• func Bootstrapper(api libmachine.API, bootstrapperName string, cc config.ClusterConfig, ...) (bootstrapper.Bootstrapper, error)
• func CheckIfPaused(cr cruntime.Manager, namespaces []string) (bool, error)
• func ControlPlaneBootstrapper(mAPI libmachine.API, cc *config.ClusterConfig, bootstrapperName string) (bootstrapper.Bootstrapper, command.Runner, error)
• func DriverIP(api libmachine.API, machineName string) (net.IP, error)
• func HostIP(host *host.Host, clusterName string) (net.IP, error)
• func Mount(r mountRunner, source string, target string, c *MountConfig, pid int) error
• func Pause(cr cruntime.Manager, r command.Runner, namespaces []string) ([]string, error)
• func Unmount(r mountRunner, target string) error
• func Unpause(cr cruntime.Manager, r command.Runner, namespaces []string) ([]string, error)
• type MountConfig
• type MountError
  • func (m *MountError) Error() string

Constants

const (
	// MountErrorUnknown failed with unknown error
	MountErrorUnknown = iota
	// MountErrorConnect failed to connect
	MountErrorConnect
	// MountErrorChmod failed to chmod
	MountErrorChmod
)

Functions

func Bootstrapper

func Bootstrapper(api libmachine.API, bootstrapperName string, cc config.ClusterConfig, r command.Runner) (bootstrapper.Bootstrapper, error)

Bootstrapper returns a new bootstrapper for the cluster

func CheckIfPaused

func CheckIfPaused(cr cruntime.Manager, namespaces []string) (bool, error)

CheckIfPaused checks if the Kubernetes cluster is paused

func ControlPlaneBootstrapper

func ControlPlaneBootstrapper(mAPI libmachine.API, cc *config.ClusterConfig, bootstrapperName string) (bootstrapper.Bootstrapper, command.Runner, error)

ControlPlaneBootstrapper returns the bootstrapper for the cluster's control plane

func DriverIP

func DriverIP(api libmachine.API, machineName string) (net.IP, error)

DriverIP gets the ip address of the current minikube cluster

func HostIP

func HostIP(host *host.Host, clusterName string) (net.IP, error)

HostIP gets the ip address to be used for mapping host -> VM and VM -> host

func Mount

func Mount(r mountRunner, source string, target string, c *MountConfig, pid int) error

Mount runs the mount command from the 9p client on the VM to the 9p server on the host

func Pause

func Pause(cr cruntime.Manager, r command.Runner, namespaces []string) ([]string, error)

Pause pauses a Kubernetes cluster, retrying if necessary

func Unmount

func Unmount(r mountRunner, target string) error

Unmount unmounts a path

func Unpause

func Unpause(cr cruntime.Manager, r command.Runner, namespaces []string) ([]string, error)

Unpause unpauses a Kubernetes cluster, retrying if necessary

Types

type MountConfig

type MountConfig struct {
	// Type is the filesystem type (Typically 9p)
	Type string
	// UID is the User ID which this path will be mounted as
	UID string
	// GID is the Group ID which this path will be mounted as
	GID string
	// Version is the 9P protocol version. Valid options: 9p2000, 9p200.u, 9p2000.L
	Version string
	// MSize is the number of bytes to use for 9p packet payload
	MSize int
	// Port is the port to connect to on the host
	Port int
	// Extra mount options. See https://www.kernel.org/doc/Documentation/filesystems/9p.txt
	Options map[string]string
}

MountConfig defines the options available to the Mount command

type MountError

type MountError struct {
	// ErrorType enum for more info about the error
	ErrorType int
	// UnderlyingError the error being wrapped
	UnderlyingError error
}

MountError wrapper around errors in the `Mount` function

func (*MountError) Error

func (m *MountError) Error() string