cluster

Documentation

Index

• func CreateSSHShell(api libmachine.API, args []string) error
• func DeleteHost(api libmachine.API) error
• func EnsureMinikubeRunningOrExit(api libmachine.API)
• func GenerateCerts(caCert, caKey, pub, priv string, ip net.IP) error
• func GetHostDockerEnv(api libmachine.API) (map[string]string, error)
• func GetHostLogs(api libmachine.API) (string, error)
• func GetHostStatus(api libmachine.API) (string, error)
• func GetKubernetesClient() (*unversioned.Client, error)
• func GetKubernetesEndpointsWithNamespace(namespace string) (endpointGetter, error)
• func GetKubernetesServicesWithNamespace(namespace string) (serviceGetter, error)
• func GetServiceURL(api libmachine.API, namespace, service string) (string, error)
• func GetStartCommand() string
• func SetupCerts(d drivers.Driver) error
• func StartCluster(h sshAble) error
• func StartHost(api libmachine.API, config MachineConfig) (*host.Host, error)
• func StopHost(api libmachine.API) error
• func UpdateCluster(h sshAble, d drivers.Driver, config KubernetesConfig) error
• type KubernetesConfig
• type MachineConfig
  • func (m *MachineConfig) CacheMinikubeISOFromURL() error
  • func (m *MachineConfig) GetISOCacheFilepath() string
  • func (m *MachineConfig) GetISOFileURI() string
  • func (m *MachineConfig) IsMinikubeISOCached() bool
  • func (m *MachineConfig) ShouldCacheMinikubeISO() bool

Functions

func CreateSSHShell

func CreateSSHShell(api libmachine.API, args []string) error

func DeleteHost

func DeleteHost(api libmachine.API) error

DeleteHost deletes the host VM.

func EnsureMinikubeRunningOrExit

func EnsureMinikubeRunningOrExit(api libmachine.API)

EnsureMinikubeRunningOrExit checks that minikube has a status available and that that the status is `Running`, otherwise it will exit

func GenerateCerts

func GenerateCerts(caCert, caKey, pub, priv string, ip net.IP) error

func GetHostDockerEnv

func GetHostDockerEnv(api libmachine.API) (map[string]string, error)

GetHostDockerEnv gets the necessary docker env variables to allow the use of docker through minikube's vm

func GetHostLogs

func GetHostLogs(api libmachine.API) (string, error)

GetHostLogs gets the localkube logs of the host VM.

func GetHostStatus

func GetHostStatus(api libmachine.API) (string, error)

GetHostStatus gets the status of the host VM.

func GetKubernetesClient

func GetKubernetesClient() (*unversioned.Client, error)

func GetKubernetesEndpointsWithNamespace

func GetKubernetesEndpointsWithNamespace(namespace string) (endpointGetter, error)

func GetKubernetesServicesWithNamespace

func GetKubernetesServicesWithNamespace(namespace string) (serviceGetter, error)

func GetServiceURL

func GetServiceURL(api libmachine.API, namespace, service string) (string, error)

func GetStartCommand

func GetStartCommand() string

func SetupCerts

func SetupCerts(d drivers.Driver) error

SetupCerts gets the generated credentials required to talk to the APIServer.

func StartCluster

func StartCluster(h sshAble) error

StartCluster starts a k8s cluster on the specified Host.

func StartHost

func StartHost(api libmachine.API, config MachineConfig) (*host.Host, error)

StartHost starts a host VM.

func StopHost

func StopHost(api libmachine.API) error

StopHost stops the host VM.

func UpdateCluster

func UpdateCluster(h sshAble, d drivers.Driver, config KubernetesConfig) error

Types

type KubernetesConfig

type KubernetesConfig struct {
	KubernetesVersion string
}

KubernetesConfig contains the parameters used to configure the VM Kubernetes.

type MachineConfig

type MachineConfig struct {
	MinikubeISO      string
	Memory           int
	CPUs             int
	DiskSize         int
	VMDriver         string
	DockerEnv        []string // Each entry is formatted as KEY=VALUE.
	InsecureRegistry []string
	RegistryMirror   []string
	HostOnlyCIDR     string // Only used by the virtualbox driver
}

MachineConfig contains the parameters used to start a cluster.

func (*MachineConfig) CacheMinikubeISOFromURL

func (m *MachineConfig) CacheMinikubeISOFromURL() error

func (*MachineConfig) GetISOCacheFilepath

func (m *MachineConfig) GetISOCacheFilepath() string

func (*MachineConfig) GetISOFileURI

func (m *MachineConfig) GetISOFileURI() string

func (*MachineConfig) IsMinikubeISOCached

func (m *MachineConfig) IsMinikubeISOCached() bool

func (*MachineConfig) ShouldCacheMinikubeISO

func (m *MachineConfig) ShouldCacheMinikubeISO() bool