kubekey

Documentation

Index

• Constants
• func CheckClusterRole() (bool, *rest.Config, error)
• func ClearConditions(runtime *common.KubeRuntime) error
• func CreateNodeForCluster(runtime *common.KubeRuntime) error
• func NewKubekeyClient() (*kubekeyclientset.Clientset, error)
• func PatchNodeImportStatus(runtime *common.KubeRuntime, status string) error
• func SaveKubeConfig(runtime *common.KubeRuntime) error
• func UpdateClusterConditions(runtime *common.KubeRuntime, step string, result *ending.ModuleResult) error
• func UpdateKubeSphereCluster(runtime *common.KubeRuntime) error
• func UpdateStatus(runtime *common.KubeRuntime) error
• type ClusterReconciler
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Configuration
• type Etcd
• type External
• type NodeInfo

Constants

const (
	CreateCluster = "create cluster"
	AddNodes      = "add nodes"
)

const (
	// Pending representative the cluster is being created.
	Pending = "pending"
	// Success representative the cluster cluster has been created successfully.
	Success = "success"
	// Failed creation failure.
	Failed = "failed"
)

Functions

func CheckClusterRole

func CheckClusterRole() (bool, *rest.Config, error)

CheckClusterRole is used to check the cluster's role (host or member).

func ClearConditions

func ClearConditions(runtime *common.KubeRuntime) error

func CreateNodeForCluster

func CreateNodeForCluster(runtime *common.KubeRuntime) error

CreateNodeForCluster is used to create new nodes for the cluster to be add nodes.

func NewKubekeyClient

func NewKubekeyClient() (*kubekeyclientset.Clientset, error)

NewKubekeyClient is used to create a kubekey cluster client.

func PatchNodeImportStatus

func PatchNodeImportStatus(runtime *common.KubeRuntime, status string) error

PatchNodeImportStatus is used to update new node's status.

func SaveKubeConfig

func SaveKubeConfig(runtime *common.KubeRuntime) error

SaveKubeConfig is used to save the kubeconfig for the new cluster.

func UpdateClusterConditions

func UpdateClusterConditions(runtime *common.KubeRuntime, step string, result *ending.ModuleResult) error

UpdateClusterConditions is used for updating cluster installation process information or adding nodes.

func UpdateKubeSphereCluster

func UpdateKubeSphereCluster(runtime *common.KubeRuntime) error

UpdateKubeSphereCluster is used to update the cluster object of KubeSphere's multicluster.

func UpdateStatus

func UpdateStatus(runtime *common.KubeRuntime) error

UpdateStatus is used to update status for a new or expanded cluster.

Types

type ClusterReconciler

type ClusterReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile

func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ClusterReconciler) SetupWithManager

func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

type Configuration

type Configuration struct {
	Etcd Etcd `yaml:"etcd"`
}

type Etcd

type Etcd struct {
	External External `yaml:"external"`
}

type External

type External struct {
	Endpoints []string `yaml:"endpoints"`
}

type NodeInfo

type NodeInfo struct {
	Name    string
	Address string
	Master  bool
	Worker  bool
	Etcd    bool
}