resources

Documentation

Index

• Constants
• func AuditLogsTargetJob(name string, envVars []v1.EnvVar) *batchv1.Job
• func ReceiverKService(name, namespace string) *unstructured.Unstructured
• func SchedulerJob(name string, envVars []v1.EnvVar) *batchv1.Job
• func SenderJob(name string, envVars []v1.EnvVar) *batchv1.Job
• func StorageTargetJob(name string, envVars []v1.EnvVar) *batchv1.Job
• func TargetJob(name string, envVars []v1.EnvVar) *batchv1.Job

Constants

const (
	BatchAPIVersion     = "batch/v1"
	MessagingAPIVersion = "messaging.cloud.google.com/v1alpha1"
	EventsAPIVersion    = "events.cloud.google.com/v1alpha1"
	PubSubAPIVersion    = "pubsub.cloud.google.com/v1alpha1"
	ServingAPIVersion   = "serving.knative.dev/v1"
)

API versions for the resources.

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

Kind for events resources.

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 []v1.EnvVar) *batchv1.Job

func ReceiverKService

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

ReceiverKService creates a Knative Service as an event receiver.

func SchedulerJob

func SchedulerJob(name string, envVars []v1.EnvVar) *batchv1.Job

func SenderJob

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

func StorageTargetJob

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

func TargetJob

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