v1

package
v0.18.3 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2021 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	SubscriptionID = "subID"
)

Variables

This section is empty.

Functions

func NewCloudAuditLogsSource 

func NewCloudAuditLogsSource(name, namespace string, opts ...CloudAuditLogsSourceOption) *v1.CloudAuditLogsSource

func NewCloudBuildSource added in v0.18.0 

func NewCloudBuildSource(name, namespace string, so ...CloudBuildSourceOption) *v1.CloudBuildSource

NewCloudBuildSource creates a CloudBuildSource with CloudBuildSourceOptions

func NewCloudPubSubSource 

func NewCloudPubSubSource(name, namespace string, so ...CloudPubSubSourceOption) *v1.CloudPubSubSource

NewCloudPubSubSource creates a CloudPubSubSource with CloudPubSubSourceOptions

func NewCloudSchedulerSource 

func NewCloudSchedulerSource(name, namespace string, so ...CloudSchedulerSourceOption) *v1.CloudSchedulerSource

NewCloudSchedulerSource creates a CloudSchedulerSource with CloudSchedulerSourceOptions

func NewCloudStorageSource 

func NewCloudStorageSource(name, namespace string, so ...CloudStorageSourceOption) *v1.CloudStorageSource

NewCloudStorageSource creates a CloudStorageSource with CloudStorageSourceOptions

func NewPullSubscription 

func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1.PullSubscription

NewPullSubscription creates a PullSubscription with PullSubscriptionOptions

func NewPullSubscriptionWithoutNamespace 

func NewPullSubscriptionWithoutNamespace(name string, so ...PullSubscriptionOption) *v1.PullSubscription

NewPullSubscriptionWithoutNamespace creates a PullSubscription with PullSubscriptionOptions but without a specific namespace

func NewTopic 

func NewTopic(name, namespace string, to ...TopicOption) *v1.Topic

NewTopic creates a Topic with TopicOptions

func WithCloudAuditLogsSourceDeletionTimestamp 

func WithCloudAuditLogsSourceDeletionTimestamp(s *v1.CloudAuditLogsSource)

func WithCloudAuditLogsSourcePullSubscriptionDeleted 

func WithCloudAuditLogsSourcePullSubscriptionDeleted(s *v1.CloudAuditLogsSource)

WithCloudAuditLogsSourcePullSubscriptionDeleted is a wrapper to indicate that the PullSubscription is deleted. Inside the function, we still mark the status of PullSubscription to be ready, as the status of PullSubscription is unchanged if the deletion is successful.

func WithCloudAuditLogsSourcePullSubscriptionReady 

func WithCloudAuditLogsSourcePullSubscriptionReady(s *v1.CloudAuditLogsSource)

WithCloudAuditLogsSourcePullSubscriptionReady marks the condition that the PullSubscription is Ready.

func WithCloudAuditLogsSourceSetDefaults 

func WithCloudAuditLogsSourceSetDefaults(s *v1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceSinkDeleted 

func WithCloudAuditLogsSourceSinkDeleted(s *v1.CloudAuditLogsSource)

WithCloudAuditLogsSourceSinkDeleted is a wrapper to indicate that the sink is deleted. Inside the function, we still mark the status of sink to be ready, as the status of sink is unchanged if the deletion is successful.

func WithCloudAuditLogsSourceSinkReady 

func WithCloudAuditLogsSourceSinkReady(s *v1.CloudAuditLogsSource)

WithCloudAuditLogsSourceSinkReady marks the condition that the sink is ready.

func WithCloudAuditLogsSourceTopicDeleted 

func WithCloudAuditLogsSourceTopicDeleted(s *v1.CloudAuditLogsSource)

WithCloudAuditLogsSourceTopicDeleted is a wrapper to indicate that the topic is deleted. Inside the function, we still mark the status of topic to be ready, as the status of topic is unchanged if the deletion is successful. We do not set the topicID because the topicID is set to empty when deleting the topic.

func WithCloudBuildSourceDeletionTimestamp added in v0.18.0 

func WithCloudBuildSourceDeletionTimestamp(bs *v1.CloudBuildSource)

func WithCloudBuildSourceSetDefault added in v0.18.0 

func WithCloudBuildSourceSetDefault(bs *v1.CloudBuildSource)

func WithCloudPubSubSourceDeletionTimestamp 

func WithCloudPubSubSourceDeletionTimestamp(s *v1.CloudPubSubSource)

func WithCloudPubSubSourcePullSubscriptionReady 

func WithCloudPubSubSourcePullSubscriptionReady(ps *v1.CloudPubSubSource)

WithCloudPubSubSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudPubSubSourceSetDefaults 

func WithCloudPubSubSourceSetDefaults(ps *v1.CloudPubSubSource)

func WithCloudSchedulerSourceDeletionTimestamp 

func WithCloudSchedulerSourceDeletionTimestamp(s *v1.CloudSchedulerSource)

func WithCloudSchedulerSourcePullSubscriptionDeleted 

func WithCloudSchedulerSourcePullSubscriptionDeleted(s *v1.CloudSchedulerSource)

WithCloudSchedulerSourcePullSubscriptionDeleted is a wrapper to indicate that the PullSubscription is deleted. Inside the function, we still mark the status of PullSubscription to be ready, as the status of PullSubscription is unchanged if the deletion is successful.

func WithCloudSchedulerSourcePullSubscriptionReady 

func WithCloudSchedulerSourcePullSubscriptionReady(s *v1.CloudSchedulerSource)

WithCloudSchedulerSourcePullSubscriptionReady marks the condition that the topic is ready.

func WithCloudSchedulerSourceSetDefaults 

func WithCloudSchedulerSourceSetDefaults(s *v1.CloudSchedulerSource)

func WithCloudSchedulerSourceTopicDeleted 

func WithCloudSchedulerSourceTopicDeleted(s *v1.CloudSchedulerSource)

WithCloudAuditLogsSourceTopicDeleted is a wrapper to indicate that the topic is deleted. Inside the function, we still mark the status of topic to be ready, as the status of topic is unchanged if the deletion is successful. We do not set the topicID and projectID because they are set to empty when deleting the topic.

func WithCloudStorageSourcePullSubscriptionDeleted 

func WithCloudStorageSourcePullSubscriptionDeleted(s *v1.CloudStorageSource)

WithCloudStorageSourcePullSubscriptionDeleted a wrapper to indicate that the pullSubscription is deleted. Inside the function, we still mark the status of pullSubscription to be ready, as the status of pullSubscription is unchanged if the deletion is successful.

func WithCloudStorageSourcePullSubscriptionReady 

func WithCloudStorageSourcePullSubscriptionReady(s *v1.CloudStorageSource)

WithCloudStorageSourcePullSubscriptionReady marks the condition that the pullSubscription is ready.

func WithCloudStorageSourceSetDefaults 

func WithCloudStorageSourceSetDefaults(s *v1.CloudStorageSource)

func WithCloudStorageSourceTopicDeleted 

func WithCloudStorageSourceTopicDeleted(s *v1.CloudStorageSource)

WithCloudStorageSourceTopicDeleted is a wrapper to indicate that the topic is deleted. Inside the function, we still mark the status of topic to be ready, as the status of topic is unchanged if the deletion is successful. We do not set the topicID because the topicID is set to empty when deleting the topic.

func WithDeletionTimestamp 

func WithDeletionTimestamp(s *v1.CloudStorageSource)

func WithInitCloudAuditLogsSourceConditions 

func WithInitCloudAuditLogsSourceConditions(s *v1.CloudAuditLogsSource)

WithInitCloudAuditLogsSourceConditions initializes the CloudAuditLogsSource's conditions.

func WithInitCloudBuildSourceConditions added in v0.18.0 

func WithInitCloudBuildSourceConditions(bs *v1.CloudBuildSource)

WithInitCloudBuildSourceConditions initializes the CloudBuildSource's conditions.

func WithInitCloudPubSubSourceConditions 

func WithInitCloudPubSubSourceConditions(ps *v1.CloudPubSubSource)

WithInitCloudPubSubSourceConditions initializes the CloudPubSubSource's conditions.

func WithInitCloudSchedulerSourceConditions 

func WithInitCloudSchedulerSourceConditions(s *v1.CloudSchedulerSource)

WithInitCloudSchedulerSourceConditions initializes the CloudSchedulerSources's conditions.

func WithInitCloudStorageSourceConditions 

func WithInitCloudStorageSourceConditions(s *v1.CloudStorageSource)

WithInitCloudStorageSourceConditions initializes the CloudStorageSources's conditions.

func WithInitPullSubscriptionConditions 

func WithInitPullSubscriptionConditions(s *v1.PullSubscription)

WithInitPullSubscriptionConditions initializes the PullSubscriptions's conditions.

func WithInitTopicConditions 

func WithInitTopicConditions(t *v1.Topic)

WithInitTopicConditions initializes the Topics's conditions.

func WithPullSubscriptionDefaultGCPAuth 

func WithPullSubscriptionDefaultGCPAuth(s *v1.PullSubscription)

func WithPullSubscriptionDeleted 

func WithPullSubscriptionDeleted(s *v1.PullSubscription)

func WithPullSubscriptionSetDefaults 

func WithPullSubscriptionSetDefaults(s *v1.PullSubscription)

func WithTopicDeleted 

func WithTopicDeleted(t *v1.Topic)

func WithTopicFailed 

func WithTopicFailed(t *v1.Topic)

func WithTopicPublisherDeployed 

func WithTopicPublisherDeployed(t *v1.Topic)

func WithTopicPublisherNotConfigured 

func WithTopicPublisherNotConfigured(t *v1.Topic)

func WithTopicSetDefaults 

func WithTopicSetDefaults(t *v1.Topic)

func WithTopicUnknown 

func WithTopicUnknown(t *v1.Topic)

Types

type CloudAuditLogsSourceOption 

type CloudAuditLogsSourceOption func(*v1.CloudAuditLogsSource)

func WithCloudAuditLogsSourceAnnotations 

func WithCloudAuditLogsSourceAnnotations(Annotations map[string]string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceFinalizers 

func WithCloudAuditLogsSourceFinalizers(finalizers ...string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceMethodName 

func WithCloudAuditLogsSourceMethodName(methodName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProject 

func WithCloudAuditLogsSourceProject(project string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceProjectID 

func WithCloudAuditLogsSourceProjectID(projectID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourcePullSubscriptionFailed 

func WithCloudAuditLogsSourcePullSubscriptionFailed(reason, message string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourcePullSubscriptionFailed marks the condition that the PullSubscription is False.

func WithCloudAuditLogsSourcePullSubscriptionUnknown 

func WithCloudAuditLogsSourcePullSubscriptionUnknown(reason, message string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourcePullSubscriptionUnknown marks the condition that the PullSubscription is Unknown.

func WithCloudAuditLogsSourceResourceName 

func WithCloudAuditLogsSourceResourceName(resourceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceServiceAccount 

func WithCloudAuditLogsSourceServiceAccount(kServiceAccount string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceServiceName 

func WithCloudAuditLogsSourceServiceName(serviceName string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSink 

func WithCloudAuditLogsSourceSink(gvk metav1.GroupVersionKind, name string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkID 

func WithCloudAuditLogsSourceSinkID(sinkID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkNotReady 

func WithCloudAuditLogsSourceSinkNotReady(reason, messageFmt string, messageA ...interface{}) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceSinkNotReady marks the condition that the sink is False.

func WithCloudAuditLogsSourceSinkURI 

func WithCloudAuditLogsSourceSinkURI(url *apis.URL) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceSinkUnknown 

func WithCloudAuditLogsSourceSinkUnknown(reason, messageFmt string, messageA ...interface{}) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceSinkUnknown marks the condition that the sink is unknown.

func WithCloudAuditLogsSourceSubscriptionID 

func WithCloudAuditLogsSourceSubscriptionID(subscriptionID string) CloudAuditLogsSourceOption

func WithCloudAuditLogsSourceTopicFailed 

func WithCloudAuditLogsSourceTopicFailed(reason, message string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceTopicFailed marks the condition that the topic is False.

func WithCloudAuditLogsSourceTopicReady 

func WithCloudAuditLogsSourceTopicReady(topicID string) CloudAuditLogsSourceOption

WithCloudStorageSourceTopicUnknown marks the condition that the topic is Ready.

func WithCloudAuditLogsSourceTopicUnknown 

func WithCloudAuditLogsSourceTopicUnknown(reason, message string) CloudAuditLogsSourceOption

WithCloudStorageSourceTopicUnknown marks the condition that the topic is Unknown.

func WithCloudAuditLogsSourceUID 

func WithCloudAuditLogsSourceUID(uid string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceUID sets the CloudAuditLogsSource's ObjectMeta.UID.

func WithCloudAuditLogsSourceWorkloadIdentityFailed 

func WithCloudAuditLogsSourceWorkloadIdentityFailed(reason, message string) CloudAuditLogsSourceOption

WithCloudAuditLogsSourceWorkloadIdentityFailed marks the condition that the WorkloadIdentity is False.

type CloudBuildSourceOption added in v0.18.0 

type CloudBuildSourceOption func(*v1.CloudBuildSource)

CloudBuildSourceOption enables further configuration of a CloudBuildSource.

func WithCloudBuildSourceAnnotations added in v0.18.0 

func WithCloudBuildSourceAnnotations(Annotations map[string]string) CloudBuildSourceOption

func WithCloudBuildSourceFinalizers added in v0.18.0 

func WithCloudBuildSourceFinalizers(finalizers ...string) CloudBuildSourceOption

func WithCloudBuildSourceObjectMetaGeneration added in v0.18.0 

func WithCloudBuildSourceObjectMetaGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceProject added in v0.18.0 

func WithCloudBuildSourceProject(project string) CloudBuildSourceOption

func WithCloudBuildSourcePullSubscriptionFailed added in v0.18.0 

func WithCloudBuildSourcePullSubscriptionFailed(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudBuildSourcePullSubscriptionReady added in v0.18.0 

func WithCloudBuildSourcePullSubscriptionReady() CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudBuildSourcePullSubscriptionUnknown added in v0.18.0 

func WithCloudBuildSourcePullSubscriptionUnknown(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudBuildSourceServiceAccount added in v0.18.0 

func WithCloudBuildSourceServiceAccount(kServiceAccount string) CloudBuildSourceOption

func WithCloudBuildSourceSink added in v0.18.0 

func WithCloudBuildSourceSink(gvk metav1.GroupVersionKind, name string) CloudBuildSourceOption

func WithCloudBuildSourceSinkURI added in v0.18.0 

func WithCloudBuildSourceSinkURI(url *apis.URL) CloudBuildSourceOption

WithCloudBuildSourceSinkURI sets the status for sink URI

func WithCloudBuildSourceStatusObservedGeneration added in v0.18.0 

func WithCloudBuildSourceStatusObservedGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceSubscriptionID added in v0.18.0 

func WithCloudBuildSourceSubscriptionID(subscriptionID string) CloudBuildSourceOption

func WithCloudBuildSourceWorkloadIdentityFailed added in v0.18.0 

func WithCloudBuildSourceWorkloadIdentityFailed(reason, message string) CloudBuildSourceOption

type CloudPubSubSourceOption 

type CloudPubSubSourceOption func(*v1.CloudPubSubSource)

CloudPubSubSourceOption enables further configuration of a CloudPubSubSource.

func WithCloudPubSubSourceAnnotations 

func WithCloudPubSubSourceAnnotations(Annotations map[string]string) CloudPubSubSourceOption

func WithCloudPubSubSourceFinalizers 

func WithCloudPubSubSourceFinalizers(finalizers ...string) CloudPubSubSourceOption

func WithCloudPubSubSourceObjectMetaGeneration 

func WithCloudPubSubSourceObjectMetaGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourceProject 

func WithCloudPubSubSourceProject(project string) CloudPubSubSourceOption

func WithCloudPubSubSourcePullSubscriptionFailed 

func WithCloudPubSubSourcePullSubscriptionFailed(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudPubSubSourcePullSubscriptionUnknown 

func WithCloudPubSubSourcePullSubscriptionUnknown(reason, message string) CloudPubSubSourceOption

WithCloudPubSubSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudPubSubSourceServiceAccount 

func WithCloudPubSubSourceServiceAccount(kServiceAccount string) CloudPubSubSourceOption

func WithCloudPubSubSourceSink 

func WithCloudPubSubSourceSink(gvk metav1.GroupVersionKind, name string) CloudPubSubSourceOption

func WithCloudPubSubSourceSinkURI 

func WithCloudPubSubSourceSinkURI(url *apis.URL) CloudPubSubSourceOption

WithCloudPubSubSourceSinkURI sets the status for sink URI

func WithCloudPubSubSourceStatusObservedGeneration 

func WithCloudPubSubSourceStatusObservedGeneration(generation int64) CloudPubSubSourceOption

func WithCloudPubSubSourceSubscriptionID 

func WithCloudPubSubSourceSubscriptionID(subscriptionID string) CloudPubSubSourceOption

func WithCloudPubSubSourceTopic 

func WithCloudPubSubSourceTopic(topicID string) CloudPubSubSourceOption

func WithCloudPubSubSourceWorkloadIdentityFailed 

func WithCloudPubSubSourceWorkloadIdentityFailed(reason, message string) CloudPubSubSourceOption

type CloudSchedulerSourceOption 

type CloudSchedulerSourceOption func(*v1.CloudSchedulerSource)

CloudSchedulerSourceOption enables further configuration of a CloudSchedulerSource.

func WithCloudSchedulerSourceAnnotations 

func WithCloudSchedulerSourceAnnotations(Annotations map[string]string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceData 

func WithCloudSchedulerSourceData(data string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceFinalizers 

func WithCloudSchedulerSourceFinalizers(finalizers ...string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceJobDeleted 

func WithCloudSchedulerSourceJobDeleted(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobDeleted is a wrapper to indicate that the job is deleted. Inside the function, we still mark the status of job to be ready, as the status of job is unchanged if the deletion is successful.

func WithCloudSchedulerSourceJobName 

func WithCloudSchedulerSourceJobName(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobName sets the status for job Name

func WithCloudSchedulerSourceJobNotReady 

func WithCloudSchedulerSourceJobNotReady(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobNotReady marks the condition that the CloudSchedulerSource Job is not ready.

func WithCloudSchedulerSourceJobReady 

func WithCloudSchedulerSourceJobReady(jobName string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobReady marks the condition that the CloudSchedulerSource Job is ready and sets Status.JobName to jobName.

func WithCloudSchedulerSourceJobUnknown 

func WithCloudSchedulerSourceJobUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceJobUnknown marks the condition that the CloudSchedulerSource Job is unknown.

func WithCloudSchedulerSourceLocation 

func WithCloudSchedulerSourceLocation(location string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceProject 

func WithCloudSchedulerSourceProject(project string) CloudSchedulerSourceOption

func WithCloudSchedulerSourcePullSubscriptionFailed 

func WithCloudSchedulerSourcePullSubscriptionFailed(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionFailed marks the condition that the topic is False.

func WithCloudSchedulerSourcePullSubscriptionUnknown 

func WithCloudSchedulerSourcePullSubscriptionUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourcePullSubscriptionUnknown marks the condition that the topic is Unknown.

func WithCloudSchedulerSourceSchedule 

func WithCloudSchedulerSourceSchedule(schedule string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceServiceAccount 

func WithCloudSchedulerSourceServiceAccount(kServiceAccount string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceSink 

func WithCloudSchedulerSourceSink(gvk metav1.GroupVersionKind, name string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceSinkURI 

func WithCloudSchedulerSourceSinkURI(url *apis.URL) CloudSchedulerSourceOption

WithCloudSchedulerSourceSinkURI sets the status for sink URI

func WithCloudSchedulerSourceSubscriptionID 

func WithCloudSchedulerSourceSubscriptionID(subscriptionID string) CloudSchedulerSourceOption

func WithCloudSchedulerSourceTopicFailed 

func WithCloudSchedulerSourceTopicFailed(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicFailed marks the condition that the status of topic is False.

func WithCloudSchedulerSourceTopicReady 

func WithCloudSchedulerSourceTopicReady(topicID, projectID string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicNotReady marks the condition that the topic is not ready.

func WithCloudSchedulerSourceTopicUnknown 

func WithCloudSchedulerSourceTopicUnknown(reason, message string) CloudSchedulerSourceOption

WithCloudSchedulerSourceTopicUnknown marks the condition that the status of topic is Unknown.

func WithCloudSchedulerSourceWorkloadIdentityFailed 

func WithCloudSchedulerSourceWorkloadIdentityFailed(reason, message string) CloudSchedulerSourceOption

type CloudStorageSourceOption 

type CloudStorageSourceOption func(*v1.CloudStorageSource)

CloudStorageSourceOption enables further configuration of a CloudStorageSource.

func WithCloudStorageSourceAnnotations 

func WithCloudStorageSourceAnnotations(Annotations map[string]string) CloudStorageSourceOption

func WithCloudStorageSourceBucket 

func WithCloudStorageSourceBucket(bucket string) CloudStorageSourceOption

func WithCloudStorageSourceEventTypes 

func WithCloudStorageSourceEventTypes(eventTypes []string) CloudStorageSourceOption

func WithCloudStorageSourceNotificationDeleted 

func WithCloudStorageSourceNotificationDeleted(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationDeleted a wrapper to indicate that the notification is deleted. Inside the function, we still mark the status of notification to be ready, as the status of notification is unchanged if the deletion is successful.

func WithCloudStorageSourceNotificationID 

func WithCloudStorageSourceNotificationID(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationId sets the status for Notification ID.

func WithCloudStorageSourceNotificationNotReady 

func WithCloudStorageSourceNotificationNotReady(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceNotificationNotReady marks the condition that the GCS Notification is not ready.

func WithCloudStorageSourceNotificationReady 

func WithCloudStorageSourceNotificationReady(notificationID string) CloudStorageSourceOption

WithCloudStorageSourceNotificationReady marks the condition that the GCS Notification is ready.

func WithCloudStorageSourceNotificationUnknown 

func WithCloudStorageSourceNotificationUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceNotificationNotReady marks the condition that the GCS Notification is unknown.

func WithCloudStorageSourceObjectMetaGeneration 

func WithCloudStorageSourceObjectMetaGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceProject 

func WithCloudStorageSourceProject(project string) CloudStorageSourceOption

func WithCloudStorageSourceProjectID 

func WithCloudStorageSourceProjectID(projectID string) CloudStorageSourceOption

WithCloudStorageSourceProjectId sets the status for Project ID.

func WithCloudStorageSourcePullSubscriptionFailed 

func WithCloudStorageSourcePullSubscriptionFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionFailed marks the condition that the status of topic is False.

func WithCloudStorageSourcePullSubscriptionUnknown 

func WithCloudStorageSourcePullSubscriptionUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourcePullSubscriptionUnknown marks the condition that the status of topic is Unknown.

func WithCloudStorageSourceServiceAccount 

func WithCloudStorageSourceServiceAccount(kServiceAccount string) CloudStorageSourceOption

func WithCloudStorageSourceSink 

func WithCloudStorageSourceSink(gvk metav1.GroupVersionKind, name string) CloudStorageSourceOption

func WithCloudStorageSourceSinkDestination 

func WithCloudStorageSourceSinkDestination(sink duckv1.Destination) CloudStorageSourceOption

func WithCloudStorageSourceSinkURI 

func WithCloudStorageSourceSinkURI(url *apis.URL) CloudStorageSourceOption

WithCloudStorageSourceSinkURI sets the status for sink URI.

func WithCloudStorageSourceStatusObservedGeneration 

func WithCloudStorageSourceStatusObservedGeneration(generation int64) CloudStorageSourceOption

func WithCloudStorageSourceSubscriptionID 

func WithCloudStorageSourceSubscriptionID(subscriptionID string) CloudStorageSourceOption

func WithCloudStorageSourceTopicFailed 

func WithCloudStorageSourceTopicFailed(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicFailed marks the condition that the topic is False.

func WithCloudStorageSourceTopicID 

func WithCloudStorageSourceTopicID(topicID string) CloudStorageSourceOption

func WithCloudStorageSourceTopicReady 

func WithCloudStorageSourceTopicReady(topicID string) CloudStorageSourceOption

WithCloudStorageSourceTopicNotReady marks the condition that the topic is not ready.

func WithCloudStorageSourceTopicUnknown 

func WithCloudStorageSourceTopicUnknown(reason, message string) CloudStorageSourceOption

WithCloudStorageSourceTopicUnknown marks the condition that the topic is Unknown.

func WithCloudStorageSourceWorkloadIdentityFailed 

func WithCloudStorageSourceWorkloadIdentityFailed(reason, message string) CloudStorageSourceOption

type PullSubscriptionOption 

type PullSubscriptionOption func(*v1.PullSubscription)

PullSubscriptionOption enables further configuration of a PullSubscription.

func WithPullSubscriptionAnnotations 

func WithPullSubscriptionAnnotations(annotations map[string]string) PullSubscriptionOption

func WithPullSubscriptionFailed 

func WithPullSubscriptionFailed() PullSubscriptionOption

func WithPullSubscriptionFinalizers 

func WithPullSubscriptionFinalizers(finalizers ...string) PullSubscriptionOption

func WithPullSubscriptionGenerateName 

func WithPullSubscriptionGenerateName(generateName string) PullSubscriptionOption

func WithPullSubscriptionJobFailure 

func WithPullSubscriptionJobFailure(subscriptionID, reason, message string) PullSubscriptionOption

func WithPullSubscriptionLabels 

func WithPullSubscriptionLabels(labels map[string]string) PullSubscriptionOption

func WithPullSubscriptionMarkDeployed 

func WithPullSubscriptionMarkDeployed(name, namespace string) PullSubscriptionOption

func WithPullSubscriptionMarkDeployedFailed added in v0.18.0 

func WithPullSubscriptionMarkDeployedFailed(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkDeployedUnknown added in v0.18.0 

func WithPullSubscriptionMarkDeployedUnknown(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkNoDeployed 

func WithPullSubscriptionMarkNoDeployed(name, namespace string) PullSubscriptionOption

func WithPullSubscriptionMarkNoSubscription 

func WithPullSubscriptionMarkNoSubscription(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkNoTransformer 

func WithPullSubscriptionMarkNoTransformer(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkSink 

func WithPullSubscriptionMarkSink(uri *apis.URL) PullSubscriptionOption

func WithPullSubscriptionMarkSubscribed 

func WithPullSubscriptionMarkSubscribed(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionMarkTransformer 

func WithPullSubscriptionMarkTransformer(uri *apis.URL) PullSubscriptionOption

func WithPullSubscriptionObjectMetaGeneration 

func WithPullSubscriptionObjectMetaGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionOwnerReferences 

func WithPullSubscriptionOwnerReferences(ownerReferences []metav1.OwnerReference) PullSubscriptionOption

func WithPullSubscriptionProjectID 

func WithPullSubscriptionProjectID(projectID string) PullSubscriptionOption

func WithPullSubscriptionReady 

func WithPullSubscriptionReady(sink *apis.URL) PullSubscriptionOption

func WithPullSubscriptionReadyStatus 

func WithPullSubscriptionReadyStatus(status corev1.ConditionStatus, reason, message string) PullSubscriptionOption

func WithPullSubscriptionServiceAccount 

func WithPullSubscriptionServiceAccount(kServiceAccount string) PullSubscriptionOption

func WithPullSubscriptionSink 

func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption

func WithPullSubscriptionSinkNotFound 

func WithPullSubscriptionSinkNotFound() PullSubscriptionOption

func WithPullSubscriptionSpec 

func WithPullSubscriptionSpec(spec v1.PullSubscriptionSpec) PullSubscriptionOption

func WithPullSubscriptionStatusObservedGeneration 

func WithPullSubscriptionStatusObservedGeneration(generation int64) PullSubscriptionOption

func WithPullSubscriptionSubscriptionID 

func WithPullSubscriptionSubscriptionID(subscriptionID string) PullSubscriptionOption

func WithPullSubscriptionTopic 

func WithPullSubscriptionTopic(topicID string) PullSubscriptionOption

func WithPullSubscriptionTransformer 

func WithPullSubscriptionTransformer(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption

func WithPullSubscriptionTransformerURI 

func WithPullSubscriptionTransformerURI(uri *apis.URL) PullSubscriptionOption

func WithPullSubscriptionUID 

func WithPullSubscriptionUID(uid types.UID) PullSubscriptionOption

func WithPullSubscriptionUnknown 

func WithPullSubscriptionUnknown() PullSubscriptionOption

type TopicOption 

type TopicOption func(*v1.Topic)

TopicOption enables further configuration of a Topic.

func WithTopicAddress 

func WithTopicAddress(uri string) TopicOption

func WithTopicAnnotations 

func WithTopicAnnotations(annotations map[string]string) TopicOption

func WithTopicFinalizers 

func WithTopicFinalizers(finalizers ...string) TopicOption

func WithTopicJobFailure 

func WithTopicJobFailure(topicID, reason, message string) TopicOption

func WithTopicLabels 

func WithTopicLabels(labels map[string]string) TopicOption

func WithTopicNoTopic 

func WithTopicNoTopic(reason, message string) TopicOption

func WithTopicOwnerReferences 

func WithTopicOwnerReferences(ownerReferences []metav1.OwnerReference) TopicOption

func WithTopicProjectID 

func WithTopicProjectID(projectID string) TopicOption

func WithTopicPropagationPolicy 

func WithTopicPropagationPolicy(policy string) TopicOption

func WithTopicPublisherNotDeployed 

func WithTopicPublisherNotDeployed(reason, message string) TopicOption

func WithTopicPublisherUnknown 

func WithTopicPublisherUnknown(reason, message string) TopicOption

func WithTopicReady 

func WithTopicReady(topicID string) TopicOption

func WithTopicReadyAndPublisherDeployed 

func WithTopicReadyAndPublisherDeployed(topicID string) TopicOption

func WithTopicSpec 

func WithTopicSpec(spec v1.TopicSpec) TopicOption

func WithTopicTopicDeleted 

func WithTopicTopicDeleted(topicID string) TopicOption

func WithTopicTopicID 

func WithTopicTopicID(topicID string) TopicOption

func WithTopicUID 

func WithTopicUID(uid types.UID) TopicOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.