commands

Documentation

Index

• func NewCmdHelpers(f *util.Factory, out io.Writer) *cobra.Command
• func ReadAllInstanceGroups(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster) ([]*kops.InstanceGroup, error)
• func RunToolboxEnroll(ctx context.Context, f commandutils.Factory, out io.Writer, ...) error
• func SetClusterFields(fields []string, cluster *api.Cluster) error
• func SetInstancegroupFields(fields []string, instanceGroup *api.InstanceGroup) error
• func UnsetClusterFields(fields []string, cluster *api.Cluster) error
• func UnsetInstancegroupFields(fields []string, instanceGroup *api.InstanceGroup) error
• func UpdateCluster(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster, ...) error
• func UpdateInstanceGroup(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster, ...) error
• type CommandOutput
• type ExecOptions
• type SSHHost
  • func NewSSHHost(ctx context.Context, host string, sshPort int, sshUser string, sudo bool) (*SSHHost, error)
  • func (s *SSHHost) Close() error
• type ToolboxEnrollOptions
  • func (o *ToolboxEnrollOptions) InitDefaults()

Functions

func NewCmdHelpers

func NewCmdHelpers(f *util.Factory, out io.Writer) *cobra.Command

NewCmdHelpers builds the cobra command tree for the `helpers` subcommand

func ReadAllInstanceGroups

func ReadAllInstanceGroups(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster) ([]*kops.InstanceGroup, error)

ReadAllInstanceGroups reads all the instance groups for the cluster

func RunToolboxEnroll

func RunToolboxEnroll(ctx context.Context, f commandutils.Factory, out io.Writer, options *ToolboxEnrollOptions) error

func SetClusterFields

func SetClusterFields(fields []string, cluster *api.Cluster) error

SetClusterFields sets field values in the cluster

func SetInstancegroupFields

func SetInstancegroupFields(fields []string, instanceGroup *api.InstanceGroup) error

SetInstancegroupFields sets field values in the instance group.

func UnsetClusterFields

func UnsetClusterFields(fields []string, cluster *api.Cluster) error

UnsetClusterFields unsets field values in the cluster

func UnsetInstancegroupFields

func UnsetInstancegroupFields(fields []string, instanceGroup *api.InstanceGroup) error

UnsetInstancegroupFields sets field values in the instance group.

func UpdateCluster

func UpdateCluster(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster, instanceGroups []*kops.InstanceGroup) error

UpdateCluster writes the updated cluster to the state store, after performing validation

func UpdateInstanceGroup

func UpdateInstanceGroup(ctx context.Context, clientset simple.Clientset, cluster *kops.Cluster, allInstanceGroups []*kops.InstanceGroup, instanceGroupToUpdate *kops.InstanceGroup) error

UpdateInstanceGroup writes the updated instance group to the state store after performing validation

Types

type CommandOutput

type CommandOutput struct {
	Stdout bytes.Buffer
	Stderr bytes.Buffer
}

CommandOutput holds the results of running a command.

type ExecOptions

type ExecOptions struct {
	Sudo bool
	Echo bool
}

ExecOptions holds options for running a command remotely.

type SSHHost

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

SSHHost is a wrapper around an SSH connection to a host machine.

func NewSSHHost

func NewSSHHost(ctx context.Context, host string, sshPort int, sshUser string, sudo bool) (*SSHHost, error)

NewSSHHost creates a new SSHHost.

func (*SSHHost) Close

func (s *SSHHost) Close() error

Close closes the connection.

type ToolboxEnrollOptions

type ToolboxEnrollOptions struct {
	ClusterName   string
	InstanceGroup string

	Host string

	SSHUser string
	SSHPort int
}

func (*ToolboxEnrollOptions) InitDefaults

func (o *ToolboxEnrollOptions) InitDefaults()