helpers

Documentation

Index

• Constants
• func CreateCallbackDisplayOrFail(ctx context.Context, client *lib.Client) *v1.Pod
• func CreateDockerHubSourceOrFail(ctx context.Context, c *eventingtestlib.Client, ...)
• func CreateValidationReceiverOrFail(ctx context.Context, client *lib.Client) *v1.Pod
• func DeleteKServiceOrFail(ctx context.Context, c *eventingtestlib.Client, name, namespace string)
• func DockerHubSourceV1Alpha1(t *testing.T, ctx context.Context, data dockerhub.BuildPayload, ...)
• func GetServiceClient(c *eventingtestlib.Client) *kservicesource.Clientset
• func GetSourceClient(c *eventingtestlib.Client) *dhsource.Clientset
• func GetSourceEndpointOrFail(client *eventingtestlib.Client, source *sourcesv1alpha1.DockerHubSource) string
• func GetSourceOrFail(ctx context.Context, c *eventingtestlib.Client, namespace, name string) *sourcev1alpha1.DockerHubSource
• func MustHasSameServiceName(ctx context.Context, c *eventingtestlib.Client, ...)
• func MustSendWebhook(client *eventingtestlib.Client, targetURL string, data *dockerhub.BuildPayload)

Constants

const (
	Pusher   = "webhook-sender-pod"
	Tag      = "latest"
	RepoName = "e2e/sender"

	ValidationReceivePort = 8080 // same number as knative/eventing/test/lib/resources/ServiceDefaultHTTP()
)

Functions

func CreateCallbackDisplayOrFail

func CreateCallbackDisplayOrFail(ctx context.Context, client *lib.Client) *v1.Pod

CreateCallbackDisplayOrFail creates callback-display pod or fail.

func CreateDockerHubSourceOrFail

func CreateDockerHubSourceOrFail(ctx context.Context, c *eventingtestlib.Client, dockerHubSource *sourcev1alpha1.DockerHubSource)

func CreateValidationReceiverOrFail

func CreateValidationReceiverOrFail(ctx context.Context, client *lib.Client) *v1.Pod

CreateValidationReceiverOrFail creates validation-receiver pod or fail.

func DeleteKServiceOrFail

func DeleteKServiceOrFail(ctx context.Context, c *eventingtestlib.Client, name, namespace string)

func DockerHubSourceV1Alpha1

func DockerHubSourceV1Alpha1(t *testing.T, ctx context.Context, data dockerhub.BuildPayload, disableAutoCallback bool, matcherGen func(namespace string) cetestv2.EventMatcher)

func GetServiceClient

func GetServiceClient(c *eventingtestlib.Client) *kservicesource.Clientset

func GetSourceClient

func GetSourceClient(c *eventingtestlib.Client) *dhsource.Clientset

func GetSourceEndpointOrFail

func GetSourceEndpointOrFail(client *eventingtestlib.Client, source *sourcesv1alpha1.DockerHubSource) string

GetSourceEndpointOrFail gets source's endpoint or fail.

func GetSourceOrFail

func GetSourceOrFail(ctx context.Context, c *eventingtestlib.Client, namespace, name string) *sourcev1alpha1.DockerHubSource

func MustHasSameServiceName

func MustHasSameServiceName(ctx context.Context, c *eventingtestlib.Client, dockerHubSource *sourcesv1alpha1.DockerHubSource)

MustHasSameServiceName ensures the source keeps same ReceiveAdapterServiceName even if ksvc gets accidentally deleted.

func MustSendWebhook

func MustSendWebhook(client *eventingtestlib.Client, targetURL string, data *dockerhub.BuildPayload)

MustSendWebhook sends data to the given targetURL.