testingdata

Documentation

Overview

Package testingdata creates data plane resources used by tests by reading YAML files. This reduces the cubersome of creating those resources in go code. The YAML files are also easier to read.

Index

• func Config(bc *intv1alpha1.BrokerCell, bco BrokerCellObjects) *corev1.ConfigMap
• func EmptyConfig(t *testing.T, bc *intv1alpha1.BrokerCell) *corev1.ConfigMap
• func FanoutDeployment(t *testing.T) *appsv1.Deployment
• func FanoutDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment
• func FanoutDeploymentWithStatus(t *testing.T) *appsv1.Deployment
• func FanoutHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler
• func IngressDeployment(t *testing.T) *appsv1.Deployment
• func IngressDeploymentWithFilteringAnnotation(t *testing.T) *appsv1.Deployment
• func IngressDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment
• func IngressDeploymentWithStatus(t *testing.T) *appsv1.Deployment
• func IngressHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler
• func IngressService(t *testing.T) *corev1.Service
• func IngressServiceWithStatus(t *testing.T) *corev1.Service
• func RetryDeployment(t *testing.T) *appsv1.Deployment
• func RetryDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment
• func RetryDeploymentWithStatus(t *testing.T) *appsv1.Deployment
• func RetryHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler
• type BrokerCellObjects

Functions

func Config

func Config(bc *intv1alpha1.BrokerCell, bco BrokerCellObjects) *corev1.ConfigMap

func EmptyConfig

func EmptyConfig(t *testing.T, bc *intv1alpha1.BrokerCell) *corev1.ConfigMap

func FanoutDeployment

func FanoutDeployment(t *testing.T) *appsv1.Deployment

func FanoutDeploymentWithRestartAnnotation

func FanoutDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment

func FanoutDeploymentWithStatus

func FanoutDeploymentWithStatus(t *testing.T) *appsv1.Deployment

func FanoutHPA

func FanoutHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler

func IngressDeployment

func IngressDeployment(t *testing.T) *appsv1.Deployment

func IngressDeploymentWithFilteringAnnotation

func IngressDeploymentWithFilteringAnnotation(t *testing.T) *appsv1.Deployment

TODO(1804): remove this function when ingress filtering is enabled by default.

func IngressDeploymentWithRestartAnnotation

func IngressDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment

func IngressDeploymentWithStatus

func IngressDeploymentWithStatus(t *testing.T) *appsv1.Deployment

func IngressHPA

func IngressHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler

func IngressService

func IngressService(t *testing.T) *corev1.Service

func IngressServiceWithStatus

func IngressServiceWithStatus(t *testing.T) *corev1.Service

func RetryDeployment

func RetryDeployment(t *testing.T) *appsv1.Deployment

func RetryDeploymentWithRestartAnnotation

func RetryDeploymentWithRestartAnnotation(t *testing.T) *appsv1.Deployment

func RetryDeploymentWithStatus

func RetryDeploymentWithStatus(t *testing.T) *appsv1.Deployment

func RetryHPA

func RetryHPA(t *testing.T) *hpav2beta2.HorizontalPodAutoscaler

Types

type BrokerCellObjects

type BrokerCellObjects struct {
	BrokersToTriggers map[*brokerv1.Broker][]*brokerv1.Trigger
	Channels          []*v1beta1.Channel
}