kubernetes

May 30, 2022

Changes in this version

+ func AddEdgeWorkerLabelAndAutonomyAnnotation(cliSet *kubernetes.Clientset, node *corev1.Node, lVal, aVal string) (*corev1.Node, error)

Jan 12, 2022

Changes in this version

+ const DefaultWaitServantJobTimeout

+ const SystemNamespace

+ var ErrClusterVersionEmpty = errors.New("cluster version should not be empty")

+ func AddEdgeWorkerLableAndAutonomyAnnotation(cliSet *kubernetes.Clientset, node *corev1.Node, lVal, aVal string) (*corev1.Node, error)

+ func DeleteCRDResource(clientset *kubernetes.Clientset, yurtAppManagerClientSet dynamic.Interface, ...) error

+ func GetKubernetesVersionFromCluster(client kubernetes.Interface) (string, error)

+ func RenderServantJob(action string, tmplCtx map[string]string, nodeName string) (*batchv1.Job, error)

+ func SetKubeletCaCert(config *clientcmdapi.Config) error

+ func SetKubeletConfigForNode() error

Sep 27, 2021

Changes in this version

+ func CheckAndInstallKubelet(clusterVersion string) error

+ func DeleteYurthubSetting(client *kubernetes.Clientset) error

+ func DeployYurtAppManager(client *kubernetes.Clientset, yurtappmanagerImage string, ...) error

+ func DeployYurtControllerManager(client *kubernetes.Clientset, yurtControllerManagerImage string) error

+ func DeployYurthubSetting(client *kubernetes.Clientset) error

+ func DeployYurttunnelAgent(client *kubernetes.Clientset, tunnelServerAddress string, ...) error

+ func DeployYurttunnelServer(client *kubernetes.Clientset, cloudNodes []string, ...) error

+ func SetKubeletService() error

+ func SetKubeletUnitConfig(nodeType string) error

Aug 6, 2021

Changes in this version

+ const DisableNodeControllerJobNameBase

+ const EnableNodeControllerJobNameBase

+ func CreateCRDFromYaml(clientset *kubernetes.Clientset, yurtAppManagerClient dynamic.Interface, ...) error

+ func CreateMutatingWebhookConfigurationFromYaml(cliSet *kubernetes.Clientset, svcTmpl string) error

+ func CreateRoleBindingFromYaml(cliSet *kubernetes.Clientset, ns, crbTmpl string) error

+ func CreateRoleFromYaml(cliSet *kubernetes.Clientset, ns, crTmpl string) error

+ func CreateSecretFromYaml(cliSet *kubernetes.Clientset, ns, saTmpl string) error

+ func CreateValidatingWebhookConfigurationFromYaml(cliSet *kubernetes.Clientset, svcTmpl string) error

+ func GenDynamicClientSet(flags *pflag.FlagSet) (dynamic.Interface, error)

+ func GetKubeControllerManagerHANodes(cliSet *kubernetes.Clientset) ([]string, error)

May 26, 2021

Changes in this version

+ const ConvertJobNameBase

+ const RevertJobNameBase

+ var CheckServantJobPeriod = time.Second * 10

+ var PropagationPolicy = metav1.DeletePropagationBackground

+ var ValidServerVersions = []string

+ var WaitServantJobTimeout = time.Minute * 2

+ 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)