Documentation
¶
Index ¶
- Constants
- func NewCloudAuditLogsSource(name, namespace string, opts ...CloudAuditLogsSourceOption) *v1alpha1.CloudAuditLogsSource
- func NewCloudBuildSource(name, namespace string, so ...CloudBuildSourceOption) *v1alpha1.CloudBuildSource
- func NewCloudPubSubSource(name, namespace string, so ...CloudPubSubSourceOption) *v1alpha1.CloudPubSubSource
- func NewCloudSchedulerSource(name, namespace string, so ...CloudSchedulerSourceOption) *v1alpha1.CloudSchedulerSource
- func NewCloudStorageSource(name, namespace string, so ...CloudStorageSourceOption) *v1alpha1.CloudStorageSource
- func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
- func WithCloudStorageSourceSetDefaults(s *v1alpha1.CloudStorageSource)
- func WithDeletionTimestamp(s *v1alpha1.CloudStorageSource)
- func WithInitCloudStorageSourceConditions(s *v1alpha1.CloudStorageSource)
- type CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceMethodName(methodName string) CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceProject(project string) CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceResourceName(resourceName string) CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceServiceAccount(kServiceAccount string) CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceServiceName(serviceName string) CloudAuditLogsSourceOption
- func WithCloudAuditLogsSourceSink(gvk metav1.GroupVersionKind, name string) CloudAuditLogsSourceOption
- type CloudBuildSourceOption
- type CloudPubSubSourceOption
- type CloudSchedulerSourceOption
- func WithCloudSchedulerSourceData(data string) CloudSchedulerSourceOption
- func WithCloudSchedulerSourceLocation(location string) CloudSchedulerSourceOption
- func WithCloudSchedulerSourceSchedule(schedule string) CloudSchedulerSourceOption
- func WithCloudSchedulerSourceServiceAccount(kServiceAccount string) CloudSchedulerSourceOption
- func WithCloudSchedulerSourceSink(gvk metav1.GroupVersionKind, name string) CloudSchedulerSourceOption
- type CloudStorageSourceOption
- func WithCloudStorageSourceAnnotations(Annotations map[string]string) CloudStorageSourceOption
- func WithCloudStorageSourceBucket(bucket string) CloudStorageSourceOption
- func WithCloudStorageSourceEventTypes(eventTypes []string) CloudStorageSourceOption
- func WithCloudStorageSourceNotificationID(notificationID string) CloudStorageSourceOption
- func WithCloudStorageSourceNotificationNotReady(reason, message string) CloudStorageSourceOption
- func WithCloudStorageSourceNotificationReady(notificationID string) CloudStorageSourceOption
- func WithCloudStorageSourceObjectMetaGeneration(generation int64) CloudStorageSourceOption
- func WithCloudStorageSourceProject(project string) CloudStorageSourceOption
- func WithCloudStorageSourceProjectID(projectID string) CloudStorageSourceOption
- func WithCloudStorageSourcePullSubscriptionFailed(reason, message string) CloudStorageSourceOption
- func WithCloudStorageSourcePullSubscriptionReady() CloudStorageSourceOption
- func WithCloudStorageSourcePullSubscriptionUnknown(reason, message string) CloudStorageSourceOption
- func WithCloudStorageSourceServiceAccount(kServiceAccount string) CloudStorageSourceOption
- func WithCloudStorageSourceServiceAccountName(name string) CloudStorageSourceOption
- func WithCloudStorageSourceSink(gvk metav1.GroupVersionKind, name string) CloudStorageSourceOption
- func WithCloudStorageSourceSinkDestination(sink duckv1.Destination) CloudStorageSourceOption
- func WithCloudStorageSourceSinkURI(url *apis.URL) CloudStorageSourceOption
- func WithCloudStorageSourceStatusObservedGeneration(generation int64) CloudStorageSourceOption
- func WithCloudStorageSourceSubscriptionID(subscriptionID string) CloudStorageSourceOption
- func WithCloudStorageSourceTopicFailed(reason, message string) CloudStorageSourceOption
- func WithCloudStorageSourceTopicID(topicID string) CloudStorageSourceOption
- func WithCloudStorageSourceTopicReady(topicID string) CloudStorageSourceOption
- func WithCloudStorageSourceTopicUnknown(reason, message string) CloudStorageSourceOption
- func WithCloudStorageSourceWorkloadIdentityFailed(reason, message string) CloudStorageSourceOption
- type PullSubscriptionOption
- func WithPullSubscriptionServiceAccount(kServiceAccount string) PullSubscriptionOption
- func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption
- func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
- func WithPullSubscriptionTopic(topicID string) PullSubscriptionOption
Constants ¶
const (
SubscriptionID = "subID"
)
Variables ¶
This section is empty.
Functions ¶
func NewCloudAuditLogsSource ¶
func NewCloudAuditLogsSource(name, namespace string, opts ...CloudAuditLogsSourceOption) *v1alpha1.CloudAuditLogsSource
func NewCloudBuildSource ¶
func NewCloudBuildSource(name, namespace string, so ...CloudBuildSourceOption) *v1alpha1.CloudBuildSource
NewCloudBuildSource creates a CloudBuildSource with CloudBuildSourceOptions
func NewCloudPubSubSource ¶
func NewCloudPubSubSource(name, namespace string, so ...CloudPubSubSourceOption) *v1alpha1.CloudPubSubSource
NewCloudPubSubSource creates a CloudPubSubSource with CloudPubSubSourceOptions
func NewCloudSchedulerSource ¶
func NewCloudSchedulerSource(name, namespace string, so ...CloudSchedulerSourceOption) *v1alpha1.CloudSchedulerSource
NewCloudSchedulerSource creates a CloudSchedulerSource with CloudSchedulerSourceOptions
func NewCloudStorageSource ¶
func NewCloudStorageSource(name, namespace string, so ...CloudStorageSourceOption) *v1alpha1.CloudStorageSource
NewCloudStorageSource creates a CloudStorageSource with CloudStorageSourceOptions
func NewPullSubscription ¶
func NewPullSubscription(name, namespace string, so ...PullSubscriptionOption) *v1alpha1.PullSubscription
NewPullSubscription creates a PullSubscription with PullSubscriptionOptions
func WithCloudStorageSourceSetDefaults ¶
func WithCloudStorageSourceSetDefaults(s *v1alpha1.CloudStorageSource)
func WithDeletionTimestamp ¶
func WithDeletionTimestamp(s *v1alpha1.CloudStorageSource)
func WithInitCloudStorageSourceConditions ¶
func WithInitCloudStorageSourceConditions(s *v1alpha1.CloudStorageSource)
WithInitCloudStorageSourceConditions initializes the CloudStorageSources's conditions.
Types ¶
type CloudAuditLogsSourceOption ¶
type CloudAuditLogsSourceOption func(*v1alpha1.CloudAuditLogsSource)
func WithCloudAuditLogsSourceMethodName ¶
func WithCloudAuditLogsSourceMethodName(methodName string) CloudAuditLogsSourceOption
func WithCloudAuditLogsSourceProject ¶
func WithCloudAuditLogsSourceProject(project string) CloudAuditLogsSourceOption
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
type CloudBuildSourceOption ¶
type CloudBuildSourceOption func(*v1alpha1.CloudBuildSource)
CloudBuildSourceOption enables further configuration of a CloudBuildSource.
func WithCloudBuildSourceServiceAccount ¶
func WithCloudBuildSourceServiceAccount(kServiceAccount string) CloudBuildSourceOption
func WithCloudBuildSourceSink ¶
func WithCloudBuildSourceSink(gvk metav1.GroupVersionKind, name string) CloudBuildSourceOption
type CloudPubSubSourceOption ¶
type CloudPubSubSourceOption func(*v1alpha1.CloudPubSubSource)
CloudPubSubSourceOption enables further configuration of a CloudPubSubSource.
func WithCloudPubSubSourceServiceAccount ¶
func WithCloudPubSubSourceServiceAccount(kServiceAccount string) CloudPubSubSourceOption
func WithCloudPubSubSourceSink ¶
func WithCloudPubSubSourceSink(gvk metav1.GroupVersionKind, name string) CloudPubSubSourceOption
func WithCloudPubSubSourceTopic ¶
func WithCloudPubSubSourceTopic(topicID string) CloudPubSubSourceOption
type CloudSchedulerSourceOption ¶
type CloudSchedulerSourceOption func(*v1alpha1.CloudSchedulerSource)
CloudSchedulerSourceOption enables further configuration of a CloudSchedulerSource.
func WithCloudSchedulerSourceData ¶
func WithCloudSchedulerSourceData(data string) CloudSchedulerSourceOption
func WithCloudSchedulerSourceLocation ¶
func WithCloudSchedulerSourceLocation(location string) CloudSchedulerSourceOption
func WithCloudSchedulerSourceSchedule ¶
func WithCloudSchedulerSourceSchedule(schedule string) CloudSchedulerSourceOption
func WithCloudSchedulerSourceServiceAccount ¶
func WithCloudSchedulerSourceServiceAccount(kServiceAccount string) CloudSchedulerSourceOption
func WithCloudSchedulerSourceSink ¶
func WithCloudSchedulerSourceSink(gvk metav1.GroupVersionKind, name string) CloudSchedulerSourceOption
type CloudStorageSourceOption ¶
type CloudStorageSourceOption func(*v1alpha1.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 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 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 WithCloudStorageSourcePullSubscriptionReady ¶
func WithCloudStorageSourcePullSubscriptionReady() CloudStorageSourceOption
WithCloudStorageSourcePullSubscriptionReady marks the condition that the topic is ready.
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 WithCloudStorageSourceServiceAccountName ¶
func WithCloudStorageSourceServiceAccountName(name string) CloudStorageSourceOption
WithCloudStorageSourceServiceAccountName will give status.ServiceAccountName a k8s service account name, which is related on Workload Identity's Google service account.
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 False
func WithCloudStorageSourceWorkloadIdentityFailed ¶
func WithCloudStorageSourceWorkloadIdentityFailed(reason, message string) CloudStorageSourceOption
type PullSubscriptionOption ¶
type PullSubscriptionOption func(*v1alpha1.PullSubscription)
PullSubscriptionOption enables further configuration of a PullSubscription.
func WithPullSubscriptionServiceAccount ¶
func WithPullSubscriptionServiceAccount(kServiceAccount string) PullSubscriptionOption
func WithPullSubscriptionSink ¶
func WithPullSubscriptionSink(gvk metav1.GroupVersionKind, name string) PullSubscriptionOption
func WithPullSubscriptionSpec ¶
func WithPullSubscriptionSpec(spec v1alpha1.PullSubscriptionSpec) PullSubscriptionOption
func WithPullSubscriptionTopic ¶
func WithPullSubscriptionTopic(topicID string) PullSubscriptionOption