cluster

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2016 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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)

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

func GetKubernetesEndpointsWithNamespace(namespace string) (endpointGetter, error)

func GetKubernetesServicesWithNamespace added in v0.8.0 

func GetKubernetesServicesWithNamespace(namespace string) (serviceGetter, 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 GetServiceURL added in v0.5.0 

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

func GetStartCommand 

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

Types

type BaseAsset added in v0.9.0 

type BaseAsset struct {
	Length      int
	AssetName   string
	TargetDir   string
	TargetName  string
	Permissions string
	// contains filtered or unexported fields
}

func (*BaseAsset) GetAssetName added in v0.9.0 

func (b *BaseAsset) GetAssetName() string

func (*BaseAsset) GetPermissions added in v0.9.0 

func (b *BaseAsset) GetPermissions() string

func (*BaseAsset) GetTargetDir added in v0.9.0 

func (b *BaseAsset) GetTargetDir() string

func (*BaseAsset) GetTargetName added in v0.9.0 

func (b *BaseAsset) GetTargetName() string

type CopyableFile added in v0.9.0 

type CopyableFile interface {
	io.Reader
	GetLength() int
	GetAssetName() string
	GetTargetDir() string
	GetTargetName() string
	GetPermissions() string
}

type FileAsset added in v0.9.0 

type FileAsset struct {
	BaseAsset
}

func NewFileAsset added in v0.9.0 

func NewFileAsset(assetName, targetDir, targetName, permissions string) (*FileAsset, error)

func (*FileAsset) GetLength added in v0.9.0 

func (f *FileAsset) GetLength() int

func (*FileAsset) Read added in v0.9.0 

func (f *FileAsset) Read(p []byte) (int, error)

type KubernetesConfig added in v0.8.0 

type KubernetesConfig struct {
	KubernetesVersion string
	NodeIP            string
	ContainerRuntime  string
	NetworkPlugin     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 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 MemoryAsset added in v0.9.0 

type MemoryAsset struct {
	BaseAsset
}

func NewMemoryAsset added in v0.9.0 

func NewMemoryAsset(assetName, targetDir, targetName, permissions string) *MemoryAsset

func (*MemoryAsset) GetLength added in v0.9.0 

func (m *MemoryAsset) GetLength() int

func (*MemoryAsset) Read added in v0.9.0 

func (m *MemoryAsset) Read(p []byte) (int, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.