provision

Documentation

Index

• Constants
• func Cleanup(platform *platform.Platform) error
• func KindCluster(p *platform.Platform) error
• func RollingRestart(platform *platform.Platform, opts RollingOptions) error
• func RollingUpdate(platform *platform.Platform, opts RollingOptions) error
• func Status(p *platform.Platform) error
• func TerminateNodes(platform *platform.Platform, nodes []string) error
• func TerminateOrphans(platform *platform.Platform) error
• func Upgrade(platform *platform.Platform) error
• func VM(platform *platform.Platform, vm *types.VM, konfigs ...string) error
• func VsphereCluster(platform *platform.Platform) error
• func WithVmwareCluster(p *platform.Platform) error
• type Cluster
  • func GetCluster(platform *platform.Platform) (*Cluster, error)
  • func (cluster *Cluster) Cordon(node v1.Node) error
  • func (cluster *Cluster) GetEtcdClient(node v1.Node) (*etcd.Client, error)
  • func (cluster *Cluster) GetEtcdLeader() (*etcd.Client, error)
  • func (cluster *Cluster) GetHealth(node v1.Node) string
• type NodeMachine
• type NodeMachines
  • func (n NodeMachines) Len() int
  • func (n NodeMachines) Less(i, j int) bool
  • func (n NodeMachines) Swap(i, j int)
• type RollingOptions

Constants

const ClusterConfiguration = "ClusterConfiguration"

Functions

func Cleanup

func Cleanup(platform *platform.Platform) error

Cleanup stops and deletes all VM's for a cluster;

func KindCluster

func KindCluster(p *platform.Platform) error

KindCluster provisions a new Kind cluster

func RollingRestart

func RollingRestart(platform *platform.Platform, opts RollingOptions) error

Perform a rolling restart of nodes

func RollingUpdate

func RollingUpdate(platform *platform.Platform, opts RollingOptions) error

Perform a rolling update of nodes

func Status

func Status(p *platform.Platform) error

func TerminateNodes

func TerminateNodes(platform *platform.Platform, nodes []string) error

TerminateNodes deletes all of the specified nodes stops and deletes all VM's for a cluster;

func TerminateOrphans

func TerminateOrphans(platform *platform.Platform) error

TerminateOrphans deletes all vm's that have not yet joined the cluster

func Upgrade

func Upgrade(platform *platform.Platform) error

Upgrade the kubernetes control plane to the declared version

func VM

func VM(platform *platform.Platform, vm *types.VM, konfigs ...string) error

VM provisions a new standalone VM

func VsphereCluster

func VsphereCluster(platform *platform.Platform) error

VsphereCluster provisions or creates a kubernetes cluster

func WithVmwareCluster

func WithVmwareCluster(p *platform.Platform) error

Types

type Cluster

type Cluster struct {
	*platform.Platform
	Nodes      NodeMachines
	Orphans    []types.Machine
	Kubernetes kubernetes.Interface
	Etcd       *etcd.EtcdClientGenerator
}

func GetCluster

func GetCluster(platform *platform.Platform) (*Cluster, error)

func (*Cluster) Cordon

func (cluster *Cluster) Cordon(node v1.Node) error

func (*Cluster) GetEtcdClient

func (cluster *Cluster) GetEtcdClient(node v1.Node) (*etcd.Client, error)

func (*Cluster) GetEtcdLeader

func (cluster *Cluster) GetEtcdLeader() (*etcd.Client, error)

func (*Cluster) GetHealth

func (cluster *Cluster) GetHealth(node v1.Node) string

type NodeMachine

type NodeMachine struct {
	Node    v1.Node
	Machine types.Machine
}

type NodeMachines

type NodeMachines []NodeMachine

func (NodeMachines) Len

func (n NodeMachines) Len() int

func (NodeMachines) Less

func (n NodeMachines) Less(i, j int) bool

func (NodeMachines) Swap

func (n NodeMachines) Swap(i, j int)

type RollingOptions

type RollingOptions struct {
	Timeout                time.Duration
	MinAge                 time.Duration
	Max                    int
	Force                  bool
	ScaleSingleDeployments bool
	MigrateLocalVolumes    bool
	Masters, Workers       bool
}