resources

package
v0.16.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
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.

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

Kind for events resources.

View Source
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
)
View Source
const (
	ChannelKind string = "Channel"
)

Kind for messaging resources.

View Source
const (
	JobKind string = "Job"
)

Kind for batch resources.

View Source
const (
	KServiceKind string = "Service"
)

Kind for Knative resources.

View Source
const (
	PullSubscriptionKind string = "PullSubscription"
)

Kind for pubsub resources.

Variables

This section is empty.

Functions

func AuditLogsTargetJob

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

func BrokerV1Beta1 added in v0.16.0

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

Broker returns a Broker.

func BuildTargetJob added in v0.16.0

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

func FirstNErrsReceiverKService added in v0.16.0

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 added in v0.15.0

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 added in v0.15.0

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 added in v0.16.0

type BrokerV1Beta1Option func(*v1beta1.Broker)

BrokerV1Beta1Option enables further configuration of a Broker.

func WithBrokerClassForBrokerV1Beta1 added in v0.16.0

func WithBrokerClassForBrokerV1Beta1(brokerClass string) BrokerV1Beta1Option

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL