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
Constants ¶
View Source
const ( BatchAPIVersion = "batch/v1" MessagingAPIVersion = "messaging.cloud.google.com/v1alpha1" MessagingV1beta1APIVersion = "messaging.cloud.google.com/v1beta1" 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.
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. // Increase from 40 seconds to 60 seconds, for issue: https://github.com/google/knative-gcp/issues/1568. // WaitDeletionTime for deleting resources WaitDeletionTime = 60 * 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 = 60 * 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 )
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 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 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 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
Types ¶
type BrokerV1Beta1Option ¶ added in v0.16.0
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.
Click to show internal directories.
Click to hide internal directories.