common

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 2 more Imports: 56 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 added in v0.4.0 

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 added in v0.6.0 

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

func DeleteByYamlFile 

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

func DeleteEdgeAPPS added in v0.4.0 

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

func DeleteEdgeCoredns added in v0.5.0 

func DeleteEdgeCoredns(kubeconfigFile string, manifestsDir string) error

DeleteEdgeCoredns uninstalls edge node CoreDNS addon to a Kubernetes cluster

func DeleteEdgeHealth added in v0.4.0 

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

func DeleteEdgex added in v0.6.0 

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

func DeleteLiteApiServerCert added in v0.4.0 

func DeleteLiteApiServerCert(clientSet kubernetes.Interface) error

func DeleteServiceGroup added in v0.4.0 

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

func DeleteTunnelAddon added in v0.4.0 

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

func DeleteTunnelCloud added in v0.4.0 

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

func DeleteTunnelEdge added in v0.4.0 

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

func DeployEdgeAPPS added in v0.3.0 

func DeployEdgeAPPS(client *kubernetes.Clientset, manifestsDir, caCertFile, caKeyFile, masterPublicAddr string, certSANs []string, configPath string) error

func DeployEdgeCorednsAddon added in v0.5.0 

func DeployEdgeCorednsAddon(kubeconfigFile string, manifestsDir string) error

DeployEdgeCorednsAddon installs edge node CoreDNS addon to a Kubernetes cluster

func DeployEdgeHealth added in v0.3.0 

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

func DeployEdgePreflight added in v0.4.0 

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

DeployEdgePreflight is a preflight step for the addon.

func DeployEdgex added in v0.6.0 

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

func DeployHelperJob 

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

func DeployServiceGroup added in v0.3.0 

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

func DeployTopolvmAppS added in v0.6.0 

func DeployTopolvmAppS(kubeconfigFile, manifestsDir string) error

func DeployTopolvmCRD added in v0.6.0 

func DeployTopolvmCRD(kubeconfigFile string, manifestsDir string) error

func DeployTopolvmController added in v0.6.0 

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

DeployTopolvmController installs topolvm controller to a Kubernetes cluster

func DeployTopolvmLvmd added in v0.6.0 

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

DeployTopolvmLvmd installs topolvm-lvmd to a Kubernetes cluster

func DeployTopolvmNode added in v0.6.0 

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

DeployTopolvmNode installs topolvm-node to a Kubernetes cluster

func DeployTopolvmScheduler added in v0.6.0 

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

DeployTopolvmscheduler installs topolvm scheduler to a Kubernetes cluster

func DeployTopolvmWebhook added in v0.6.0 

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

DeployTopolvmWebhook installs topolvm webhook to a Kubernetes cluster

func DeployTunnelAddon added in v0.3.0 

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

runCoreDNSAddon installs CoreDNS addon to a Kubernetes cluster

func DeployTunnelCloud added in v0.3.0 

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

func DeployTunnelEdge added in v0.3.0 

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

func EnsureEdgeSystemNamespace added in v0.4.0 

func EnsureEdgeSystemNamespace(client kubernetes.Interface) error

func EnsureEdgexNamespace added in v0.6.0 

func EnsureEdgexNamespace(client kubernetes.Interface) error

func GenEdgeWebhookCertAndKey added in v0.4.0 

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

func GenerateEdgeWebhookCA added in v0.4.0 

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

func GetCertAndKey added in v0.3.0 

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

func GetClientCert 

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

func GetIndexedIP added in v0.3.0 

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

func GetKubeAPIServerAddr added in v0.3.0 

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 added in v0.3.0 

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

func GetTunnelCloudPort added in v0.3.0 

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

func IgnoreTopolvmWebookNamesapceMatchExpressions added in v0.6.0 

func IgnoreTopolvmWebookNamesapceMatchExpressions(client *kubernetes.Clientset) error

func JoinNodePrepare added in v0.5.0 

func JoinNodePrepare(clientSet kubernetes.Interface, manifestsDir, caCertFile, caKeyFile string) error

func ParseCertAndKey 

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

func PatchKubeProxy added in v0.3.0 

func PatchKubeProxy(clientSet kubernetes.Interface) error

func ReadYaml 

func ReadYaml(inputPath, defaults string) string

func RecoverClusterInfoKubeconfig added in v0.4.0 

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

func RecoverKubeConfig added in v0.4.0 

func RecoverKubeConfig(client *kubernetes.Clientset) error

func RecoverKubeProxy added in v0.6.1 

func RecoverKubeProxy(clientSet kubernetes.Interface) error

func RecoverKubeProxyKubeconfig added in v0.4.0 

func RecoverKubeProxyKubeconfig(kubeClient kubernetes.Interface) error

func RecoverKubernetesEndpoint added in v0.4.0 

func RecoverKubernetesEndpoint(clientSet kubernetes.Interface) error

func RemoveNamespace added in v0.6.0 

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

func RemoveTopolvmApps added in v0.6.0 

func RemoveTopolvmApps(kubeconfigFile, manifestsDir string) error

func RemoveTopolvmCRD added in v0.6.0 

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

func RemoveTopolvmController added in v0.6.0 

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

RemoveTopolvmController remove topolvm controller to a Kubernetes cluster

func RemoveTopolvmLvmd added in v0.6.0 

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

RemoveTopolvmLvmd remove topolvm-lvmd to a Kubernetes cluster

func RemoveTopolvmNode added in v0.6.0 

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

RemoveTopolvmNode remove topolvm-node to a Kubernetes cluster

func RemoveTopolvmScheduler added in v0.6.0 

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

RemoveTopolvmscheduler remove topolvm scheduler to a Kubernetes cluster

func RemoveTopolvmWebhook added in v0.6.0 

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

RemoveTopolvmWebhook remove topolvm webhook to a Kubernetes cluster

func SetPackagePath added in v0.3.0 

func SetPackagePath(workerPath, kubeconfigDir string) error

func UnzipPackage added in v0.3.0 

func UnzipPackage(srcPackage, dstPath string) error

func UpdateClusterInfoKubeconfig added in v0.3.0 

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

func UpdateKubeConfig added in v0.3.0 

func UpdateKubeConfig(client *kubernetes.Clientset) error

runCoreDNSAddon installs CoreDNS addon to a Kubernetes cluster

func UpdateKubeProxyKubeconfig added in v0.3.0 

func UpdateKubeProxyKubeconfig(kubeClient kubernetes.Interface) error

func UpdateKubernetesEndpoint added in v0.3.0 

func UpdateKubernetesEndpoint(clientSet kubernetes.Interface) error

func UpdateKubernetesEndpointSlice added in v0.7.0 

func UpdateKubernetesEndpointSlice(clientSet kubernetes.Interface) 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.