cluster

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2016 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckIfApiExistsAndLoad added in v0.12.0

func CheckIfApiExistsAndLoad(api libmachine.API) (*host.Host, error)

func CheckService added in v0.13.0

func CheckService(namespace string, service string) error

CheckService waits for the specified service to be ready by returning an error until the service is up The check is done by polling the endpoint associated with the service and when the endpoint exists, returning no error->service-online

func CreateSSHShell added in v0.2.0

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

func DeleteHost

func DeleteHost(api libmachine.API) error

DeleteHost deletes the host VM.

func EnsureMinikubeRunningOrExit added in v0.8.0

func EnsureMinikubeRunningOrExit(api libmachine.API, exitStatus int)

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 added in v0.8.0

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

func GetLocalkubeStatus added in v0.10.0

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

GetLocalkubeStatus gets the status of localkube from the host VM.

func GetServiceListByLabel added in v0.13.0

func GetServiceListByLabel(namespace string, key string, value string) (*kubeapi.ServiceList, error)

func GetServiceURLsForService added in v0.12.1

func GetServiceURLsForService(api libmachine.API, namespace, service string, t *template.Template) ([]string, error)

func GetStartCommand

func GetStartCommand(kubernetesConfig KubernetesConfig) (string, error)

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, kubernetesConfig KubernetesConfig) 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

func WaitAndMaybeOpenService added in v0.13.0

func WaitAndMaybeOpenService(api libmachine.API, namespace string, service string, urlTemplate *template.Template, urlMode bool, https bool)

Types

type KubernetesConfig added in v0.8.0

type KubernetesConfig struct {
	KubernetesVersion string
	NodeIP            string
	ContainerRuntime  string
	NetworkPlugin     string
	ExtraOptions      util.ExtraOptionSlice
}

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
	HypervVirtualSwitch string
	KvmNetwork          string // Only used by the KVM driver
}

MachineConfig contains the parameters used to start a cluster.

func (*MachineConfig) CacheMinikubeISOFromURL added in v0.8.0

func (m *MachineConfig) CacheMinikubeISOFromURL() error

func (*MachineConfig) GetISOCacheFilepath added in v0.7.0

func (m *MachineConfig) GetISOCacheFilepath() string

func (*MachineConfig) GetISOFileURI added in v0.8.0

func (m *MachineConfig) GetISOFileURI() string

func (*MachineConfig) IsMinikubeISOCached added in v0.7.0

func (m *MachineConfig) IsMinikubeISOCached() bool

func (*MachineConfig) ShouldCacheMinikubeISO added in v0.8.0

func (m *MachineConfig) ShouldCacheMinikubeISO() bool

type MissingNodePortError added in v0.12.0

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

func (MissingNodePortError) Error added in v0.12.0

func (e MissingNodePortError) Error() string

type ServiceURL added in v0.12.1

type ServiceURL struct {
	Namespace string
	Name      string
	URLs      []string
}

type ServiceURLs added in v0.12.1

type ServiceURLs []ServiceURL

func GetServiceURLs added in v0.12.1

func GetServiceURLs(api libmachine.API, namespace string, t *template.Template) (ServiceURLs, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL