utils

Documentation

Index

• func CurrentPodsNumInTargetClusters(ctx context.Context, client runtimeClient.Client, deploy *appsv1.Deployment, ...) (map[string]int, map[string]string, error)
• func DesiredPodsNumInTargetClusters(weights []policyv1alpha1.StaticClusterWeight, replicaNum int32) map[string]int
• func GetClustersWithName(ctx context.Context, client runtimeClient.Client, clusterName []string) ([]clusterv1alpha1.Cluster, error)
• func GetManifestsDeploys(ctx context.Context, client runtimeClient.Client, ...) ([]*appsv1.Deployment, error)
• func GetNodesInClusters(ctx context.Context, client runtimeClient.Client, ...) (map[string]string, error)
• func GetPodListFromDeploy(ctx context.Context, client runtimeClient.Client, deploy *appsv1.Deployment) (*corev1.PodList, error)
• func GetRelativeDeployment(ctx context.Context, client runtimeClient.Client, pod *corev1.Pod, ...) (*appsv1.Deployment, error)
• func ParseNamespaceName(namespaceName string) (string, string, error)
• func WithCheck(handler http.Handler) http.Handler

Functions

func CurrentPodsNumInTargetClusters

func CurrentPodsNumInTargetClusters(ctx context.Context, client runtimeClient.Client, deploy *appsv1.Deployment, policy *policyv1alpha1.PropagationPolicy) (map[string]int, map[string]string, error)

func DesiredPodsNumInTargetClusters

func DesiredPodsNumInTargetClusters(weights []policyv1alpha1.StaticClusterWeight, replicaNum int32) map[string]int

func GetClustersWithName

func GetClustersWithName(ctx context.Context, client runtimeClient.Client, clusterName []string) ([]clusterv1alpha1.Cluster, error)

func GetManifestsDeploys

func GetManifestsDeploys(ctx context.Context, client runtimeClient.Client, policy *policyv1alpha1.PropagationPolicy) ([]*appsv1.Deployment, error)

func GetNodesInClusters

func GetNodesInClusters(ctx context.Context, client runtimeClient.Client, clusters []clusterv1alpha1.Cluster) (map[string]string, error)

func GetPodListFromDeploy

func GetPodListFromDeploy(ctx context.Context, client runtimeClient.Client, deploy *appsv1.Deployment) (*corev1.PodList, error)

func GetRelativeDeployment

func GetRelativeDeployment(ctx context.Context, client runtimeClient.Client, pod *corev1.Pod, policy *policyv1alpha1.PropagationPolicy) (*appsv1.Deployment, error)

func ParseNamespaceName

func ParseNamespaceName(namespaceName string) (string, string, error)

func WithCheck

func WithCheck(handler http.Handler) http.Handler