commands

package
v1.31.0-beta.1 Latest Latest
Warning

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

Go to latest
Published: Dec 15, 2024 License: Apache-2.0 Imports: 45 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCmdHelpers added in v1.19.0

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 added in v1.29.0

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 added in v1.20.0

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

SetInstancegroupFields sets field values in the instance group.

func UnsetClusterFields added in v1.21.3

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

UnsetClusterFields unsets field values in the cluster

func UnsetInstancegroupFields added in v1.21.3

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 added in v1.20.0

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 BootstrapData added in v1.31.0

type BootstrapData struct {
	// NodeupScript is a script that can be used to bootstrap the node.
	NodeupScript []byte
	// NodeupConfig is structured configuration, provided by kops-controller (for example).
	NodeupConfig *nodeup.Config
	// NodeupScriptAdditionalFiles are additional files that are needed by the nodeup script.
	NodeupScriptAdditionalFiles map[string][]byte
}

type CommandOutput added in v1.29.0

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

CommandOutput holds the results of running a command.

type ConfigBuilder added in v1.31.0

type ConfigBuilder struct {
	// ClusterName is the name of the cluster to build.
	// Required.
	ClusterName string

	// InstanceGroupName is the name of the InstanceGroup we are building configuration for.
	// Required.
	InstanceGroupName string

	// Clientset is the clientset to use to query for clusters / instancegroups etc
	// Required.
	Clientset simple.Clientset

	// Cloud is the cloud implementation
	// Use GetCloud to read and auto-populate.
	Cloud fi.Cloud

	// AssetBuilder holds the assets used by the cluster.
	// Use GetAssetBuilder to read and auto-populate.
	AssetBuilder *assets.AssetBuilder

	// Cluster holds the (unexpanded) cluster configuration.
	// Use GetCluster to read and auto-populate.
	Cluster *kops.Cluster

	// InstanceGroup holds the (unexpanded) instance group configuration.
	// Use GetInstanceGroup to read and auto-populate.
	InstanceGroup *kops.InstanceGroup
	// contains filtered or unexported fields
}

ConfigBuilder builds bootstrap configuration for a node.

func (*ConfigBuilder) GetAssetBuilder added in v1.31.0

func (b *ConfigBuilder) GetAssetBuilder(ctx context.Context) (*assets.AssetBuilder, error)

func (*ConfigBuilder) GetBootstrapData added in v1.31.0

func (b *ConfigBuilder) GetBootstrapData(ctx context.Context) (*BootstrapData, error)

func (*ConfigBuilder) GetClientset added in v1.31.0

func (b *ConfigBuilder) GetClientset(ctx context.Context) (simple.Clientset, error)

func (*ConfigBuilder) GetCloud added in v1.31.0

func (b *ConfigBuilder) GetCloud(ctx context.Context) (fi.Cloud, error)

func (*ConfigBuilder) GetCluster added in v1.31.0

func (b *ConfigBuilder) GetCluster(ctx context.Context) (*kops.Cluster, error)

func (*ConfigBuilder) GetFullCluster added in v1.31.0

func (b *ConfigBuilder) GetFullCluster(ctx context.Context) (*kops.Cluster, error)

func (*ConfigBuilder) GetFullInstanceGroup added in v1.31.0

func (b *ConfigBuilder) GetFullInstanceGroup(ctx context.Context) (*kops.InstanceGroup, error)

func (*ConfigBuilder) GetInstanceGroup added in v1.31.0

func (b *ConfigBuilder) GetInstanceGroup(ctx context.Context) (*kops.InstanceGroup, error)

func (*ConfigBuilder) GetInstanceGroups added in v1.31.0

func (b *ConfigBuilder) GetInstanceGroups(ctx context.Context) (*kops.InstanceGroupList, error)

func (*ConfigBuilder) GetWellKnownAddresses added in v1.31.0

func (b *ConfigBuilder) GetWellKnownAddresses(ctx context.Context) (model.WellKnownAddresses, error)

type ExecOptions added in v1.29.0

type ExecOptions struct {
	Sudo bool
	Echo bool
}

ExecOptions holds options for running a command remotely.

type SSHHost added in v1.29.0

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

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

func NewSSHHost added in v1.29.0

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

NewSSHHost creates a new SSHHost.

func (*SSHHost) Close added in v1.29.0

func (s *SSHHost) Close() error

Close closes the connection.

type ToolboxEnrollOptions added in v1.29.0

type ToolboxEnrollOptions struct {
	ClusterName   string
	InstanceGroup string

	Host string

	SSHUser string
	SSHPort int
}

func (*ToolboxEnrollOptions) InitDefaults added in v1.29.0

func (o *ToolboxEnrollOptions) InitDefaults()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳