init

Documentation

Index

• Variables
• func NewInitCMD(out io.Writer) *cobra.Command
• type ClusterConverter
  • func (c *ClusterConverter) Run() error
• type Initializer
  • func (ki *Initializer) Run() error
• type KindOperator
  • func NewKindOperator(kindCMDPath string, kubeconfigPath string) *KindOperator
  • func (k *KindOperator) KindCreateClusterWithConfig(out io.Writer, configPath string) error
  • func (k *KindOperator) KindInstall() error
  • func (k *KindOperator) KindLoadDockerImage(out io.Writer, clusterName, image string, nodeNames []string) error
  • func (k *KindOperator) KindVersion() (string, error)
  • func (k *KindOperator) SetExecCommand(execCommand func(string, ...string) *exec.Cmd)

Variables

var (
	AllValidOpenYurtVersions = append(projectinfo.Get().AllVersions, "latest")
)

Functions

func NewInitCMD

func NewInitCMD(out io.Writer) *cobra.Command

Types

type ClusterConverter

type ClusterConverter struct {
	RootDir                   string
	ClientSet                 kubeclientset.Interface
	CloudNodes                []string
	EdgeNodes                 []string
	WaitServantJobTimeout     time.Duration
	YurthubHealthCheckTimeout time.Duration
	KubeConfigPath            string
	YurtManagerImage          string
	NodeServantImage          string
	YurthubImage              string
}

func (*ClusterConverter) Run

func (c *ClusterConverter) Run() error

type Initializer

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

func (*Initializer) Run

func (ki *Initializer) Run() error

type KindOperator

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

func NewKindOperator

func NewKindOperator(kindCMDPath string, kubeconfigPath string) *KindOperator

func (*KindOperator) KindCreateClusterWithConfig

func (k *KindOperator) KindCreateClusterWithConfig(out io.Writer, configPath string) error

func (*KindOperator) KindInstall

func (k *KindOperator) KindInstall() error

KindInstall will install kind of default version. If KindOperator has got kindCMDPath, it will do nothing.

func (*KindOperator) KindLoadDockerImage

func (k *KindOperator) KindLoadDockerImage(out io.Writer, clusterName, image string, nodeNames []string) error

func (*KindOperator) KindVersion

func (k *KindOperator) KindVersion() (string, error)

func (*KindOperator) SetExecCommand

func (k *KindOperator) SetExecCommand(execCommand func(string, ...string) *exec.Cmd)