v1

package
v0.0.0-...-d19fc40 Latest Latest
Warning

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

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

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

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

func WithCloudBuildSourceDeletionTimestamp(bs *v1.CloudBuildSource)

func WithCloudBuildSourceSetDefault

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

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

type CloudBuildSourceOption func(*v1.CloudBuildSource)

CloudBuildSourceOption enables further configuration of a CloudBuildSource.

func WithCloudBuildSourceAnnotations

func WithCloudBuildSourceAnnotations(Annotations map[string]string) CloudBuildSourceOption

func WithCloudBuildSourceFinalizers

func WithCloudBuildSourceFinalizers(finalizers ...string) CloudBuildSourceOption

func WithCloudBuildSourceObjectMetaGeneration

func WithCloudBuildSourceObjectMetaGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceProject

func WithCloudBuildSourceProject(project string) CloudBuildSourceOption

func WithCloudBuildSourcePullSubscriptionFailed

func WithCloudBuildSourcePullSubscriptionFailed(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionFailed marks the condition that the status of PullSubscription is False

func WithCloudBuildSourcePullSubscriptionReady

func WithCloudBuildSourcePullSubscriptionReady() CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionReady marks the condition that the topic is not ready

func WithCloudBuildSourcePullSubscriptionUnknown

func WithCloudBuildSourcePullSubscriptionUnknown(reason, message string) CloudBuildSourceOption

WithCloudBuildSourcePullSubscriptionUnknown marks the condition that the topic is Unknown

func WithCloudBuildSourceServiceAccount

func WithCloudBuildSourceServiceAccount(kServiceAccount string) CloudBuildSourceOption

func WithCloudBuildSourceSink

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

func WithCloudBuildSourceSinkURI

func WithCloudBuildSourceSinkURI(url *apis.URL) CloudBuildSourceOption

WithCloudBuildSourceSinkURI sets the status for sink URI

func WithCloudBuildSourceStatusObservedGeneration

func WithCloudBuildSourceStatusObservedGeneration(generation int64) CloudBuildSourceOption

func WithCloudBuildSourceSubscriptionID

func WithCloudBuildSourceSubscriptionID(subscriptionID string) CloudBuildSourceOption

func WithCloudBuildSourceWorkloadIdentityFailed

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

func WithPullSubscriptionMarkDeployedFailed(reason, message string) PullSubscriptionOption

func WithPullSubscriptionMarkDeployedUnknown

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

Jump to

Keyboard shortcuts

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