cluster

package
v0.6.0-alpha.3 Latest Latest
Warning

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

 Go to latest Published: May 25, 2023 License: AGPL-3.0 Imports: 82 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CueTemplateName = "cluster_template.cue"
)
View Source 
const (
	EnvExperimentalExpose = "KBCLI_EXPERIMENTAL_EXPOSE"
)

Variables

This section is empty.

Functions

func MultipleSourceComponents 

func MultipleSourceComponents(fileName string, in io.Reader) ([]byte, error)

MultipleSourceComponents get component data from multiple source, such as stdin, URI and local file

func NewClusterCmd 

func NewClusterCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewClusterCmd creates the cluster command

func NewConnectCmd 

func NewConnectCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewConnectCmd return the cmd of connecting a cluster

func NewCreateAccountCmd 

func NewCreateAccountCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewCreateBackupCmd 

func NewCreateBackupCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewCreateCmd 

func NewCreateCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewCreateRestoreCmd 

func NewCreateRestoreCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDeleteAccountCmd 

func NewDeleteAccountCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDeleteBackupCmd 

func NewDeleteBackupCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDeleteCmd 

func NewDeleteCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDeleteOpsCmd 

func NewDeleteOpsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDescAccountCmd 

func NewDescAccountCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDescribeCmd 

func NewDescribeCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDescribeOpsCmd 

func NewDescribeOpsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewDescribeReconfigureCmd 

func NewDescribeReconfigureCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewDescribeReconfigureCmd shows details of history modifications or configuration file of reconfiguring operations

func NewDiffConfigureCmd 

func NewDiffConfigureCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewDiffConfigureCmd shows the difference between two configuration version.

func NewEditBackupPolicyCmd 

func NewEditBackupPolicyCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewEditConfigureCmd 

func NewEditConfigureCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewEditConfigureCmd shows the difference between two configuration version.

func NewExplainReconfigureCmd 

func NewExplainReconfigureCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewExplainReconfigureCmd shows details of modifiable parameters.

func NewExposeCmd 

func NewExposeCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewExposeCmd creates an expose command

func NewGrantOptions 

func NewGrantOptions(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewHorizontalScalingCmd 

func NewHorizontalScalingCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewHorizontalScalingCmd creates a horizontal scaling command

func NewLabelCmd 

func NewLabelCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListAccountsCmd 

func NewListAccountsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListBackupCmd 

func NewListBackupCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListBackupPolicyCmd 

func NewListBackupPolicyCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListCmd 

func NewListCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListComponentsCmd 

func NewListComponentsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListEventsCmd 

func NewListEventsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListInstancesCmd 

func NewListInstancesCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListLogsCmd 

func NewListLogsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewListOpsCmd 

func NewListOpsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewLogsCmd 

func NewLogsCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewLogsCmd returns the logic of accessing cluster log file

func NewReconfigureCmd 

func NewReconfigureCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewReconfigureCmd creates a Reconfiguring command

func NewRestartCmd 

func NewRestartCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewRestartCmd creates a restart command

func NewRevokeOptions 

func NewRevokeOptions(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewStartCmd 

func NewStartCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewStartCmd creates a start command

func NewStopCmd 

func NewStopCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewStopCmd creates a stop command

func NewUpdateCmd 

func NewUpdateCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

func NewUpgradeCmd 

func NewUpgradeCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewUpgradeCmd creates a upgrade command

func NewVerticalScalingCmd 

func NewVerticalScalingCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewVerticalScalingCmd creates a vertical scaling command

func NewVolumeExpansionCmd 

func NewVolumeExpansionCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command

NewVolumeExpansionCmd creates a volume expanding command

Types

type ConnectOptions 

type ConnectOptions struct {
	*exec.ExecOptions
	// contains filtered or unexported fields
}

type CreateBackupOptions 

type CreateBackupOptions struct {
	BackupType   string `json:"backupType"`
	BackupName   string `json:"backupName"`
	Role         string `json:"role,omitempty"`
	BackupPolicy string `json:"backupPolicy"`

	create.CreateOptions `json:"-"`
}

func (*CreateBackupOptions) CompleteBackup added in v0.6.0 

func (o *CreateBackupOptions) CompleteBackup() error

func (*CreateBackupOptions) Validate 

func (o *CreateBackupOptions) Validate() error

type CreateOptions 

type CreateOptions struct {
	// ClusterDefRef reference clusterDefinition
	ClusterDefRef     string                   `json:"clusterDefRef"`
	ClusterVersionRef string                   `json:"clusterVersionRef"`
	Tolerations       []interface{}            `json:"tolerations,omitempty"`
	ComponentSpecs    []map[string]interface{} `json:"componentSpecs"`
	Annotations       map[string]string        `json:"annotations,omitempty"`
	SetFile           string                   `json:"-"`
	Values            []string                 `json:"-"`

	// backup name to restore in creation
	Backup string `json:"backup,omitempty"`
	UpdatableFlags
	create.CreateOptions `json:"-"`
	// contains filtered or unexported fields
}

func NewCreateOptions added in v0.6.0 

func NewCreateOptions(f cmdutil.Factory, streams genericclioptions.IOStreams) *CreateOptions

func (*CreateOptions) CleanUp 

func (o *CreateOptions) CleanUp() error

func (*CreateOptions) Complete 

func (o *CreateOptions) Complete() error

func (*CreateOptions) CreateDependencies 

func (o *CreateOptions) CreateDependencies(dryRun []string) error

func (*CreateOptions) PreCreate 

func (o *CreateOptions) PreCreate(obj *unstructured.Unstructured) error

PreCreate before commit yaml to k8s, make changes on Unstructured yaml

func (*CreateOptions) Validate 

func (o *CreateOptions) Validate() error

type CreateRestoreOptions 

type CreateRestoreOptions struct {
	// backup name to restore in creation
	Backup string `json:"backup,omitempty"`

	// point in time recovery args
	RestoreTime    *time.Time `json:"restoreTime,omitempty"`
	RestoreTimeStr string     `json:"restoreTimeStr,omitempty"`
	SourceCluster  string     `json:"sourceCluster,omitempty"`

	create.CreateOptions `json:"-"`
}

func (*CreateRestoreOptions) Run 

func (o *CreateRestoreOptions) Run() error

func (*CreateRestoreOptions) Validate 

func (o *CreateRestoreOptions) Validate() error

type LabelOptions 

type LabelOptions struct {
	Factory cmdutil.Factory
	GVR     schema.GroupVersionResource

	genericclioptions.IOStreams
	// contains filtered or unexported fields
}

func NewLabelOptions 

func NewLabelOptions(f cmdutil.Factory, streams genericclioptions.IOStreams, gvr schema.GroupVersionResource) *LabelOptions

type ListBackupOptions 

type ListBackupOptions struct {
	*list.ListOptions
	BackupName string
}

type ListLogsOptions 

type ListLogsOptions struct {
	genericclioptions.IOStreams
	// contains filtered or unexported fields
}

ListLogsOptions declares the arguments accepted by the list-logs command

func (*ListLogsOptions) Complete 

func (o *ListLogsOptions) Complete(f cmdutil.Factory, args []string) error

func (*ListLogsOptions) Run 

func (o *ListLogsOptions) Run() error

func (*ListLogsOptions) Validate 

func (o *ListLogsOptions) Validate(args []string) error

type LogsOptions 

type LogsOptions struct {
	*exec.ExecOptions
	// contains filtered or unexported fields
}

LogsOptions declares the arguments accepted by the logs command

type OperationsOptions 

type OperationsOptions struct {
	create.CreateOptions  `json:"-"`
	HasComponentNamesFlag bool `json:"-"`

	ComponentNames         []string `json:"componentNames,omitempty"`
	OpsRequestName         string   `json:"opsRequestName"`
	TTLSecondsAfterSucceed int      `json:"ttlSecondsAfterSucceed"`

	// OpsType operation type
	OpsType appsv1alpha1.OpsType `json:"type"`

	// OpsTypeLower lower OpsType
	OpsTypeLower string `json:"typeLower"`

	// Upgrade options
	ClusterVersionRef string `json:"clusterVersionRef"`

	// VerticalScaling options
	CPU    string `json:"cpu"`
	Memory string `json:"memory"`
	Class  string `json:"class"`

	// HorizontalScaling options
	Replicas int `json:"replicas"`

	// Reconfiguring options
	KeyValues       map[string]string `json:"keyValues"`
	CfgTemplateName string            `json:"cfgTemplateName"`
	CfgFile         string            `json:"cfgFile"`

	// VolumeExpansion options.
	// VCTNames VolumeClaimTemplate names
	VCTNames []string `json:"vctNames,omitempty"`
	Storage  string   `json:"storage"`

	// Expose options
	ExposeType    string                                 `json:"-"`
	ExposeEnabled string                                 `json:"-"`
	Services      []appsv1alpha1.ClusterComponentService `json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationsOptions) CompleteComponentsFlag 

func (o *OperationsOptions) CompleteComponentsFlag() error

CompleteComponentsFlag when components flag is null and the cluster only has one component, should auto complete it.

func (*OperationsOptions) CompleteRestartOps 

func (o *OperationsOptions) CompleteRestartOps() error

CompleteRestartOps when restart a cluster and components is null, it means restarting all components of the cluster. we should set all component names to ComponentNames flag.

func (*OperationsOptions) Validate 

func (o *OperationsOptions) Validate() error

Validate command flags or args is legal

type UpdatableFlags 

type UpdatableFlags struct {
	// Options for cluster termination policy
	TerminationPolicy string `json:"terminationPolicy"`

	// Add-on switches for cluster observability
	Monitor       bool `json:"monitor"`
	EnableAllLogs bool `json:"enableAllLogs"`

	// Configuration and options for cluster affinity and tolerations
	PodAntiAffinity string `json:"podAntiAffinity"`
	// TopologyKeys if TopologyKeys is nil, add omitempty json tag, because CueLang can not covert null to list.
	TopologyKeys   []string          `json:"topologyKeys,omitempty"`
	NodeLabels     map[string]string `json:"nodeLabels,omitempty"`
	Tenancy        string            `json:"tenancy"`
	TolerationsRaw []string          `json:"-"`
}

UpdatableFlags is the flags that cat be updated by update command

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.