resources

Documentation

Index

• Constants
• func AuditLogsTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func BuildTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func FirstNErrsReceiverKService(name, namespace, imageName string, firstN int) *unstructured.Unstructured
• func PubSubTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func ReceiverKService(name, namespace, imageName string) *unstructured.Unstructured
• func SchedulerTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func SenderJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func StorageTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func TargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func WithDependencyAnnotationTriggerV1(dependencyAnnotation string) eventingresources.TriggerOptionV1

Constants

const (
	BatchAPIVersion             = "batch/v1"
	MessagingV1beta1APIVersion  = "messaging.cloud.google.com/v1beta1"
	EventingV1APIVersion        = "eventing.knative.dev/v1"
	EventsV1APIVersion          = "events.cloud.google.com/v1"
	EventsV1beta1APIVersion     = "events.cloud.google.com/v1beta1"
	EventsV1alpha1APIVersion    = "events.cloud.google.com/v1alpha1"
	IntEventsV1APIVersion       = "internal.events.cloud.google.com/v1"
	IntEventsV1beta1APIVersion  = "internal.events.cloud.google.com/v1beta1"
	IntEventsV1alpha1APIVersion = "internal.events.cloud.google.com/v1alpha1"
	ServingAPIVersion           = "serving.knative.dev/v1"
)

API versions for the resources.

const (
	CloudStorageSourceKind   string = "CloudStorageSource"
	CloudPubSubSourceKind    string = "CloudPubSubSource"
	CloudBuildSourceKind     string = "CloudBuildSource"
	CloudAuditLogsSourceKind string = "CloudAuditLogsSource"
	CloudSchedulerSourceKind string = "CloudSchedulerSource"
)

Kind for events resources.

const (
	// Tried with 20 seconds but the test has been quite flaky.
	// Increase from 40 seconds to 120 seconds, for issue: https://github.com/google/knative-gcp/issues/1568.
	// WaitDeletionTime for deleting resources
	WaitDeletionTime = 120 * time.Second
	// WaitCALTime for time needed to wait to fire an event after CAL Source is ready
	// Tried with 45 seconds but the test has been quite flaky.
	// Tried with 90 seconds but the test has been quite flaky.
	// Tried with 120 seconds but the test still has some flakiness.
	WaitCALTime = 150 * time.Second
	// WaitExtraSourceReadyTime for additional time needed to wait for a source becomes ready.
	WaitExtraSourceReadyTime = 90 * time.Second
	// As initially suspected in https://github.com/google/knative-gcp/issues/1437,
	// sometimes brokercell seems to take much longer than expected to reconcile
	// the broker config. Plus, the configmap propagation probably also takes a
	// little bit time.
	WaitBrokercellTime = 40 * time.Second
)

const (
	ChannelKind string = "Channel"
)

Kind for messaging resources.

const (
	JobKind string = "Job"
)

Kind for batch resources.

const (
	KServiceKind string = "Service"
)

Kind for Knative resources.

const (
	PullSubscriptionKind string = "PullSubscription"
)

Kind for pubsub resources.

Functions

func AuditLogsTargetJob

func AuditLogsTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func BuildTargetJob

func BuildTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func FirstNErrsReceiverKService

func FirstNErrsReceiverKService(name, namespace, imageName string, firstN int) *unstructured.Unstructured

FirstNErrsReceiverKService creates a Knative Service as an event receiver with its first N responses being errors.

func PubSubTargetJob

func PubSubTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func ReceiverKService

func ReceiverKService(name, namespace, imageName string) *unstructured.Unstructured

ReceiverKService creates a Knative Service as an event receiver.

func SchedulerTargetJob

func SchedulerTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func SenderJob

func SenderJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func StorageTargetJob

func StorageTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func TargetJob

func TargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job

func WithDependencyAnnotationTriggerV1

func WithDependencyAnnotationTriggerV1(dependencyAnnotation string) eventingresources.TriggerOptionV1

WithDependencyAnnotationTriggerV1 returns an option that adds a dependency annotation to the given V1 Trigger. This option is missing from eventing v1 test resources, so we must patch it in ourselves.