resources

Documentation

Index

• Constants
• func AuditLogsTargetJob(name string, envVars []corev1.EnvVar) *batchv1.Job
• func BrokerV1Beta1(name string, options ...BrokerV1Beta1Option) *v1beta1.Broker
• 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
• type BrokerV1Beta1Option
  • func WithBrokerClassForBrokerV1Beta1(brokerClass string) BrokerV1Beta1Option

Constants

const (
	BatchAPIVersion            = "batch/v1"
	MessagingAPIVersion        = "messaging.cloud.google.com/v1alpha1"
	MessagingV1beta1APIVersion = "messaging.cloud.google.com/v1beta1"
	EventsAPIVersion           = "events.cloud.google.com/v1alpha1"
	IntEventsAPIVersion        = "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.
	// WaitDeletionTime for deleting resources
	WaitDeletionTime = 40 * 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.
	WaitCALTime = 120 * 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 BrokerV1Beta1

func BrokerV1Beta1(name string, options ...BrokerV1Beta1Option) *v1beta1.Broker

Broker returns a Broker.

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

Types

type BrokerV1Beta1Option

type BrokerV1Beta1Option func(*v1beta1.Broker)

BrokerV1Beta1Option enables further configuration of a Broker.

func WithBrokerClassForBrokerV1Beta1

func WithBrokerClassForBrokerV1Beta1(brokerClass string) BrokerV1Beta1Option

WithBrokerClassForBrokerV1Beta1 returns a function that adds a brokerClass annotation to the given Broker.