common

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2023 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Overview

Copyright 2020 The SuperEdge Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	NodesKubeadmConfigClusterRoleName = "kubeadm:nodes-kubeadm-config"
	GetNodesClusterRoleName           = "kubeadm:get-nodes"
	NodeBootstrapperClusterRoleName   = "system:node-bootstrapper"
	KubeletBootstrapClusterRoleName   = "kubeadm:kubelet-bootstrap"
)

Variables

This section is empty.

Functions

func CheckIfEdgeAppDeletable 

func CheckIfEdgeAppDeletable(clientSet kubernetes.Interface) bool

func ClearJob 

func ClearJob(clientSet *kubernetes.Clientset, label string) error

func CreateByYamlFile 

func CreateByYamlFile(clientSet kubernetes.Interface, yamlFile string) error

func CreateNamespace 

func CreateNamespace(client kubernetes.Interface, namespace string) error

func DeleteByYamlFile 

func DeleteByYamlFile(clientSet kubernetes.Interface, yamlFile string) error

func DeleteEdgeAPPS 

func DeleteEdgeAPPS(client kubernetes.Interface, manifestsDir, caCertFile, caKeyFile string, masterPublicAddr string, certSANs []string, configPath string) error

func DeleteEdgeCoredns 

func DeleteEdgeCoredns(kubeconfigFile string, manifestsDir string) error

DeleteEdgeCoredns uninstalls edge node CoreDNS addon to a Kubernetes cluster

func DeleteEdgeHealth 

func DeleteEdgeHealth(clientSet kubernetes.Interface, manifestsDir string) error

func DeleteEdgex 

func DeleteEdgex(client *kubernetes.Clientset, manifestsDir string, modules []bool) error

func DeleteLiteApiServerCert 

func DeleteLiteApiServerCert(clientSet kubernetes.Interface) error

func DeleteServiceGroup 

func DeleteServiceGroup(clientSet kubernetes.Interface) error

func DeleteSiteManager added in v0.9.0 

func DeleteSiteManager(kubeconfigFile string, manifestsDir string) error

DeleteSiteManager uninstalls edge node CoreDNS addon to a Kubernetes cluster

func DeleteTunnelAddon 

func DeleteTunnelAddon(client kubernetes.Interface, manifestsDir, caCertFile, caKeyFile string, tunnelCloudPublicAddr string, certSANs []string) error

func DeleteTunnelCloud 

func DeleteTunnelCloud(clientSet kubernetes.Interface, manifestsDir, caCertFile, caKeyFile, tunnelCloudToken string, certSANs []string) error

func DeleteTunnelEdge 

func DeleteTunnelEdge(clientSet kubernetes.Interface, manifestsDir,
	caCertFile, caKeyFile, tunnelCloudToken string, tunnelCloudNodeAddr string, tunnelCloudNodePort int32) error

func DeployEdgeAPPS 

func DeployEdgeAPPS(client kubernetes.Interface, manifestsDir, caCertFile, caKeyFile, masterPublicAddr string, certSANs []string, configPath string, edgeadmConf *cmd.EdgeadmConfig) error

func DeployEdgeCorednsAddon 

func DeployEdgeCorednsAddon(client kubernetes.Interface, manifestsDir string, edgeadmConf *cmd.EdgeadmConfig) error

DeployEdgeCorednsAddon installs edge node CoreDNS addon to a Kubernetes cluster

func DeployEdgeHealth 

func DeployEdgeHealth(clientSet kubernetes.Interface, manifestsDir string, edgeadmConf *cmd.EdgeadmConfig) error

func DeployEdgePreflight 

func DeployEdgePreflight(clientSet kubernetes.Interface, manifestsDir string, masterPublicAddr string, configPath string) error

DeployEdgePreflight is a preflight step for the addon.

func DeployEdgex 

func DeployEdgex(client *kubernetes.Clientset, manifestsDir string, modules []bool) error

func DeployHelperJob 

func DeployHelperJob(clientSet *kubernetes.Clientset, helperYaml, action, role string) error

func DeployServiceGroup 

func DeployServiceGroup(clientSet kubernetes.Interface, manifestsDir string, cfg *kubeadmapi.InitConfiguration, edgeConf *cmd.EdgeadmConfig) error

func DeploySiteManager added in v0.9.0 

func DeploySiteManager(clientSet kubernetes.Interface, manifestsDir string, edgeadmConf *cmd.EdgeadmConfig) error

func DeployTopolvmAppS 

func DeployTopolvmAppS(kubeconfigFile, manifestsDir string) error

func DeployTopolvmCRD 

func DeployTopolvmCRD(kubeconfigFile string, manifestsDir string) error

func DeployTopolvmController 

func DeployTopolvmController(client *kubernetes.Clientset, manifestsDir string) error

DeployTopolvmController installs topolvm controller to a Kubernetes cluster

func DeployTopolvmLvmd 

func DeployTopolvmLvmd(client *kubernetes.Clientset, manifestsDir string) error

DeployTopolvmLvmd installs topolvm-lvmd to a Kubernetes cluster

func DeployTopolvmNode 

func DeployTopolvmNode(client *kubernetes.Clientset, manifestsDir string) error

DeployTopolvmNode installs topolvm-node to a Kubernetes cluster

func DeployTopolvmScheduler 

func DeployTopolvmScheduler(client *kubernetes.Clientset, manifestsDir string) error

DeployTopolvmscheduler installs topolvm scheduler to a Kubernetes cluster

func DeployTopolvmWebhook 

func DeployTopolvmWebhook(client *kubernetes.Clientset, manifestsDir string) error

DeployTopolvmWebhook installs topolvm webhook to a Kubernetes cluster

func DeployTunnelAddon 

func DeployTunnelAddon(kubeconfigFile string, client kubernetes.Interface, manifestsDir, caCertFile, caKeyFile, tunnelCloudPublicAddr string, certSANs []string) error

runCoreDNSAddon installs CoreDNS addon to a Kubernetes cluster

func DeployTunnelCloud 

func DeployTunnelCloud(clientSet kubernetes.Interface, manifestsDir, caCertFile, caKeyFile, tunnelCloudToken string, certSANs []string, cfg *kubeadmapi.InitConfiguration, edgeadmConf *cmd.EdgeadmConfig) error

func DeployTunnelEdge 

func DeployTunnelEdge(clientSet kubernetes.Interface, manifestsDir,
	caCertFile, caKeyFile, tunnelCloudToken, tunnelCloudNodeAddr string, tunnelCloudNodePort int32, cfg *kubeadmapi.InitConfiguration, edgeadmConf *cmd.EdgeadmConfig) error

func EnsureEdgeSystemNamespace 

func EnsureEdgeSystemNamespace(client kubernetes.Interface) error

func EnsureEdgexNamespace 

func EnsureEdgexNamespace(client kubernetes.Interface) error

func GenEdgeWebhookCertAndKey 

func GenEdgeWebhookCertAndKey(ca *x509.Certificate, key *rsa.PrivateKey) (serverCrt, serverKey string, err error)

func GenerateEdgeWebhookCA 

func GenerateEdgeWebhookCA() (caBundle string, caCert *x509.Certificate, caPrivKey *rsa.PrivateKey, err error)

func GetCertAndKey 

func GetCertAndKey(caCertFile, caKeyFile string) (*x509.Certificate, *rsa.PrivateKey, error)

func GetClientCert 

func GetClientCert(commonName, certPath, keyPath string) ([]byte, []byte, error)

func GetEdgeDnsImage 

func GetEdgeDnsImage(edgeConf *cmd.EdgeadmConfig) string

func GetEdgeFlannel 

func GetEdgeFlannel(edgeConf *cmd.EdgeadmConfig) string

func GetEdgeKubeProxy 

func GetEdgeKubeProxy(edgeConf *cmd.EdgeadmConfig, k8sversion string) string

func GetIndexedIP 

func GetIndexedIP(subnet string, index int) (net.IP, error)

func GetInitCniPlugin added in v0.8.1 

func GetInitCniPlugin(edgeConf *cmd.EdgeadmConfig) string

func GetKubeAPIServerAddr 

func GetKubeAPIServerAddr(clientSet kubernetes.Interface) (string, error)

func GetMasterIps 

func GetMasterIps(clientSet kubernetes.Interface) ([]string, error)

func GetRootCartAndKey 

func GetRootCartAndKey(certPath, keyPath string) ([]byte, []byte, error)

func GetServiceCert 

func GetServiceCert(commonName, caCertFile, caKeyFile string, dns []string, ips []string) ([]byte, []byte, error)

func GetSuperEdgeImage 

func GetSuperEdgeImage(image string, edgeConf *cmd.EdgeadmConfig) (string, error)

func GetTunnelCloudPort 

func GetTunnelCloudPort(clientSet kubernetes.Interface) (int32, error)

func IgnoreTopolvmWebookNamesapceMatchExpressions 

func IgnoreTopolvmWebookNamesapceMatchExpressions(client *kubernetes.Clientset) error

func JoinNodePrepare 

func JoinNodePrepare(clientSet kubernetes.Interface, manifestsDir, caCertFile, caKeyFile string, egeadmConf *cmd.EdgeadmConfig) error

func ParseCertAndKey 

func ParseCertAndKey(ca, key []byte) (*x509.Certificate, *rsa.PrivateKey, error)

func PatchKubeProxy 

func PatchKubeProxy(clientSet kubernetes.Interface) error

func ReadYaml 

func ReadYaml(inputPath, defaults string) string

func RecoverClusterInfoKubeconfig 

func RecoverClusterInfoKubeconfig(kubeClient kubernetes.Interface, certSANs []string) error

func RecoverKubeConfig 

func RecoverKubeConfig(client kubernetes.Interface) error

func RecoverKubeProxy 

func RecoverKubeProxy(clientSet kubernetes.Interface) error

func RecoverKubeProxyKubeconfig 

func RecoverKubeProxyKubeconfig(kubeClient kubernetes.Interface) error

func RecoverKubernetesEndpoint 

func RecoverKubernetesEndpoint(clientSet kubernetes.Interface) error

func RemoveNamespace 

func RemoveNamespace(client kubernetes.Interface, namespace string) error

func RemoveTopolvmApps 

func RemoveTopolvmApps(kubeconfigFile, manifestsDir string) error

func RemoveTopolvmCRD 

func RemoveTopolvmCRD(client *kubernetes.Clientset, manifestsDir string) error

func RemoveTopolvmController 

func RemoveTopolvmController(client *kubernetes.Clientset, manifestsDir string) error

RemoveTopolvmController remove topolvm controller to a Kubernetes cluster

func RemoveTopolvmLvmd 

func RemoveTopolvmLvmd(client *kubernetes.Clientset, manifestsDir string) error

RemoveTopolvmLvmd remove topolvm-lvmd to a Kubernetes cluster

func RemoveTopolvmNode 

func RemoveTopolvmNode(client *kubernetes.Clientset, manifestsDir string) error

RemoveTopolvmNode remove topolvm-node to a Kubernetes cluster

func RemoveTopolvmScheduler 

func RemoveTopolvmScheduler(client *kubernetes.Clientset, manifestsDir string) error

RemoveTopolvmscheduler remove topolvm scheduler to a Kubernetes cluster

func RemoveTopolvmWebhook 

func RemoveTopolvmWebhook(client *kubernetes.Clientset, manifestsDir string) error

RemoveTopolvmWebhook remove topolvm webhook to a Kubernetes cluster

func SetPackagePath 

func SetPackagePath(workerPath, kubeconfigDir string) error

func UnzipPackage 

func UnzipPackage(srcPackage, dstPath string) error

func UpdateClusterInfoKubeconfig 

func UpdateClusterInfoKubeconfig(kubeClient kubernetes.Interface, certSANs []string) error

func UpdateKubeConfig 

func UpdateKubeConfig(client kubernetes.Interface, edgeConf *cmd.EdgeadmConfig) error

runCoreDNSAddon installs CoreDNS addon to a Kubernetes cluster

func UpdateKubeProxyKubeconfig 

func UpdateKubeProxyKubeconfig(kubeClient kubernetes.Interface, cfg *kubeadmapi.InitConfiguration, edgeConf *cmd.EdgeadmConfig) error

func UpdateKubernetesEndpoint 

func UpdateKubernetesEndpoint(clientSet kubernetes.Interface, edgeConf *cmd.EdgeadmConfig) error

func UpdateKubernetesEndpointSlice 

func UpdateKubernetesEndpointSlice(clientSet kubernetes.Interface, edgeConf *cmd.EdgeadmConfig) error

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.