kubernetes

Documentation

Index

• Constants
• Variables
• func AddEdgeWorkerLabelAndAutonomyAnnotation(cliSet kubeclientset.Interface, node *corev1.Node, lVal, aVal string) (*corev1.Node, error)
• func AnnotateNode(cliSet kubeclientset.Interface, node *corev1.Node, key, val string) (*corev1.Node, error)
• func CreateCRDFromYaml(clientset kubeclientset.Interface, yurtAppManagerClient dynamic.Interface, ...) error
• func CreateClusterRoleBindingFromYaml(cliSet kubeclientset.Interface, crbTmpl string) error
• func CreateClusterRoleFromYaml(cliSet kubeclientset.Interface, crTmpl string) error
• func CreateConfigMapFromYaml(cliSet kubeclientset.Interface, ns, cmTmpl string) error
• func CreateDaemonSetFromYaml(cliSet kubeclientset.Interface, ns, dsTmpl string, ctx interface{}) error
• func CreateDeployFromYaml(cliSet kubeclientset.Interface, ns, dplyTmpl string, ctx interface{}) error
• func CreateMutatingWebhookConfigurationFromYaml(cliSet kubeclientset.Interface, svcTmpl string) error
• func CreateRoleBindingFromYaml(cliSet kubeclientset.Interface, ns, crbTmpl string) error
• func CreateRoleFromYaml(cliSet kubeclientset.Interface, ns, crTmpl string) error
• func CreateSecretFromYaml(cliSet kubeclientset.Interface, ns, saTmpl string) error
• func CreateServiceAccountFromYaml(cliSet kubeclientset.Interface, ns, saTmpl string) error
• func CreateServiceFromYaml(cliSet kubeclientset.Interface, ns, svcTmpl string) error
• func CreateValidatingWebhookConfigurationFromYaml(cliSet kubeclientset.Interface, svcTmpl string) error
• func DeleteYurthubSetting(client kubeclientset.Interface) error
• func DeployYurtControllerManager(client kubeclientset.Interface, yurtControllerManagerImage string) error
• func DeployYurthubSetting(client kubeclientset.Interface) error
• func DeployYurttunnelAgent(client kubeclientset.Interface, tunnelServerAddress string, ...) error
• func DeployYurttunnelServer(client kubeclientset.Interface, certIP string, yurttunnelServerImage string, ...) error
• func GenClientSet(flags *pflag.FlagSet) (*kubeclientset.Clientset, error)
• func GetOrCreateJoinTokenString(cliSet kubeclientset.Interface) (string, error)
• func PrepareKubeConfigPath(flags *pflag.FlagSet) (string, error)
• func RunJobAndCleanup(cliSet kubeclientset.Interface, job *batchv1.Job, ...) error
• func RunServantJobs(cliSet kubeclientset.Interface, waitServantJobTimeout time.Duration, ...) error
• func YamlToObject(yamlContent []byte) (k8sruntime.Object, error)

Constants

const (
	SystemNamespace = "kube-system"
	// DefaultWaitServantJobTimeout specifies the timeout value of waiting for the ServantJob to be succeeded
	DefaultWaitServantJobTimeout = time.Minute * 5
)

Variables

var (
	// PropagationPolicy defines the propagation policy used when deleting a resource
	PropagationPolicy = metav1.DeletePropagationBackground
	// CheckServantJobPeriod defines the time interval between two successive ServantJob statu's inspection
	CheckServantJobPeriod = time.Second * 10
)

Functions

func AddEdgeWorkerLabelAndAutonomyAnnotation

func AddEdgeWorkerLabelAndAutonomyAnnotation(cliSet kubeclientset.Interface, node *corev1.Node, lVal, aVal string) (*corev1.Node, error)

func AnnotateNode

func AnnotateNode(cliSet kubeclientset.Interface, node *corev1.Node, key, val string) (*corev1.Node, error)

AnnotateNode add a new annotation (<key>=<val>) to the given node

func CreateCRDFromYaml

func CreateCRDFromYaml(clientset kubeclientset.Interface, yurtAppManagerClient dynamic.Interface, nameSpace string, filebytes []byte) error

func CreateClusterRoleBindingFromYaml

func CreateClusterRoleBindingFromYaml(cliSet kubeclientset.Interface, crbTmpl string) error

CreateClusterRoleBindingFromYaml creates the ClusterRoleBinding from the yaml template.

func CreateClusterRoleFromYaml

func CreateClusterRoleFromYaml(cliSet kubeclientset.Interface, crTmpl string) error

CreateClusterRoleFromYaml creates the ClusterRole from the yaml template.

func CreateConfigMapFromYaml

func CreateConfigMapFromYaml(cliSet kubeclientset.Interface, ns, cmTmpl string) error

CreateConfigMapFromYaml creates the ConfigMap from the yaml template.

func CreateDaemonSetFromYaml

func CreateDaemonSetFromYaml(cliSet kubeclientset.Interface, ns, dsTmpl string, ctx interface{}) error

CreateDaemonSetFromYaml creates the DaemonSet from the yaml template.

func CreateDeployFromYaml

func CreateDeployFromYaml(cliSet kubeclientset.Interface, ns, dplyTmpl string, ctx interface{}) error

CreateDeployFromYaml creates the Deployment from the yaml template.

func CreateMutatingWebhookConfigurationFromYaml

func CreateMutatingWebhookConfigurationFromYaml(cliSet kubeclientset.Interface, svcTmpl string) error

CreateMutatingWebhookConfigurationFromYaml creates the Service from the yaml template.

func CreateRoleBindingFromYaml

func CreateRoleBindingFromYaml(cliSet kubeclientset.Interface, ns, crbTmpl string) error

CreateRoleBindingFromYaml creates the ClusterRoleBinding from the yaml template.

func CreateRoleFromYaml

func CreateRoleFromYaml(cliSet kubeclientset.Interface, ns, crTmpl string) error

func CreateSecretFromYaml

func CreateSecretFromYaml(cliSet kubeclientset.Interface, ns, saTmpl string) error

CreateSecretFromYaml creates the Secret from the yaml template.

func CreateServiceAccountFromYaml

func CreateServiceAccountFromYaml(cliSet kubeclientset.Interface, ns, saTmpl string) error

CreateServiceAccountFromYaml creates the ServiceAccount from the yaml template.

func CreateServiceFromYaml

func CreateServiceFromYaml(cliSet kubeclientset.Interface, ns, svcTmpl string) error

CreateServiceFromYaml creates the Service from the yaml template.

func CreateValidatingWebhookConfigurationFromYaml

func CreateValidatingWebhookConfigurationFromYaml(cliSet kubeclientset.Interface, svcTmpl string) error

CreateValidatingWebhookConfigurationFromYaml creates the Service from the yaml template.

func DeleteYurthubSetting

func DeleteYurthubSetting(client kubeclientset.Interface) error

DeleteYurthubSetting rm settings for yurthub pod

func DeployYurtControllerManager

func DeployYurtControllerManager(client kubeclientset.Interface, yurtControllerManagerImage string) error

func DeployYurthubSetting

func DeployYurthubSetting(client kubeclientset.Interface) error

DeployYurthubSetting deploy clusterrole, clusterrolebinding for yurthub static pod.

func DeployYurttunnelAgent

func DeployYurttunnelAgent(
	client kubeclientset.Interface,
	tunnelServerAddress string,
	yurttunnelAgentImage string) error

func DeployYurttunnelServer

func DeployYurttunnelServer(
	client kubeclientset.Interface,
	certIP string,
	yurttunnelServerImage string,
	systemArchitecture string) error

func GenClientSet

func GenClientSet(flags *pflag.FlagSet) (*kubeclientset.Clientset, error)

GenClientSet generates the clientset based on command option, environment variable or the default kubeconfig file

func GetOrCreateJoinTokenString

func GetOrCreateJoinTokenString(cliSet kubeclientset.Interface) (string, error)

func PrepareKubeConfigPath

func PrepareKubeConfigPath(flags *pflag.FlagSet) (string, error)

PrepareKubeConfigPath returns the path of cluster kubeconfig file

func RunJobAndCleanup

func RunJobAndCleanup(cliSet kubeclientset.Interface, job *batchv1.Job, timeout, period time.Duration, waitForTimeout bool) error

RunJobAndCleanup runs the job, wait for it to be complete, and delete it

func RunServantJobs

func RunServantJobs(
	cliSet kubeclientset.Interface,
	waitServantJobTimeout time.Duration,
	getJob func(nodeName string) (*batchv1.Job, error),
	nodeNames []string, ww io.Writer,
	waitForTimeout bool) error

RunServantJobs launch servant jobs on specified nodes and wait all jobs to finish. Succeed jobs will be deleted when finished. Failed jobs are preserved for diagnosis.

func YamlToObject

func YamlToObject(yamlContent []byte) (k8sruntime.Object, error)

YamlToObject deserializes object in yaml format to a runtime.Object