clusterproxy

Documentation

Index

• func CreateKubeconfig(logger logr.Logger, kubeconfigContent []byte) (fileName string, closer func(), err error)
• func GetCAPIKubernetesClient(ctx context.Context, logger logr.Logger, c client.Client, s *runtime.Scheme, ...) (client.Client, error)
• func GetCAPIKubernetesRestConfig(ctx context.Context, logger logr.Logger, c client.Client, ...) (*rest.Config, error)
• func GetCAPISecretData(ctx context.Context, logger logr.Logger, c client.Client, ...) ([]byte, error)
• func GetCluster(ctx context.Context, c client.Client, clusterNamespace, clusterName string, ...) (client.Object, error)
• func GetClusterType(cluster *corev1.ObjectReference) libsveltosv1beta1.ClusterType
• func GetKubernetesClient(ctx context.Context, c client.Client, ...) (client.Client, error)
• func GetKubernetesRestConfig(ctx context.Context, c client.Client, ...) (*rest.Config, error)
• func GetListOfClusters(ctx context.Context, c client.Client, namespace, capiOnboardAnnotation string, ...) ([]corev1.ObjectReference, error)
• func GetListOfClustersForShardKey(ctx context.Context, c client.Client, ...) ([]corev1.ObjectReference, error)
• func GetMachinesForCluster(ctx context.Context, c client.Client, cluster *corev1.ObjectReference, ...) (*clusterv1.MachineList, error)
• func GetMatchingClusters(ctx context.Context, c client.Client, selector *metav1.LabelSelector, ...) ([]corev1.ObjectReference, error)
• func GetSecretData(ctx context.Context, c client.Client, ...) ([]byte, error)
• func GetSveltosKubernetesClient(ctx context.Context, logger logr.Logger, c client.Client, s *runtime.Scheme, ...) (client.Client, error)
• func GetSveltosKubernetesRestConfig(ctx context.Context, logger logr.Logger, c client.Client, ...) (*rest.Config, error)
• func GetSveltosSecretData(ctx context.Context, logger logr.Logger, c client.Client, ...) ([]byte, error)
• func GetSveltosSecretNameAndKey(ctx context.Context, logger logr.Logger, c client.Client, ...) (secretName, secretkey string, err error)
• func IsClusterPaused(ctx context.Context, c client.Client, clusterNamespace, clusterName string, ...) (bool, error)
• func IsClusterReadyToBeConfigured(ctx context.Context, c client.Client, cluster *corev1.ObjectReference, ...) (bool, error)
• func UpdateSveltosSecretData(ctx context.Context, logger logr.Logger, c client.Client, ...) error

Functions

func CreateKubeconfig

func CreateKubeconfig(logger logr.Logger, kubeconfigContent []byte) (fileName string, closer func(), err error)

CreateKubeconfig creates a temporary file with the Kubeconfig to access CAPI cluster

func GetCAPIKubernetesClient

func GetCAPIKubernetesClient(ctx context.Context, logger logr.Logger, c client.Client,
	s *runtime.Scheme, clusterNamespace, clusterName string) (client.Client, error)

GetCAPIKubernetesClient returns a client to access CAPI Cluster clusterNamespace/clusterName c is the client to access management cluster

func GetCAPIKubernetesRestConfig

func GetCAPIKubernetesRestConfig(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName string) (*rest.Config, error)

GetCAPIKubernetesRestConfig returns rest.Config for a CAPI Cluster clusterNamespace/clusterName c is the client to access management cluster

func GetCAPISecretData

func GetCAPISecretData(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName string) ([]byte, error)

GetCAPISecretData verifies Cluster exists and returns the content of secret containing the kubeconfig for CAPI cluster

func GetCluster

func GetCluster(ctx context.Context, c client.Client,
	clusterNamespace, clusterName string, clusterType libsveltosv1beta1.ClusterType) (client.Object, error)

getCluster returns the cluster object

func GetClusterType

func GetClusterType(cluster *corev1.ObjectReference) libsveltosv1beta1.ClusterType

GetClusterType returns clustertype for a given cluster

func GetKubernetesClient

func GetKubernetesClient(ctx context.Context, c client.Client,
	clusterNamespace, clusterName, adminNamespace, adminName string,
	clusterType libsveltosv1beta1.ClusterType, logger logr.Logger) (client.Client, error)

GetKubernetesClient returns client to access cluster

func GetKubernetesRestConfig

func GetKubernetesRestConfig(ctx context.Context, c client.Client,
	clusterNamespace, clusterName, adminNamespace, adminName string,
	clusterType libsveltosv1beta1.ClusterType, logger logr.Logger) (*rest.Config, error)

GetKubernetesRestConfig returns restConfig for a cluster

func GetListOfClusters

func GetListOfClusters(ctx context.Context, c client.Client, namespace, capiOnboardAnnotation string,
	logger logr.Logger) ([]corev1.ObjectReference, error)

GetListOfClusters returns all existing Sveltos/CAPI Clusters. If namespace is not empty, clusters in different namespaces are filtered out. If capiOnboardAnnotation is set, clusters without this annotation are filtered out.

func GetListOfClustersForShardKey

func GetListOfClustersForShardKey(ctx context.Context, c client.Client,
	namespace, capiOnboardAnnotation, shard string, logger logr.Logger) ([]corev1.ObjectReference, error)

GetListOfClustersForShardKey returns all existing Sveltos/CAPI Clusters for a given shard If namespace is not empty, clusters in different namespaces are filtered out. If capiOnboardAnnotation is set, clusters without this annotation are filtered out.

func GetMachinesForCluster

func GetMachinesForCluster(
	ctx context.Context, c client.Client,
	cluster *corev1.ObjectReference, logger logr.Logger,
) (*clusterv1.MachineList, error)

GetMachinesForCluster find all Machines for a given CAPI Cluster.

func GetMatchingClusters

func GetMatchingClusters(ctx context.Context, c client.Client, selector *metav1.LabelSelector,
	namespace, capiOnboardAnnotation string, logger logr.Logger) ([]corev1.ObjectReference, error)

GetMatchingClusters returns CAPI clusters matching the selector. If capiOnboardAnnotation is set, only clusters with that annotation are considered and selector match evaluated.

func GetSecretData

func GetSecretData(ctx context.Context, c client.Client,
	clusterNamespace, clusterName, adminNamespace, adminName string,
	clusterType libsveltosv1beta1.ClusterType, logger logr.Logger) ([]byte, error)

GetSecretData returns Kubeconfig to access cluster

func GetSveltosKubernetesClient

func GetSveltosKubernetesClient(ctx context.Context, logger logr.Logger, c client.Client,
	s *runtime.Scheme, clusterNamespace, clusterName string) (client.Client, error)

GetSveltosKubernetesClient returns a client to access Sveltos Cluster clusterNamespace/clusterName c is the client to access management cluster

func GetSveltosKubernetesRestConfig

func GetSveltosKubernetesRestConfig(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName string) (*rest.Config, error)

GetSveltosKubernetesRestConfig returns rest.Config for a Sveltos Cluster clusterNamespace/clusterName c is the client to access management cluster

func GetSveltosSecretData

func GetSveltosSecretData(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName string) ([]byte, error)

GetSveltosSecretData verifies Cluster exists and returns the content of secret containing the kubeconfig for Sveltos cluster.

func GetSveltosSecretNameAndKey

func GetSveltosSecretNameAndKey(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName string) (secretName, secretkey string, err error)

GetSveltosSecretNameAndKey returns the name of the Secret containing the Kubeconfig for the SveltosCluster. If a key is specified, returns the name of the key to use.

func IsClusterPaused

func IsClusterPaused(ctx context.Context, c client.Client,
	clusterNamespace, clusterName string, clusterType libsveltosv1beta1.ClusterType) (bool, error)

IsClusterPaused returns true if cluster is currently paused

func IsClusterReadyToBeConfigured

func IsClusterReadyToBeConfigured(
	ctx context.Context, c client.Client, cluster *corev1.ObjectReference,
	logger logr.Logger,
) (bool, error)

IsClusterReadyToBeConfigured returns true if cluster is ready to be configured

func UpdateSveltosSecretData

func UpdateSveltosSecretData(ctx context.Context, logger logr.Logger, c client.Client,
	clusterNamespace, clusterName, kubeconfig, kubeconfigKey string) error

UpdateSveltosSecretData updates the content of the secret containing the the kubeconfig for Sveltos cluster