util

Documentation

Index

• func GVKToString(gvk schema.GroupVersionKind) string
• func GetEndpointForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) clusterregistryv1alpha1.KubernetesAPIEndpoint
• func GetExternalAddressOfAPIServer(kubeConfig *rest.Config) (string, error)
• func GetKubeconfigOverridesForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) (*clientcmd.ConfigOverrides, error)
• func GetKubeconfigWithSAToken(name, username, endpointURL string, caData []byte, saToken string) (string, error)
• func GetReaderSecretForCluster(ctx context.Context, kubeClient client.Client, kubeConfig *rest.Config, ...) (*corev1.Secret, error)
• func GetReaderSecretTokenAndCACert(ctx context.Context, kubeClient client.Client, saRef types.NamespacedName) ([]byte, []byte, error)
• func K8SResourceOverlayPatchExecuteTemplate(patch resources.K8SResourceOverlayPatch, data interface{}) (resources.K8SResourceOverlayPatch, error)
• func K8SResourceOverlayPatchExecuteTemplates(patches []resources.K8SResourceOverlayPatch, data interface{}) ([]resources.K8SResourceOverlayPatch, error)
• func NewLocalCluster(c client.Client, namespace, name, apiServerEndpointAddress string) (*v1alpha1.Cluster, error)
• func ParseGVKFromString(str string) *schema.GroupVersionKind
• func ProvisionLocalClusterObject(c client.Client, log logr.Logger, configuration config.Configuration) error

Functions

func GVKToString

func GVKToString(gvk schema.GroupVersionKind) string

func GetEndpointForClusterByNetwork

func GetEndpointForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) clusterregistryv1alpha1.KubernetesAPIEndpoint

func GetExternalAddressOfAPIServer

func GetExternalAddressOfAPIServer(kubeConfig *rest.Config) (string, error)

func GetKubeconfigOverridesForClusterByNetwork

func GetKubeconfigOverridesForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) (*clientcmd.ConfigOverrides, error)

func GetKubeconfigWithSAToken

func GetKubeconfigWithSAToken(name, username, endpointURL string, caData []byte, saToken string) (string, error)

func GetReaderSecretForCluster

func GetReaderSecretForCluster(ctx context.Context, kubeClient client.Client, kubeConfig *rest.Config, cluster *clusterregistryv1alpha1.Cluster, saRef types.NamespacedName, apiServerEndpointAddress string) (*corev1.Secret, error)

func GetReaderSecretTokenAndCACert

func GetReaderSecretTokenAndCACert(ctx context.Context, kubeClient client.Client, saRef types.NamespacedName) ([]byte, []byte, error)

func K8SResourceOverlayPatchExecuteTemplate

func K8SResourceOverlayPatchExecuteTemplate(patch resources.K8SResourceOverlayPatch, data interface{}) (resources.K8SResourceOverlayPatch, error)

func K8SResourceOverlayPatchExecuteTemplates

func K8SResourceOverlayPatchExecuteTemplates(patches []resources.K8SResourceOverlayPatch, data interface{}) ([]resources.K8SResourceOverlayPatch, error)

func NewLocalCluster

func NewLocalCluster(c client.Client, namespace, name, apiServerEndpointAddress string) (*v1alpha1.Cluster, error)

func ParseGVKFromString

func ParseGVKFromString(str string) *schema.GroupVersionKind

func ProvisionLocalClusterObject

func ProvisionLocalClusterObject(c client.Client, log logr.Logger, configuration config.Configuration) error