util

Documentation

Index

• func AppendResourceSelector(cpp *policyv1alpha1.ClusterPropagationPolicy, ...)
• func ApplyPropagationPolicy(c *client.Client, clusters []string, obj runtime.Object) error
• func CreateBearerTokenKubeconfig(caData, token []byte, clusterName, server string) *api.Config
• func DownloadResource(url, path string) (raw string, err error)
• func IsClustersReady(karmada karmadaclientset.Interface, clusterNames ...string) error
• func JoinUrlPath(base string, elem ...string) (result string, err error)
• func OSExt() string
• func PrintFlags(l logr.Logger, flags *pflag.FlagSet)
• func RunCommand(cmd *exec.Cmd) error
• func Untar(r io.Reader, dir string) error
• func VerifyExecutableBinary(binaryPath string) (string, error)
• func WaitAPIEnableInClusters(karmadaClient karmadaclientset.Interface, gvk schema.GroupVersionKind, ...) error
• func WaitCRDReady(crdClient crdclientset.Interface, crdName string, ...) error
• func WaitMemberClusterPodReady(client *client.Client, cluster, namespace, selector string, ...) error
• func WaitNamespaceDelete(client kubeclient.Interface, namespace string, interval, timeout time.Duration) error
• func WaitPodReady(client kubeclient.Interface, namespace, selector string, ...) error
• func WaitServiceReady(client kubeclient.Interface, namespace, name string, ...) (*v1.Service, error)

Functions

func AppendResourceSelector

func AppendResourceSelector(cpp *policyv1alpha1.ClusterPropagationPolicy,
	pp *policyv1alpha1.PropagationPolicy,
	resourceList kube.ResourceList)

func ApplyPropagationPolicy

func ApplyPropagationPolicy(c *client.Client, clusters []string, obj runtime.Object) error

func CreateBearerTokenKubeconfig

func CreateBearerTokenKubeconfig(caData, token []byte, clusterName, server string) *api.Config

func DownloadResource

func DownloadResource(url, path string) (raw string, err error)

DownloadResource retrieves resources from remote url. If path is provided, it will also write it to the dir. If the resource is a tar file, it will first untar it.

func IsClustersReady

func IsClustersReady(karmada karmadaclientset.Interface, clusterNames ...string) error

func JoinUrlPath

func JoinUrlPath(base string, elem ...string) (result string, err error)

JoinUrlPath returns a URL string with the provided path elements joined to the existing path of base and the resulting path cleaned of any ./ or ../ elements.

func OSExt

func OSExt() string

func PrintFlags

func PrintFlags(l logr.Logger, flags *pflag.FlagSet)

func RunCommand

func RunCommand(cmd *exec.Cmd) error

RunCommand executes the given cmd, and streaming the realtime output.

func Untar

func Untar(r io.Reader, dir string) error

Untar reads the gzip-compressed tar file from r and writes it into dir.

func VerifyExecutableBinary

func VerifyExecutableBinary(binaryPath string) (string, error)

func WaitAPIEnableInClusters

func WaitAPIEnableInClusters(karmadaClient karmadaclientset.Interface, gvk schema.GroupVersionKind, clusters []string, interval, timeout time.Duration) error

func WaitCRDReady

func WaitCRDReady(crdClient crdclientset.Interface, crdName string, interval, timeout time.Duration) error

func WaitMemberClusterPodReady

func WaitMemberClusterPodReady(client *client.Client, cluster, namespace, selector string, interval, timeout time.Duration) error

WaitMemberClusterPodReady return until the member cluster's pod is ready or an error occurs. Note: client is the karmada apiserver client, cluster should be a valid member cluster name.

func WaitNamespaceDelete

func WaitNamespaceDelete(client kubeclient.Interface, namespace string, interval, timeout time.Duration) error

WaitNamespaceDelete will wait until namespace is completely deleted

func WaitPodReady

func WaitPodReady(client kubeclient.Interface, namespace, selector string, interval, timeout time.Duration) error

func WaitServiceReady

func WaitServiceReady(client kubeclient.Interface, namespace, name string, interval, timeout time.Duration) (*v1.Service, error)

WaitServiceReady will wait until loadbalancer type service allocated an IP.