helper

Documentation

Index

• Constants
• func IsScheduleResultEqual(tc1, tc2 []workv1alpha2.TargetCluster) bool
• func MakeNodeWithLabels(node string, milliCPU, memory, pods, ephemeralStorage int64, ...) *corev1.Node
• func MakeNodeWithTaints(node string, milliCPU, memory, pods, ephemeralStorage int64, ...) *corev1.Node
• func NewCluster(name string) *clusterv1alpha1.Cluster
• func NewClusterPropagationPolicy(policyName string, rsSelectors []policyv1alpha1.ResourceSelector, ...) *policyv1alpha1.ClusterPropagationPolicy
• func NewClusterWithResource(name string, allocatable, allocating, allocated corev1.ResourceList) *clusterv1alpha1.Cluster
• func NewCustomResource(apiVersion, kind, namespace, name string) *unstructured.Unstructured
• func NewCustomResourceDefinition(group string, specNames apiextensionsv1.CustomResourceDefinitionNames, ...) *apiextensionsv1.CustomResourceDefinition
• func NewDeployment(namespace string, name string) *appsv1.Deployment
• func NewJob(namespace string, name string) *batchv1.Job
• func NewNamespace(namespace string) *corev1.Namespace
• func NewNode(node string, milliCPU, memory, pods, ephemeralStorage int64) *corev1.Node
• func NewOverridePolicy(namespace, policyName string, rsSelectors []policyv1alpha1.ResourceSelector, ...) *policyv1alpha1.OverridePolicy
• func NewOverridePolicyByOverrideRules(namespace, policyName string, rsSelectors []policyv1alpha1.ResourceSelector, ...) *policyv1alpha1.OverridePolicy
• func NewPod(namespace string, name string) *corev1.Pod
• func NewPodWithRequest(pod, node string, milliCPU, memory, ephemeralStorage int64) *corev1.Pod
• func NewPropagationPolicy(ns, name string, rsSelectors []policyv1alpha1.ResourceSelector, ...) *policyv1alpha1.PropagationPolicy
• func NewResourceList(milliCPU, memory, ephemeralStorage int64) corev1.ResourceList
• func NewService(namespace string, name string) *corev1.Service
• func NewWorkload(namespace string, name string) *worklodv1alpha1.Workload

Constants

const (
	ResourceUnitZero             int64 = 0
	ResourceUnitCPU              int64 = 1000
	ResourceUnitMem              int64 = 1024 * 1024 * 1024
	ResourceUnitPod              int64 = 1
	ResourceUnitEphemeralStorage int64 = 1024 * 1024 * 1024
	ResourceUnitGPU              int64 = 1
)

These are different resource units.

Functions

func IsScheduleResultEqual

func IsScheduleResultEqual(tc1, tc2 []workv1alpha2.TargetCluster) bool

IsScheduleResultEqual will check whether two schedule results are equal.

func MakeNodeWithLabels

func MakeNodeWithLabels(node string, milliCPU, memory, pods, ephemeralStorage int64, labels map[string]string) *corev1.Node

MakeNodeWithLabels will build a ready node with resource and labels.

func MakeNodeWithTaints

func MakeNodeWithTaints(node string, milliCPU, memory, pods, ephemeralStorage int64, taints []corev1.Taint) *corev1.Node

MakeNodeWithTaints will build a ready node with resource and taints.

func NewCluster

func NewCluster(name string) *clusterv1alpha1.Cluster

NewCluster will build a Cluster.

func NewClusterPropagationPolicy

func NewClusterPropagationPolicy(policyName string, rsSelectors []policyv1alpha1.ResourceSelector, placement policyv1alpha1.Placement) *policyv1alpha1.ClusterPropagationPolicy

NewClusterPropagationPolicy will build a ClusterPropagationPolicy object.

func NewClusterWithResource

func NewClusterWithResource(name string, allocatable, allocating, allocated corev1.ResourceList) *clusterv1alpha1.Cluster

NewClusterWithResource will build a Cluster with resource.

func NewCustomResource

func NewCustomResource(apiVersion, kind, namespace, name string) *unstructured.Unstructured

NewCustomResource will build a CR object with CRD Foo.

func NewCustomResourceDefinition

func NewCustomResourceDefinition(group string, specNames apiextensionsv1.CustomResourceDefinitionNames, scope apiextensionsv1.ResourceScope) *apiextensionsv1.CustomResourceDefinition

NewCustomResourceDefinition will build a CRD object.

func NewDeployment

func NewDeployment(namespace string, name string) *appsv1.Deployment

NewDeployment will build a deployment object.

func NewJob

func NewJob(namespace string, name string) *batchv1.Job

NewJob will build a job object.

func NewNamespace

func NewNamespace(namespace string) *corev1.Namespace

NewNamespace will build a Namespace object.

func NewNode

func NewNode(node string, milliCPU, memory, pods, ephemeralStorage int64) *corev1.Node

NewNode will build a ready node with resource.

func NewOverridePolicy

func NewOverridePolicy(namespace, policyName string, rsSelectors []policyv1alpha1.ResourceSelector, clusterAffinity policyv1alpha1.ClusterAffinity, overriders policyv1alpha1.Overriders) *policyv1alpha1.OverridePolicy

NewOverridePolicy will build a OverridePolicy object.

func NewOverridePolicyByOverrideRules

func NewOverridePolicyByOverrideRules(namespace, policyName string, rsSelectors []policyv1alpha1.ResourceSelector, overrideRules []policyv1alpha1.RuleWithCluster) *policyv1alpha1.OverridePolicy

NewOverridePolicyByOverrideRules will build a OverridePolicy object by OverrideRules

func NewPod

func NewPod(namespace string, name string) *corev1.Pod

NewPod will build a service object.

func NewPodWithRequest

func NewPodWithRequest(pod, node string, milliCPU, memory, ephemeralStorage int64) *corev1.Pod

NewPodWithRequest will build a Pod with resource request.

func NewPropagationPolicy

func NewPropagationPolicy(ns, name string, rsSelectors []policyv1alpha1.ResourceSelector, placement policyv1alpha1.Placement) *policyv1alpha1.PropagationPolicy

NewPropagationPolicy will build a PropagationPolicy object.

func NewResourceList

func NewResourceList(milliCPU, memory, ephemeralStorage int64) corev1.ResourceList

NewResourceList will build a ResourceList.

func NewService

func NewService(namespace string, name string) *corev1.Service

NewService will build a service object.

func NewWorkload

func NewWorkload(namespace string, name string) *worklodv1alpha1.Workload

NewWorkload will build a workload object.