kops

Documentation

Index

• type ClusterSize
  • func GetSize(size string) (ClusterSize, error)
• type Cmd
  • func New(s3StateStore string, logger log.FieldLogger) (*Cmd, error)
  • func (c *Cmd) Close() error
  • func (c *Cmd) CreateCluster(name, version, ami, cloud string, clusterSize ClusterSize, ...) error
  • func (c *Cmd) DeleteCluster(name string) error
  • func (c *Cmd) ExportKubecfg(name string) error
  • func (c *Cmd) GetCluster(name string) (string, error)
  • func (c *Cmd) GetInstanceGroupYAML(clusterName, igName string) (string, error)
  • func (c *Cmd) GetKubeConfigPath() string
  • func (c *Cmd) GetOutputDirectory() string
  • func (c *Cmd) GetTempDir() string
  • func (c *Cmd) Replace(name string) (string, error)
  • func (c *Cmd) RollingUpdateCluster(name string) error
  • func (c *Cmd) SetCluster(name, setValue string) error
  • func (c *Cmd) UpdateCluster(name, dir string) error
  • func (c *Cmd) UpgradeCluster(name string) error
  • func (c *Cmd) ValidateCluster(name string, silent bool) error
  • func (c *Cmd) Version() (string, error)
  • func (c *Cmd) WaitForKubernetesReadiness(dns string, timeout int) error

Types

type ClusterSize

type ClusterSize struct {
	NodeCount   string
	NodeSize    string
	MasterCount string
	MasterSize  string
}

ClusterSize is sizing configuration used by kops at cluster creation.

func GetSize

func GetSize(size string) (ClusterSize, error)

GetSize takes a size keyword and returns the matching kops cluster configuration.

type Cmd

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

Cmd is the kops command to execute.

func New

func New(s3StateStore string, logger log.FieldLogger) (*Cmd, error)

New creates a new instance of Cmd through which to execute kops.

func (*Cmd) Close

func (c *Cmd) Close() error

Close cleans up the temporary output directory used by kops.

func (*Cmd) CreateCluster

func (c *Cmd) CreateCluster(name, version, ami, cloud string, clusterSize ClusterSize, zones, privateSubnetIds, publicSubnetIds, masterSecurityGroups, workerSecurityGroups []string) error

CreateCluster invokes kops create cluster, using the context of the created Cmd.

func (*Cmd) DeleteCluster

func (c *Cmd) DeleteCluster(name string) error

DeleteCluster invokes kops delete cluster, using the context of the created Cmd.

func (*Cmd) ExportKubecfg

func (c *Cmd) ExportKubecfg(name string) error

ExportKubecfg invokes kops export kubecfg for the named cluster in the context of the created Cmd.

func (*Cmd) GetCluster

func (c *Cmd) GetCluster(name string) (string, error)

GetCluster invokes kops get cluster, using the context of the created Cmd, and returns the stdout.

func (*Cmd) GetInstanceGroupYAML

func (c *Cmd) GetInstanceGroupYAML(clusterName, igName string) (string, error)

GetInstanceGroupYAML invokes kops get instancegroup, using the context of the created Cmd, and returns the YAML stdout.

func (*Cmd) GetKubeConfigPath

func (c *Cmd) GetKubeConfigPath() string

GetKubeConfigPath returns the temporary kubeconfig directory used by kops.

func (*Cmd) GetOutputDirectory

func (c *Cmd) GetOutputDirectory() string

GetOutputDirectory returns the temporary output directory used by kops.

func (*Cmd) GetTempDir

func (c *Cmd) GetTempDir() string

GetTempDir returns the root temporary directory used by kops.

func (*Cmd) Replace

func (c *Cmd) Replace(name string) (string, error)

Replace invokes kops replace, using the context of the created Cmd, and returns the stdout. The filename passed in is expected to be in the root temp dir of this kops command.

func (*Cmd) RollingUpdateCluster

func (c *Cmd) RollingUpdateCluster(name string) error

RollingUpdateCluster invokes kops rolling-update cluster, using the context of the created Cmd.

func (*Cmd) SetCluster

func (c *Cmd) SetCluster(name, setValue string) error

SetCluster invokes kops set cluster, using the context of the created Cmd. Example setValue: spec.kubernetesVersion=1.10.0

func (*Cmd) UpdateCluster

func (c *Cmd) UpdateCluster(name, dir string) error

UpdateCluster invokes kops update cluster, using the context of the created Cmd.

func (*Cmd) UpgradeCluster

func (c *Cmd) UpgradeCluster(name string) error

UpgradeCluster invokes kops upgrade cluster, using the context of the created Cmd.

func (*Cmd) ValidateCluster

func (c *Cmd) ValidateCluster(name string, silent bool) error

ValidateCluster invokes kops validate cluster, using the context of the created Cmd.

func (*Cmd) Version

func (c *Cmd) Version() (string, error)

Version invokes kops version, using the context of the created Cmd, and returns the stdout.

func (*Cmd) WaitForKubernetesReadiness

func (c *Cmd) WaitForKubernetesReadiness(dns string, timeout int) error

WaitForKubernetesReadiness will poll a given kubernetes cluster at a regular interval for it to become ready. If the cluster fails to become ready before the provided timeout then an error will be returned.