The highest tagged major version is v5.

util

package

v0.5.0-b26f4 Latest Latest Go to latest Published: Feb 15, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation ¶

Index ¶

Constants
func CreateCertificate(clusterManager *clusterv1alpha1.ClusterManager) *certmanagerv1.Certificate
func CreateEndpoint(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Endpoints
func CreateIngress(clusterManager *clusterv1alpha1.ClusterManager) *networkingv1.Ingress
func CreateMiddleware(clusterManager *clusterv1alpha1.ClusterManager) *traefikv2.Middleware
func CreatePrometheusEndpoint(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Endpoints
func CreatePrometheusService(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Service
func CreateService(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Service
func CreateSuffixString() string
func Delete(namespace, cluster string) error
func GetK8sClient() (*kubernetes.Clientset, error)
func GetProviderName(provider string) (string, error)
func GetRemoteK8sClient(secret *corev1.Secret) (*kubernetes.Clientset, error)
func GetRemoteK8sClientByKubeConfig(kubeConfig []byte) (*kubernetes.Clientset, error)
func Insert(clusterManager *clusterv1alpha1.ClusterManager) error
func IsIpAddress(endPoint string) bool
func LowestNonZeroResult(i, j ctrl.Result) ctrl.Result
func MergeJson(dest []byte, source []byte) []byte
func URIToSecretName(uriType, uri string) (string, error)

Constants ¶

View Source

const (
	KubeNamespace                      = "kube-system"
	WatchAnnotationJoinValue           = "join"
	WatchAnnotationJoinSuccess         = "complete"
	WatchAnnotationUnJoinValue         = "unjoin"
	KubeconfigSuffix                   = "-kubeconfig"
	ClusterNamespace                   = "default"
	MonitoringNamespace                = "monitoring"
	HYPERCLOUD_SYSTEM_NAMESPACE        = "hypercloud5-system"
	MultiApiServerNamespace            = "hypercloud4-multi-system"
	MultiApiServerServiceName          = "hypercloud4-multi-api-server-service"
	SecretFinalizer                    = "secret/finalizers"
	ClusterManagerFinalizer            = "clusterManager.cluster.tmax.io"
	SecretFinalizerForClusterManager   = "secretforclustermanager/finalizers"
	MultiApiServerServiceSelectorKey   = "hypercloud4"
	MultiApiServerServiceSelectorValue = "multi-api-server"
	ClusterTypeCreated                 = "created"
	ClusterTypeRegistered              = "registered"
	IngressNginxNamespace              = "ingress-nginx"
	IngressNginxName                   = "ingress-nginx-controller"
	ClusterApiKind                     = "clustermanagers"
	ClusterApiGroupVersion             = "cluster.tmax.io/v1alpha1"
	AgentIngressName                   = "hypercloud-ingress"
	SuffixDigit                        = 5
	HypercloudIngressClass             = "tmax-cloud"
	HypercloudMultiIngressClass        = "multicluster"
	HypercloudMultiIngressSubdomain    = "multicluster"
	ApiGatewayNamespace                = "api-gateway-system"

	ProviderAws     = "AWS"
	ProviderVsphere = "VSPHERE"
	ProviderUnknown = "Unknown"

	ProviderAwsLogo     = "AWS"
	ProviderVsphereLogo = "vSphere"

	ArgoApiGroup           = "argocd.argoproj.io"
	ArgoNamespace          = "argocd"
	ArgoServiceAccount     = "argocd-manager"
	ArgoClusterRole        = "argocd-manager-role"
	ArgoClusterRoleBinding = "argocd-manager-role-binding"
	ArgoSecretTypeCluster  = "cluster"

	AnnotationKeyOwner                  = "owner"
	AnnotationKeyCreator                = "creator"
	AnnotationKeyArgoClusterSecret      = "argocd.argoproj.io/cluster.secret"
	AnnotationKeyArgoManagedBy          = "managed-by"
	AnnotationKeyTraefikServerTransport = "traefik.ingress.kubernetes.io/service.serverstransport"
	AnnotationKeyTraefikEntrypoints     = "traefik.ingress.kubernetes.io/router.entrypoints"
	AnnotationKeyTraefikMiddlewares     = "traefik.ingress.kubernetes.io/router.middlewares"
	AnnotationKeyTraefikServerScheme    = "traefik.ingress.kubernetes.io/service.serversscheme"
	AnnotationKeyClmApiserverEndpoint   = "clustermanager.tmax.io/apiserver.endpoint"
	AnnotationKeyClmGatewayEndpoint     = "clustermanager.tmax.io/gateway.endpoint"
	AnnotationKeyClmSuffix              = "clustermanager.tmax.io/suffix"
	AnnotationKeyClmDns                 = "clustermanager.tmax.io/dns"

	LabelKeyHypercloudIngress = "ingress.tmaxcloud.org/name"
	LabelKeyClmRef            = "clustermanager.tmax.io/clm.ref"
	LabelKeyClmParent         = "parent"
	LabelKeyClmClusterType    = "type"
	LabelKeyArgoSecretType    = "argocd.argoproj.io/secret-type"
)

Variables ¶

This section is empty.

Functions ¶

func CreateCertificate ¶

func CreateCertificate(clusterManager *clusterv1alpha1.ClusterManager) *certmanagerv1.Certificate

func CreateEndpoint ¶

func CreateEndpoint(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Endpoints

func CreateIngress ¶

func CreateIngress(clusterManager *clusterv1alpha1.ClusterManager) *networkingv1.Ingress

func CreateMiddleware ¶

func CreateMiddleware(clusterManager *clusterv1alpha1.ClusterManager) *traefikv2.Middleware

func CreatePrometheusEndpoint ¶

func CreatePrometheusEndpoint(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Endpoints

func CreatePrometheusService ¶

func CreatePrometheusService(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Service

func CreateService ¶

func CreateService(clusterManager *clusterv1alpha1.ClusterManager) *corev1.Service

func CreateSuffixString ¶

func CreateSuffixString() string

func Delete ¶

func Delete(namespace, cluster string) error

func GetK8sClient ¶

func GetK8sClient() (*kubernetes.Clientset, error)

func GetProviderName ¶

func GetProviderName(provider string) (string, error)

func GetRemoteK8sClient ¶

func GetRemoteK8sClient(secret *corev1.Secret) (*kubernetes.Clientset, error)

func GetRemoteK8sClientByKubeConfig ¶

func GetRemoteK8sClientByKubeConfig(kubeConfig []byte) (*kubernetes.Clientset, error)

func Insert ¶

func Insert(clusterManager *clusterv1alpha1.ClusterManager) error

func IsIpAddress ¶

func IsIpAddress(endPoint string) bool

func LowestNonZeroResult ¶

func LowestNonZeroResult(i, j ctrl.Result) ctrl.Result

LowestNonZeroResult compares two reconciliation results and returns the one with lowest requeue time.

func MergeJson ¶

func MergeJson(dest []byte, source []byte) []byte

func URIToSecretName ¶

func URIToSecretName(uriType, uri string) (string, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL