utils

Documentation

Index

• func CurrentPodsNumInTargetNodeGroups(ctx context.Context, client runtimeClient.Client, deploy *appsv1.Deployment, ...) (map[string]int32, map[string]string, error)
• func DesiredPodsNumInTargetNodeGroups(weights []policyv1alpha1.StaticNodeGroupWeight, replicaNum int32) map[string]int32
• func GetManifestsDeploys(ctx context.Context, client runtimeClient.Client, ...) ([]*appsv1.Deployment, error)
• func GetNodeGroupsWithName(ctx context.Context, client runtimeClient.Client, nodeGroupName []string) ([]groupv1alpha1.NodeGroup, error)
• func GetNodesInGroups(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 GetRelativeDeployAndPolicy(ctx context.Context, client runtimeClient.Client, pod *corev1.Pod) (*appsv1.Deployment, *policyv1alpha1.PropagationPolicy, 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 CurrentPodsNumInTargetNodeGroups

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

func DesiredPodsNumInTargetNodeGroups

func DesiredPodsNumInTargetNodeGroups(weights []policyv1alpha1.StaticNodeGroupWeight, replicaNum int32) map[string]int32

func GetManifestsDeploys

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

func GetNodeGroupsWithName

func GetNodeGroupsWithName(ctx context.Context, client runtimeClient.Client, nodeGroupName []string) ([]groupv1alpha1.NodeGroup, error)

func GetNodesInGroups

func GetNodesInGroups(ctx context.Context, client runtimeClient.Client, groups []groupv1alpha1.NodeGroup) (map[string]string, error)

func GetPodListFromDeploy

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

func GetRelativeDeployAndPolicy

func GetRelativeDeployAndPolicy(ctx context.Context, client runtimeClient.Client, pod *corev1.Pod) (*appsv1.Deployment, *policyv1alpha1.PropagationPolicy, 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