init

package

v1.7.0 Latest Latest Go to latest Published: May 6, 2026 License: Apache-2.0 Imports: 41 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openyurtio/openyurt

Links

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

	NodeNameToPool = map[string]string{
		"openyurt-e2e-test-control-plane": "yurt-pool1",
		"openyurt-e2e-test-worker":        "yurt-pool2",
		"openyurt-e2e-test-worker2":       "yurt-pool2",
		"openyurt-e2e-test-worker3":       "yurt-pool3",
		"openyurt-e2e-test-worker4":       "yurt-pool3",
	}
	DefaultPools = map[string]struct {
		Kind                 appsv1beta2.NodePoolType
		EnableLeaderElection bool
		LeaderReplicas       int
	}{
		"yurt-pool1": {
			Kind:                 appsv1beta2.Cloud,
			EnableLeaderElection: false,
		},
		"yurt-pool2": {
			Kind:                 appsv1beta2.Edge,
			EnableLeaderElection: true,
			LeaderReplicas:       1,
		},
		"yurt-pool3": {
			Kind:                 appsv1beta2.Edge,
			EnableLeaderElection: false,
		},
	}
)

Functions ¶

func NewInitCMD ¶

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

Types ¶

type ClusterConverter ¶

type ClusterConverter struct {
	RootDir                   string
	ClientSet                 kubeclientset.Interface
	RuntimeClient             client.Client
	CloudNodes                []string
	EdgeNodes                 []string
	WaitNodeConversionTimeout time.Duration
	KubeConfigPath            string
	YurtManagerImage          string
	NodeServantImage          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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
constants
lock
util
kubernetes

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL