provision

Documentation

Index

• Constants
• func KindCluster(p *platform.Platform) error
• func PodStatus(p *platform.Platform, period time.Duration) error
• func RollingRestart(platform *platform.Platform, opts RollingOptions) error
• func RollingUpdate(platform *platform.Platform, opts RollingOptions) error
• func Status(p *platform.Platform) error
• func Terminate(platform *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, burninPeriod time.Duration) 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) GetHealth(node v1.Node) string
  • func (cluster *Cluster) Terminate(node types.Machine) error
• type EtcdClient
  • func GetEtcdClient(platform *platform.Platform, client kubernetes.Interface, ...) *EtcdClient
  • func (cluster *EtcdClient) GetEtcdClient(node v1.Node) (*etcd.Client, error)
  • func (cluster *EtcdClient) GetEtcdLeader() (*etcd.Client, error)
  • func (cluster *EtcdClient) GetHealth(node v1.Node) string
  • func (cluster *EtcdClient) GetOrphans() ([]string, error)
  • func (cluster *EtcdClient) MoveLeader(name string) error
  • func (cluster *EtcdClient) PrintStatus() error
  • func (cluster *EtcdClient) RemoveMember(name string) error
• type NodeMachine
  • func (node NodeMachine) String() string
• type NodeMachines
  • func (n NodeMachines) Len() int
  • func (n NodeMachines) Less(i, j int) bool
  • func (n *NodeMachines) Pop() NodeMachine
  • func (n *NodeMachines) PopN(count int) *[]NodeMachine
  • func (n *NodeMachines) Push(x NodeMachine)
  • func (n NodeMachines) Swap(i, j int)
• type RollingOptions

Constants

const ClusterConfiguration = "ClusterConfiguration"

Functions

func KindCluster

func KindCluster(p *platform.Platform) error

KindCluster provisions a new Kind cluster

func PodStatus

func PodStatus(p *platform.Platform, period time.Duration) error

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 Terminate

func Terminate(platform *platform.Platform) error

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

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, burninPeriod time.Duration) 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       *EtcdClient
}

func GetCluster

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

func (*Cluster) Cordon

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

func (*Cluster) GetHealth

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

func (*Cluster) Terminate

func (cluster *Cluster) Terminate(node types.Machine) error

type EtcdClient

type EtcdClient struct {
	*platform.Platform
	Kubernetes        kubernetes.Interface
	PreferredHostname string
	Etcd              *etcd.EtcdClientGenerator
}

func GetEtcdClient

func GetEtcdClient(platform *platform.Platform, client kubernetes.Interface, PreferredHostname string) *EtcdClient

func (*EtcdClient) GetEtcdClient

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

func (*EtcdClient) GetEtcdLeader

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

func (*EtcdClient) GetHealth

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

func (*EtcdClient) GetOrphans

func (cluster *EtcdClient) GetOrphans() ([]string, error)

func (*EtcdClient) MoveLeader

func (cluster *EtcdClient) MoveLeader(name string) error

func (*EtcdClient) PrintStatus

func (cluster *EtcdClient) PrintStatus() error

func (*EtcdClient) RemoveMember

func (cluster *EtcdClient) RemoveMember(name string) error

type NodeMachine

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

func (NodeMachine) String

func (node NodeMachine) String() string

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) Pop

func (n *NodeMachines) Pop() NodeMachine

func (*NodeMachines) PopN

func (n *NodeMachines) PopN(count int) *[]NodeMachine

func (*NodeMachines) Push

func (n *NodeMachines) Push(x NodeMachine)

func (NodeMachines) Swap

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

type RollingOptions

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