helper

Documentation

Index

• Variables
• func EnsureAdmissionWebhook(t *testing.T, client versioned.Interface, name string, ...) (current *autoscalingv1.ClusterResourceOverride, changed bool)
• func GetClusterResourceOverride(t *testing.T, client versioned.Interface, name string) *autoscalingv1.ClusterResourceOverride
• func GetCondition(override *autoscalingv1.ClusterResourceOverride, ...) *autoscalingv1.ClusterResourceOverrideCondition
• func GetConfigMap(t *testing.T, client kubernetes.Interface, namespace, name string) (cm *corev1.ConfigMap)
• func GetContainer(t *testing.T, name string, spec *corev1.PodSpec) corev1.ResourceRequirements
• func GetDeployment(t *testing.T, client kubernetes.Interface, namespace, name string) *appsv1.Deployment
• func IsAvailable(override *autoscalingv1.ClusterResourceOverride) bool
• func IsMatch(t *testing.T, requirementsWant, requirementsGot corev1.ResourceRequirements)
• func MustMatchMemoryAndCPU(t *testing.T, resourceWant map[string]corev1.ResourceRequirements, ...)
• func RemoveAdmissionWebhook(t *testing.T, client versioned.Interface, name string)
• func Wait(t *testing.T, client versioned.Interface, name string, f ConditionFunc) (override *autoscalingv1.ClusterResourceOverride)
• func WaitForConfigMap(t *testing.T, client kubernetes.Interface, namespace, name string, ...) (cm *corev1.ConfigMap)
• type Client
  • func NewClient(t *testing.T, config *rest.Config) *Client
• type ConditionFunc
  • func GetAvailableConditionFunc(original *autoscalingv1.ClusterResourceOverride, expectNewResourceVersion bool) ConditionFunc
• type Disposer
  • func NewLimitRanges(t *testing.T, client kubernetes.Interface, namespace string, ...) (object *corev1.LimitRange, disposer Disposer)
  • func NewNamespace(t *testing.T, client kubernetes.Interface, name string, optIn bool) (ns *corev1.Namespace, disposer Disposer)
  • func NewPod(t *testing.T, client kubernetes.Interface, namespace string, ...) (pod *corev1.Pod, disposer Disposer)
  • func NewPodWithResourceRequirement(t *testing.T, client kubernetes.Interface, namespace string, ...) (pod *corev1.Pod, disposer Disposer)
  • func (d Disposer) Dispose()
• type PreCondition
  • func (f *PreCondition) MustHaveAdmissionRegistrationV1(t *testing.T)
  • func (f *PreCondition) MustHaveClusterResourceOverrideAdmissionConfiguration(t *testing.T)

Variables

var (
	WaitInterval time.Duration = 1 * time.Second
	WaitTimeout  time.Duration = 5 * time.Minute
)

Functions

func EnsureAdmissionWebhook

func EnsureAdmissionWebhook(t *testing.T, client versioned.Interface, name string, override autoscalingv1.PodResourceOverride, deploymentOverrides *autoscalingv1.DeploymentOverrides) (current *autoscalingv1.ClusterResourceOverride, changed bool)

func GetClusterResourceOverride

func GetClusterResourceOverride(t *testing.T, client versioned.Interface, name string) *autoscalingv1.ClusterResourceOverride

func GetCondition

func GetCondition(override *autoscalingv1.ClusterResourceOverride, condType autoscalingv1.ClusterResourceOverrideConditionType) *autoscalingv1.ClusterResourceOverrideCondition

func GetConfigMap

func GetConfigMap(t *testing.T, client kubernetes.Interface, namespace, name string) (cm *corev1.ConfigMap)

func GetContainer

func GetContainer(t *testing.T, name string, spec *corev1.PodSpec) corev1.ResourceRequirements

func GetDeployment

func GetDeployment(t *testing.T, client kubernetes.Interface, namespace, name string) *appsv1.Deployment

func IsAvailable

func IsAvailable(override *autoscalingv1.ClusterResourceOverride) bool

func IsMatch

func IsMatch(t *testing.T, requirementsWant, requirementsGot corev1.ResourceRequirements)

func MustMatchMemoryAndCPU

func MustMatchMemoryAndCPU(t *testing.T, resourceWant map[string]corev1.ResourceRequirements, specGot *corev1.PodSpec)

func RemoveAdmissionWebhook

func RemoveAdmissionWebhook(t *testing.T, client versioned.Interface, name string)

func Wait

func Wait(t *testing.T, client versioned.Interface, name string, f ConditionFunc) (override *autoscalingv1.ClusterResourceOverride)

func WaitForConfigMap

func WaitForConfigMap(t *testing.T, client kubernetes.Interface, namespace, name string, original *corev1.ConfigMap) (cm *corev1.ConfigMap)

Types

type Client

type Client struct {
	Operator   versioned.Interface
	Kubernetes kubernetes.Interface
}

func NewClient

func NewClient(t *testing.T, config *rest.Config) *Client

type ConditionFunc

type ConditionFunc func(override *autoscalingv1.ClusterResourceOverride) bool

func GetAvailableConditionFunc

func GetAvailableConditionFunc(original *autoscalingv1.ClusterResourceOverride, expectNewResourceVersion bool) ConditionFunc

type Disposer

type Disposer func()

func NewLimitRanges

func NewLimitRanges(t *testing.T, client kubernetes.Interface, namespace string, spec corev1.LimitRangeSpec) (object *corev1.LimitRange, disposer Disposer)

func NewNamespace

func NewNamespace(t *testing.T, client kubernetes.Interface, name string, optIn bool) (ns *corev1.Namespace, disposer Disposer)

func NewPod

func NewPod(t *testing.T, client kubernetes.Interface, namespace string, spec corev1.PodSpec) (pod *corev1.Pod, disposer Disposer)

func NewPodWithResourceRequirement

func NewPodWithResourceRequirement(t *testing.T, client kubernetes.Interface, namespace string, containerName string, requirements corev1.ResourceRequirements) (pod *corev1.Pod, disposer Disposer)

func (Disposer) Dispose

func (d Disposer) Dispose()

type PreCondition

type PreCondition struct {
	Client kubernetes.Interface
}

func (*PreCondition) MustHaveAdmissionRegistrationV1

func (f *PreCondition) MustHaveAdmissionRegistrationV1(t *testing.T)

func (*PreCondition) MustHaveClusterResourceOverrideAdmissionConfiguration

func (f *PreCondition) MustHaveClusterResourceOverrideAdmissionConfiguration(t *testing.T)