Documentation ¶
Index ¶
- Constants
- Variables
- func AnnotateNode(cliSet *kubernetes.Clientset, node *v1.Node, key, val string) (*v1.Node, error)
- func CreateClusterRoleBindingFromYaml(cliSet *kubernetes.Clientset, crbTmpl string) error
- func CreateClusterRoleFromYaml(cliSet *kubernetes.Clientset, crTmpl string) error
- func CreateConfigMapFromYaml(cliSet *kubernetes.Clientset, ns, cmTmpl string) error
- func CreateDaemonSetFromYaml(cliSet *kubernetes.Clientset, dsTmpl string, ctx interface{}) error
- func CreateDeployFromYaml(cliSet *kubernetes.Clientset, ns, dplyTmpl string, ctx interface{}) error
- func CreateServiceAccountFromYaml(cliSet *kubernetes.Clientset, ns, saTmpl string) error
- func CreateServiceFromYaml(cliSet *kubernetes.Clientset, svcTmpl string) error
- func GenClientSet(flags *pflag.FlagSet) (*kubernetes.Clientset, error)
- func GetOrCreateJoinTokenString(cliSet *kubernetes.Clientset) (string, error)
- func LabelNode(cliSet *kubernetes.Clientset, node *v1.Node, key, val string) (*v1.Node, error)
- func PrepareKubeConfigPath(flags *pflag.FlagSet) (string, error)
- func RunJobAndCleanup(cliSet *kubernetes.Clientset, job *batchv1.Job, timeout, period time.Duration) error
- func RunServantJobs(cliSet *kubernetes.Clientset, tmplCtx map[string]string, ...) error
- func ValidateServerVersion(cliSet *kubernetes.Clientset) error
- func YamlToObject(yamlContent []byte) (runtime.Object, error)
Constants ¶
const ( // ConvertJobNameBase is the prefix of the convert ServantJob name ConvertJobNameBase = "yurtctl-servant-convert" // RevertJobNameBase is the prefix of the revert ServantJob name RevertJobNameBase = "yurtctl-servant-revert" )
Variables ¶
var ( // PropagationPolicy defines the propagation policy used when deleting a resource PropagationPolicy = metav1.DeletePropagationBackground // WaitServantJobTimeout specifies the timeout value of waiting for the ServantJob to be succeeded WaitServantJobTimeout = time.Minute * 2 // CheckServantJobPeriod defines the time interval between two successive ServantJob statu's inspection CheckServantJobPeriod = time.Second * 10 // ValidServerVersions contains all compatable server version // yurtctl only support Kubernetes 1.12+ - 1.16+ for now ValidServerVersions = []string{ "1.12", "1.12+", "1.13", "1.13+", "1.14", "1.14+", "1.16", "1.16+", "1.18", "1.18+"} )
Functions ¶
func AnnotateNode ¶
AnnotateNode add a new annotation (<key>=<val>) to the given node
func CreateClusterRoleBindingFromYaml ¶
func CreateClusterRoleBindingFromYaml(cliSet *kubernetes.Clientset, crbTmpl string) error
CreateClusterRoleBindingFromYaml creates the ClusterRoleBinding from the yaml template.
func CreateClusterRoleFromYaml ¶
func CreateClusterRoleFromYaml(cliSet *kubernetes.Clientset, crTmpl string) error
CreateClusterRoleFromYaml creates the ClusterRole from the yaml template.
func CreateConfigMapFromYaml ¶
func CreateConfigMapFromYaml(cliSet *kubernetes.Clientset, ns, cmTmpl string) error
CreateConfigMapFromYaml creates the ConfigMap from the yaml template.
func CreateDaemonSetFromYaml ¶
func CreateDaemonSetFromYaml(cliSet *kubernetes.Clientset, dsTmpl string, ctx interface{}) error
CreateDaemonSetFromYaml creates the DaemonSet from the yaml template.
func CreateDeployFromYaml ¶
func CreateDeployFromYaml(cliSet *kubernetes.Clientset, ns, dplyTmpl string, ctx interface{}) error
CreateDeployFromYaml creates the Deployment from the yaml template.
func CreateServiceAccountFromYaml ¶
func CreateServiceAccountFromYaml(cliSet *kubernetes.Clientset, ns, saTmpl string) error
CreateServiceAccountFromYaml creates the ServiceAccount from the yaml template.
func CreateServiceFromYaml ¶
func CreateServiceFromYaml(cliSet *kubernetes.Clientset, svcTmpl string) error
CreateServiceFromYaml creates the Service from the yaml template.
func GenClientSet ¶
func GenClientSet(flags *pflag.FlagSet) (*kubernetes.Clientset, error)
GenClientSet generates the clientset based on command option, environment variable or the default kubeconfig file
func GetOrCreateJoinTokenString ¶
func GetOrCreateJoinTokenString(cliSet *kubernetes.Clientset) (string, error)
func PrepareKubeConfigPath ¶
PrepareKubeConfigPath returns the path of cluster kubeconfig file
func RunJobAndCleanup ¶
func RunJobAndCleanup(cliSet *kubernetes.Clientset, job *batchv1.Job, timeout, period time.Duration) error
RunJobAndCleanup runs the job, wait for it to be complete, and delete it
func RunServantJobs ¶
func RunServantJobs(cliSet *kubernetes.Clientset, tmplCtx map[string]string, edgeNodeNames []string, convert bool) error
RunServantJobs launchs servant jobs on specified edge nodes
func ValidateServerVersion ¶
func ValidateServerVersion(cliSet *kubernetes.Clientset) error
ValidateServerVersion checks if the target server's version is supported
Types ¶
This section is empty.