Documentation

Overview

    Package v1alpha1 contains API Schema definitions for the events v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/google/knative-gcp/pkg/apis/events +k8s:defaulter-gen=TypeMeta +groupName=events.cloud.google.com

    Index

    Constants

    View Source
    const (
    	// CloudSchedulerSourceConditionReady has status True when CloudSchedulerSource is ready to send events.
    	CloudSchedulerSourceConditionReady = apis.ConditionReady
    
    	// JobReady has status True when CloudSchedulerSource Job has been successfully created.
    	JobReady apis.ConditionType = "JobReady"
    )
    View Source
    const (
    	// CloudStorageSourceConditionReady has status True when the CloudStorageSource is ready to send events.
    	CloudStorageSourceConditionReady = apis.ConditionReady
    
    	// NotificationReady has status True when GCS has been configured properly to
    	// send Notification events.
    	NotificationReady apis.ConditionType = "NotificationReady"
    )
    View Source
    const (
    	// CloudBuildSourceConditionReady has status True when the CloudBuildSource is
    	// ready to send events.
    	CloudBuildSourceConditionReady = apis.ConditionReady
    )
    View Source
    const (
    	// CloudPubSubSourceConditionReady has status True when the CloudPubSubSource is
    	// ready to send events.
    	CloudPubSubSourceConditionReady = apis.ConditionReady
    )
    View Source
    const (
    	DefaultTopic = "cloud-builds"
    )
    View Source
    const (
    	// SinkReady has status True when CloudAuditLogsSource sink is ready.
    	SinkReady apis.ConditionType = "SinkReady"
    )

    Variables

    View Source
    var (
    	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
    	AddToScheme   = SchemeBuilder.AddToScheme
    )
    View Source
    var SchemeGroupVersion = schema.GroupVersion{Group: events.GroupName, Version: "v1alpha1"}

      SchemeGroupVersion is group version used to register these objects

      Functions

      func CloudBuildSourceEventSource

      func CloudBuildSourceEventSource(googleCloudProject, buildId string) string

        CloudBuildSourceEventSource returns the Cloud Build CloudEvent source value.

        func Kind

        func Kind(kind string) schema.GroupKind

          Kind takes an unqualified kind and returns back a Group qualified GroupKind

          func Resource

          func Resource(resource string) schema.GroupResource

            Resource takes an unqualified resource and returns a Group qualified GroupResource

            Types

            type CloudAuditLogsSource

            type CloudAuditLogsSource struct {
            	metav1.TypeMeta   `json:",inline"`
            	metav1.ObjectMeta `json:"metadata,omitempty"`
            
            	Spec   CloudAuditLogsSourceSpec   `json:"spec"`
            	Status CloudAuditLogsSourceStatus `json:"status"`
            }

              CloudAuditLogsSource is a specification for a Cloud Audit Log event source.

              func (*CloudAuditLogsSource) CheckImmutableFields

              func (current *CloudAuditLogsSource) CheckImmutableFields(ctx context.Context, original *CloudAuditLogsSource) *apis.FieldError

              func (*CloudAuditLogsSource) ConditionSet

              func (*CloudAuditLogsSource) ConditionSet() *apis.ConditionSet

                ConditionSet returns the apis.ConditionSet of the embedding object.

                func (*CloudAuditLogsSource) ConvertFrom

                func (sink *CloudAuditLogsSource) ConvertFrom(ctx context.Context, from apis.Convertible) error

                  ConvertFrom implements apis.Convertible. Converts from a higher version of CloudAuditLogsSource to a v1alpha1.CloudAuditLogsSource.

                  func (*CloudAuditLogsSource) ConvertTo

                  func (source *CloudAuditLogsSource) ConvertTo(ctx context.Context, to apis.Convertible) error

                    ConvertTo implements apis.Convertible. Converts from a v1alpha1.CloudAuditLogsSource to a higher version of CloudAuditLogsSource.

                    func (*CloudAuditLogsSource) DeepCopy

                      DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudAuditLogsSource.

                      func (*CloudAuditLogsSource) DeepCopyInto

                      func (in *CloudAuditLogsSource) DeepCopyInto(out *CloudAuditLogsSource)

                        DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                        func (*CloudAuditLogsSource) DeepCopyObject

                        func (in *CloudAuditLogsSource) DeepCopyObject() runtime.Object

                          DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                          func (*CloudAuditLogsSource) GetGroupVersionKind

                          func (*CloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind

                          func (*CloudAuditLogsSource) IdentitySpec

                          func (s *CloudAuditLogsSource) IdentitySpec() *duckv1alpha1.IdentitySpec

                            Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.

                            func (*CloudAuditLogsSource) IdentityStatus

                            func (s *CloudAuditLogsSource) IdentityStatus() *duckv1alpha1.IdentityStatus

                              IdentityStatus returns the IdentityStatus portion of the Status.

                              func (*CloudAuditLogsSource) PubSubSpec

                              func (s *CloudAuditLogsSource) PubSubSpec() *duckv1alpha1.PubSubSpec

                                PubSubSpec returns the PubSubSpec portion of the Spec.

                                func (*CloudAuditLogsSource) PubSubStatus

                                func (s *CloudAuditLogsSource) PubSubStatus() *duckv1alpha1.PubSubStatus

                                  PubSubStatus returns the PubSubStatus portion of the Status.

                                  func (*CloudAuditLogsSource) SetDefaults

                                  func (s *CloudAuditLogsSource) SetDefaults(ctx context.Context)

                                  func (*CloudAuditLogsSource) Validate

                                  func (current *CloudAuditLogsSource) Validate(ctx context.Context) *apis.FieldError

                                  type CloudAuditLogsSourceList

                                  type CloudAuditLogsSourceList struct {
                                  	metav1.TypeMeta
                                  	metav1.ListMeta
                                  
                                  	Items []CloudAuditLogsSource `json:"items"`
                                  }

                                    +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

                                    func (*CloudAuditLogsSourceList) DeepCopy

                                      DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudAuditLogsSourceList.

                                      func (*CloudAuditLogsSourceList) DeepCopyInto

                                      func (in *CloudAuditLogsSourceList) DeepCopyInto(out *CloudAuditLogsSourceList)

                                        DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                        func (*CloudAuditLogsSourceList) DeepCopyObject

                                        func (in *CloudAuditLogsSourceList) DeepCopyObject() runtime.Object

                                          DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                          type CloudAuditLogsSourceSpec

                                          type CloudAuditLogsSourceSpec struct {
                                          	// This brings in the PubSub based Source Specs. Includes:
                                          	duckv1alpha1.PubSubSpec `json:",inline"`
                                          
                                          	// The GCP service providing audit logs. Required.
                                          	ServiceName string `json:"serviceName"`
                                          	// The name of the service method or operation. For API calls,
                                          	// this should be the name of the API method. Required.
                                          	MethodName string `json:"methodName"`
                                          	// The resource or collection that is the target of the
                                          	// operation. The name is a scheme-less URI, not including the
                                          	// API service name.
                                          	ResourceName string `json:"resourceName,omitempty"`
                                          }

                                          func (*CloudAuditLogsSourceSpec) DeepCopy

                                            DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudAuditLogsSourceSpec.

                                            func (*CloudAuditLogsSourceSpec) DeepCopyInto

                                            func (in *CloudAuditLogsSourceSpec) DeepCopyInto(out *CloudAuditLogsSourceSpec)

                                              DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                              func (*CloudAuditLogsSourceSpec) Validate

                                              func (current *CloudAuditLogsSourceSpec) Validate(ctx context.Context) *apis.FieldError

                                              type CloudAuditLogsSourceStatus

                                              type CloudAuditLogsSourceStatus struct {
                                              	duckv1alpha1.PubSubStatus `json:",inline"`
                                              
                                              	// ID of the Stackdriver sink used to publish audit log messages.
                                              	StackdriverSink string `json:"stackdriverSink,omitempty"`
                                              }

                                              func (*CloudAuditLogsSourceStatus) DeepCopy

                                                DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudAuditLogsSourceStatus.

                                                func (*CloudAuditLogsSourceStatus) DeepCopyInto

                                                  DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                  func (*CloudAuditLogsSourceStatus) GetCondition

                                                    GetCondition returns the condition currently associated with the given type, or nil.

                                                    func (*CloudAuditLogsSourceStatus) GetTopLevelCondition

                                                    func (s *CloudAuditLogsSourceStatus) GetTopLevelCondition() *apis.Condition

                                                      GetTopLevelCondition returns the top level condition.

                                                      func (*CloudAuditLogsSourceStatus) InitializeConditions

                                                      func (s *CloudAuditLogsSourceStatus) InitializeConditions()

                                                        InitializeConditions sets relevant unset conditions to Unknown state.

                                                        func (*CloudAuditLogsSourceStatus) IsReady

                                                        func (s *CloudAuditLogsSourceStatus) IsReady() bool

                                                          IsReady returns true if the resource is ready overall.

                                                          func (*CloudAuditLogsSourceStatus) MarkSinkNotReady

                                                          func (s *CloudAuditLogsSourceStatus) MarkSinkNotReady(reason, messageFormat string, messageA ...interface{})

                                                            MarkSinkNotReady sets the condition that a CloudAuditLogsSource pubsub sink has not been configured and why.

                                                            func (*CloudAuditLogsSourceStatus) MarkSinkReady

                                                            func (s *CloudAuditLogsSourceStatus) MarkSinkReady()

                                                            type CloudBuildSource

                                                            type CloudBuildSource struct {
                                                            	metav1.TypeMeta   `json:",inline"`
                                                            	metav1.ObjectMeta `json:"metadata,omitempty"`
                                                            
                                                            	Spec   CloudBuildSourceSpec   `json:"spec,omitempty"`
                                                            	Status CloudBuildSourceStatus `json:"status,omitempty"`
                                                            }

                                                              CloudBuildSource is a specification for a CloudBuildSource resource. +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

                                                              func (*CloudBuildSource) CheckImmutableFields

                                                              func (current *CloudBuildSource) CheckImmutableFields(ctx context.Context, original *CloudBuildSource) *apis.FieldError

                                                              func (*CloudBuildSource) ConditionSet

                                                              func (bs *CloudBuildSource) ConditionSet() *apis.ConditionSet

                                                                ConditionSet returns the apis.ConditionSet of the embedding object.

                                                                func (*CloudBuildSource) ConvertFrom

                                                                func (sink *CloudBuildSource) ConvertFrom(ctx context.Context, from apis.Convertible) error

                                                                  ConvertFrom implements apis.Convertible. Converts obj from v1alpha1.CloudBuildSource into v1beta1.CloudBuildSource.

                                                                  func (*CloudBuildSource) ConvertTo

                                                                  func (source *CloudBuildSource) ConvertTo(ctx context.Context, to apis.Convertible) error

                                                                    ConvertTo implements apis.Convertible. Converts source (from v1beta1.CloudBuildSource) into v1alpha1.CloudBuildSource.

                                                                    func (*CloudBuildSource) DeepCopy

                                                                    func (in *CloudBuildSource) DeepCopy() *CloudBuildSource

                                                                      DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudBuildSource.

                                                                      func (*CloudBuildSource) DeepCopyInto

                                                                      func (in *CloudBuildSource) DeepCopyInto(out *CloudBuildSource)

                                                                        DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                        func (*CloudBuildSource) DeepCopyObject

                                                                        func (in *CloudBuildSource) DeepCopyObject() runtime.Object

                                                                          DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                          func (*CloudBuildSource) GetGroupVersionKind

                                                                          func (*CloudBuildSource) GetGroupVersionKind() schema.GroupVersionKind

                                                                            Methods for pubsubable interface

                                                                            func (*CloudBuildSource) IdentitySpec

                                                                            func (s *CloudBuildSource) IdentitySpec() *duckv1alpha1.IdentitySpec

                                                                              Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.

                                                                              func (*CloudBuildSource) IdentityStatus

                                                                              func (s *CloudBuildSource) IdentityStatus() *duckv1alpha1.IdentityStatus

                                                                                IdentityStatus returns the IdentityStatus portion of the Status.

                                                                                func (*CloudBuildSource) PubSubSpec

                                                                                func (bs *CloudBuildSource) PubSubSpec() *duckv1alpha1.PubSubSpec

                                                                                  CloudBuildSourceSpec returns the CloudBuildSourceSpec portion of the Spec.

                                                                                  func (*CloudBuildSource) PubSubStatus

                                                                                  func (bs *CloudBuildSource) PubSubStatus() *duckv1alpha1.PubSubStatus

                                                                                    PubSubStatus returns the PubSubStatus portion of the Status.

                                                                                    func (*CloudBuildSource) SetDefaults

                                                                                    func (bs *CloudBuildSource) SetDefaults(ctx context.Context)

                                                                                    func (*CloudBuildSource) Validate

                                                                                    func (current *CloudBuildSource) Validate(ctx context.Context) *apis.FieldError

                                                                                    type CloudBuildSourceList

                                                                                    type CloudBuildSourceList struct {
                                                                                    	metav1.TypeMeta `json:",inline"`
                                                                                    	metav1.ListMeta `json:"metadata,omitempty"`
                                                                                    	Items           []CloudBuildSource `json:"items"`
                                                                                    }

                                                                                      CloudBuildSourceList contains a list of CloudBuildSources.

                                                                                      func (*CloudBuildSourceList) DeepCopy

                                                                                        DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudBuildSourceList.

                                                                                        func (*CloudBuildSourceList) DeepCopyInto

                                                                                        func (in *CloudBuildSourceList) DeepCopyInto(out *CloudBuildSourceList)

                                                                                          DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                          func (*CloudBuildSourceList) DeepCopyObject

                                                                                          func (in *CloudBuildSourceList) DeepCopyObject() runtime.Object

                                                                                            DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                            type CloudBuildSourceSpec

                                                                                            type CloudBuildSourceSpec struct {
                                                                                            	// This brings in the PubSub based Source Specs. Includes:
                                                                                            	// Sink, CloudEventOverrides, Secret and Project
                                                                                            	duckv1alpha1.PubSubSpec `json:",inline"`
                                                                                            
                                                                                            	// Topic is the ID of the PubSub Topic to Subscribe to. It must
                                                                                            	// be in the form of the unique identifier within the project, not the
                                                                                            	// entire name. E.g. it must be 'laconia', not
                                                                                            	// 'projects/my-proj/topics/laconia'.
                                                                                            	// It is optional. Defaults to 'cloud-builds' and the topic must be 'cloud-builds'
                                                                                            	// +optional
                                                                                            	Topic *string `json:"topic,omitempty"`
                                                                                            }

                                                                                              CloudBuildSourceSpec defines the desired state of the CloudBuildSource.

                                                                                              func (*CloudBuildSourceSpec) DeepCopy

                                                                                                DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudBuildSourceSpec.

                                                                                                func (*CloudBuildSourceSpec) DeepCopyInto

                                                                                                func (in *CloudBuildSourceSpec) DeepCopyInto(out *CloudBuildSourceSpec)

                                                                                                  DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                  func (*CloudBuildSourceSpec) SetDefaults

                                                                                                  func (bss *CloudBuildSourceSpec) SetDefaults(ctx context.Context)

                                                                                                  func (*CloudBuildSourceSpec) Validate

                                                                                                  func (current *CloudBuildSourceSpec) Validate(ctx context.Context) *apis.FieldError

                                                                                                  type CloudBuildSourceStatus

                                                                                                  type CloudBuildSourceStatus struct {
                                                                                                  	duckv1alpha1.PubSubStatus `json:",inline"`
                                                                                                  }

                                                                                                    CloudBuildSourceStatus defines the observed state of CloudBuildSource.

                                                                                                    func (*CloudBuildSourceStatus) DeepCopy

                                                                                                      DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudBuildSourceStatus.

                                                                                                      func (*CloudBuildSourceStatus) DeepCopyInto

                                                                                                      func (in *CloudBuildSourceStatus) DeepCopyInto(out *CloudBuildSourceStatus)

                                                                                                        DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                        func (*CloudBuildSourceStatus) GetCondition

                                                                                                          GetCondition returns the condition currently associated with the given type, or nil.

                                                                                                          func (*CloudBuildSourceStatus) GetTopLevelCondition

                                                                                                          func (bs *CloudBuildSourceStatus) GetTopLevelCondition() *apis.Condition

                                                                                                            GetTopLevelCondition returns the top level condition.

                                                                                                            func (*CloudBuildSourceStatus) InitializeConditions

                                                                                                            func (bs *CloudBuildSourceStatus) InitializeConditions()

                                                                                                              InitializeConditions sets relevant unset conditions to Unknown state.

                                                                                                              func (*CloudBuildSourceStatus) IsReady

                                                                                                              func (bs *CloudBuildSourceStatus) IsReady() bool

                                                                                                                IsReady returns true if the resource is ready overall.

                                                                                                                type CloudPubSubSource

                                                                                                                type CloudPubSubSource struct {
                                                                                                                	metav1.TypeMeta   `json:",inline"`
                                                                                                                	metav1.ObjectMeta `json:"metadata,omitempty"`
                                                                                                                
                                                                                                                	Spec   CloudPubSubSourceSpec   `json:"spec,omitempty"`
                                                                                                                	Status CloudPubSubSourceStatus `json:"status,omitempty"`
                                                                                                                }

                                                                                                                  CloudPubSubSource is a specification for a CloudPubSubSource resource. +k8s:openapi-gen=true

                                                                                                                  func (*CloudPubSubSource) CheckImmutableFields

                                                                                                                  func (current *CloudPubSubSource) CheckImmutableFields(ctx context.Context, original *CloudPubSubSource) *apis.FieldError

                                                                                                                  func (*CloudPubSubSource) ConditionSet

                                                                                                                  func (ps *CloudPubSubSource) ConditionSet() *apis.ConditionSet

                                                                                                                    ConditionSet returns the apis.ConditionSet of the embedding object.

                                                                                                                    func (*CloudPubSubSource) ConvertFrom

                                                                                                                    func (sink *CloudPubSubSource) ConvertFrom(ctx context.Context, from apis.Convertible) error

                                                                                                                      ConvertFrom implements apis.Convertible. Converts from a higher version of CloudPubSubSource to a v1alpha1.CloudPubSubSource.

                                                                                                                      func (*CloudPubSubSource) ConvertTo

                                                                                                                      func (source *CloudPubSubSource) ConvertTo(ctx context.Context, to apis.Convertible) error

                                                                                                                        ConvertTo implements apis.Convertible. Converts from a v1alpha1.CloudPubSubSource to a higher version of CloudPubSubSource.

                                                                                                                        func (*CloudPubSubSource) DeepCopy

                                                                                                                        func (in *CloudPubSubSource) DeepCopy() *CloudPubSubSource

                                                                                                                          DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudPubSubSource.

                                                                                                                          func (*CloudPubSubSource) DeepCopyInto

                                                                                                                          func (in *CloudPubSubSource) DeepCopyInto(out *CloudPubSubSource)

                                                                                                                            DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                            func (*CloudPubSubSource) DeepCopyObject

                                                                                                                            func (in *CloudPubSubSource) DeepCopyObject() runtime.Object

                                                                                                                              DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                              func (*CloudPubSubSource) GetGroupVersionKind

                                                                                                                              func (s *CloudPubSubSource) GetGroupVersionKind() schema.GroupVersionKind

                                                                                                                                GetGroupVersionKind returns the GroupVersionKind.

                                                                                                                                func (*CloudPubSubSource) IdentitySpec

                                                                                                                                func (s *CloudPubSubSource) IdentitySpec() *duckv1alpha1.IdentitySpec

                                                                                                                                  Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.

                                                                                                                                  func (*CloudPubSubSource) IdentityStatus

                                                                                                                                  func (s *CloudPubSubSource) IdentityStatus() *duckv1alpha1.IdentityStatus

                                                                                                                                    IdentityStatus returns the IdentityStatus portion of the Status.

                                                                                                                                    func (*CloudPubSubSource) PubSubSpec

                                                                                                                                    func (ps *CloudPubSubSource) PubSubSpec() *duckv1alpha1.PubSubSpec

                                                                                                                                      CloudPubSubSourceSpec returns the CloudPubSubSourceSpec portion of the Spec.

                                                                                                                                      func (*CloudPubSubSource) PubSubStatus

                                                                                                                                      func (s *CloudPubSubSource) PubSubStatus() *duckv1alpha1.PubSubStatus

                                                                                                                                        CloudPubSubSourceSpec returns the CloudPubSubSourceStatus portion of the Spec.

                                                                                                                                        func (*CloudPubSubSource) SetDefaults

                                                                                                                                        func (ps *CloudPubSubSource) SetDefaults(ctx context.Context)

                                                                                                                                        func (*CloudPubSubSource) Validate

                                                                                                                                        func (current *CloudPubSubSource) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                        type CloudPubSubSourceList

                                                                                                                                        type CloudPubSubSourceList struct {
                                                                                                                                        	metav1.TypeMeta `json:",inline"`
                                                                                                                                        	metav1.ListMeta `json:"metadata,omitempty"`
                                                                                                                                        	Items           []CloudPubSubSource `json:"items"`
                                                                                                                                        }

                                                                                                                                          CloudPubSubSourceList contains a list of CloudPubSubSources.

                                                                                                                                          func (*CloudPubSubSourceList) DeepCopy

                                                                                                                                            DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudPubSubSourceList.

                                                                                                                                            func (*CloudPubSubSourceList) DeepCopyInto

                                                                                                                                            func (in *CloudPubSubSourceList) DeepCopyInto(out *CloudPubSubSourceList)

                                                                                                                                              DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                              func (*CloudPubSubSourceList) DeepCopyObject

                                                                                                                                              func (in *CloudPubSubSourceList) DeepCopyObject() runtime.Object

                                                                                                                                                DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                                                type CloudPubSubSourceSpec

                                                                                                                                                type CloudPubSubSourceSpec struct {
                                                                                                                                                	// This brings in the PubSub based Source Specs. Includes:
                                                                                                                                                	// Sink, CloudEventOverrides, Secret and Project
                                                                                                                                                	duckv1alpha1.PubSubSpec `json:",inline"`
                                                                                                                                                
                                                                                                                                                	// Topic is the ID of the PubSub Topic to Subscribe to. It must
                                                                                                                                                	// be in the form of the unique identifier within the project, not the
                                                                                                                                                	// entire name. E.g. it must be 'laconia', not
                                                                                                                                                	// 'projects/my-proj/topics/laconia'.
                                                                                                                                                	Topic string `json:"topic"`
                                                                                                                                                
                                                                                                                                                	// AckDeadline is the default maximum time after a subscriber receives a
                                                                                                                                                	// message before the subscriber should acknowledge the message. Defaults
                                                                                                                                                	// to 30 seconds ('30s').
                                                                                                                                                	// +optional
                                                                                                                                                	AckDeadline *string `json:"ackDeadline,omitempty"`
                                                                                                                                                
                                                                                                                                                	// RetainAckedMessages defines whether to retain acknowledged messages. If
                                                                                                                                                	// true, acknowledged messages will not be expunged until they fall out of
                                                                                                                                                	// the RetentionDuration window.
                                                                                                                                                	RetainAckedMessages bool `json:"retainAckedMessages,omitempty"`
                                                                                                                                                
                                                                                                                                                	// RetentionDuration defines how long to retain messages in backlog, from
                                                                                                                                                	// the time of publish. If RetainAckedMessages is true, this duration
                                                                                                                                                	// affects the retention of acknowledged messages, otherwise only
                                                                                                                                                	// unacknowledged messages are retained. Cannot be longer than 7 days or
                                                                                                                                                	// shorter than 10 minutes. Defaults to 7 days ('7d').
                                                                                                                                                	// +optional
                                                                                                                                                	RetentionDuration *string `json:"retentionDuration,omitempty"`
                                                                                                                                                }

                                                                                                                                                  CloudPubSubSourceSpec defines the desired state of the CloudPubSubSource.

                                                                                                                                                  func (*CloudPubSubSourceSpec) DeepCopy

                                                                                                                                                    DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudPubSubSourceSpec.

                                                                                                                                                    func (*CloudPubSubSourceSpec) DeepCopyInto

                                                                                                                                                    func (in *CloudPubSubSourceSpec) DeepCopyInto(out *CloudPubSubSourceSpec)

                                                                                                                                                      DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                      func (CloudPubSubSourceSpec) GetAckDeadline

                                                                                                                                                      func (ps CloudPubSubSourceSpec) GetAckDeadline() time.Duration

                                                                                                                                                        GetAckDeadline parses AckDeadline and returns the default if an error occurs.

                                                                                                                                                        func (CloudPubSubSourceSpec) GetRetentionDuration

                                                                                                                                                        func (ps CloudPubSubSourceSpec) GetRetentionDuration() time.Duration

                                                                                                                                                          GetRetentionDuration parses RetentionDuration and returns the default if an error occurs.

                                                                                                                                                          func (*CloudPubSubSourceSpec) SetDefaults

                                                                                                                                                          func (pss *CloudPubSubSourceSpec) SetDefaults(ctx context.Context)

                                                                                                                                                          func (*CloudPubSubSourceSpec) Validate

                                                                                                                                                          func (current *CloudPubSubSourceSpec) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                                          type CloudPubSubSourceStatus

                                                                                                                                                          type CloudPubSubSourceStatus struct {
                                                                                                                                                          	// This brings in duck/v1beta1 Status as well as SinkURI
                                                                                                                                                          	duckv1alpha1.PubSubStatus `json:",inline"`
                                                                                                                                                          }

                                                                                                                                                            CloudPubSubSourceStatus defines the observed state of CloudPubSubSource.

                                                                                                                                                            func (*CloudPubSubSourceStatus) DeepCopy

                                                                                                                                                              DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudPubSubSourceStatus.

                                                                                                                                                              func (*CloudPubSubSourceStatus) DeepCopyInto

                                                                                                                                                              func (in *CloudPubSubSourceStatus) DeepCopyInto(out *CloudPubSubSourceStatus)

                                                                                                                                                                DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                func (*CloudPubSubSourceStatus) GetCondition

                                                                                                                                                                  GetCondition returns the condition currently associated with the given type, or nil.

                                                                                                                                                                  func (*CloudPubSubSourceStatus) GetTopLevelCondition

                                                                                                                                                                  func (ps *CloudPubSubSourceStatus) GetTopLevelCondition() *apis.Condition

                                                                                                                                                                    GetTopLevelCondition returns the top level condition.

                                                                                                                                                                    func (*CloudPubSubSourceStatus) InitializeConditions

                                                                                                                                                                    func (ps *CloudPubSubSourceStatus) InitializeConditions()

                                                                                                                                                                      InitializeConditions sets relevant unset conditions to Unknown state.

                                                                                                                                                                      func (*CloudPubSubSourceStatus) IsReady

                                                                                                                                                                      func (ps *CloudPubSubSourceStatus) IsReady() bool

                                                                                                                                                                        IsReady returns true if the resource is ready overall.

                                                                                                                                                                        type CloudSchedulerSource

                                                                                                                                                                        type CloudSchedulerSource struct {
                                                                                                                                                                        	metav1.TypeMeta   `json:",inline"`
                                                                                                                                                                        	metav1.ObjectMeta `json:"metadata,omitempty"`
                                                                                                                                                                        
                                                                                                                                                                        	Spec   CloudSchedulerSourceSpec   `json:"spec"`
                                                                                                                                                                        	Status CloudSchedulerSourceStatus `json:"status"`
                                                                                                                                                                        }

                                                                                                                                                                          CloudSchedulerSource is a specification for a CloudSchedulerSource resource.

                                                                                                                                                                          func (*CloudSchedulerSource) CheckImmutableFields

                                                                                                                                                                          func (current *CloudSchedulerSource) CheckImmutableFields(ctx context.Context, original *CloudSchedulerSource) *apis.FieldError

                                                                                                                                                                          func (*CloudSchedulerSource) ConditionSet

                                                                                                                                                                          func (s *CloudSchedulerSource) ConditionSet() *apis.ConditionSet

                                                                                                                                                                            ConditionSet returns the apis.ConditionSet of the embedding object.

                                                                                                                                                                            func (*CloudSchedulerSource) ConvertFrom

                                                                                                                                                                            func (sink *CloudSchedulerSource) ConvertFrom(ctx context.Context, from apis.Convertible) error

                                                                                                                                                                              ConvertFrom implements apis.Convertible. Converts from a higher version of CloudSchedulerSource to a v1alpha1.CloudSchedulerSource.

                                                                                                                                                                              func (*CloudSchedulerSource) ConvertTo

                                                                                                                                                                              func (source *CloudSchedulerSource) ConvertTo(ctx context.Context, to apis.Convertible) error

                                                                                                                                                                                ConvertTo implements apis.Convertible. Converts from a v1alpha1.CloudSchedulerSource to a higher version of CloudSchedulerSource.

                                                                                                                                                                                func (*CloudSchedulerSource) DeepCopy

                                                                                                                                                                                  DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudSchedulerSource.

                                                                                                                                                                                  func (*CloudSchedulerSource) DeepCopyInto

                                                                                                                                                                                  func (in *CloudSchedulerSource) DeepCopyInto(out *CloudSchedulerSource)

                                                                                                                                                                                    DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                    func (*CloudSchedulerSource) DeepCopyObject

                                                                                                                                                                                    func (in *CloudSchedulerSource) DeepCopyObject() runtime.Object

                                                                                                                                                                                      DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                                                                                      func (*CloudSchedulerSource) GetGroupVersionKind

                                                                                                                                                                                      func (scheduler *CloudSchedulerSource) GetGroupVersionKind() schema.GroupVersionKind

                                                                                                                                                                                      func (*CloudSchedulerSource) IdentitySpec

                                                                                                                                                                                      func (s *CloudSchedulerSource) IdentitySpec() *duckv1alpha1.IdentitySpec

                                                                                                                                                                                        Methods for identifiable interface IdentitySpec returns the IdentitySpec portion of the Spec.

                                                                                                                                                                                        func (*CloudSchedulerSource) IdentityStatus

                                                                                                                                                                                        func (s *CloudSchedulerSource) IdentityStatus() *duckv1alpha1.IdentityStatus

                                                                                                                                                                                          IdentityStatus returns the IdentityStatus portion of the Status.

                                                                                                                                                                                          func (*CloudSchedulerSource) PubSubSpec

                                                                                                                                                                                          func (s *CloudSchedulerSource) PubSubSpec() *duckv1alpha1.PubSubSpec

                                                                                                                                                                                            Methods for pubsubable interface PubSubSpec returns the PubSubSpec portion of the Spec.

                                                                                                                                                                                            func (*CloudSchedulerSource) PubSubStatus

                                                                                                                                                                                            func (s *CloudSchedulerSource) PubSubStatus() *duckv1alpha1.PubSubStatus

                                                                                                                                                                                              PubSubStatus returns the PubSubStatus portion of the Status.

                                                                                                                                                                                              func (*CloudSchedulerSource) SetDefaults

                                                                                                                                                                                              func (s *CloudSchedulerSource) SetDefaults(ctx context.Context)

                                                                                                                                                                                              func (*CloudSchedulerSource) Validate

                                                                                                                                                                                              func (current *CloudSchedulerSource) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                                                                              type CloudSchedulerSourceList

                                                                                                                                                                                              type CloudSchedulerSourceList struct {
                                                                                                                                                                                              	metav1.TypeMeta `json:",inline"`
                                                                                                                                                                                              	metav1.ListMeta `json:"metadata"`
                                                                                                                                                                                              
                                                                                                                                                                                              	Items []CloudSchedulerSource `json:"items"`
                                                                                                                                                                                              }

                                                                                                                                                                                                CloudSchedulerSourceList is a list of CloudSchedulerSource resources.

                                                                                                                                                                                                func (*CloudSchedulerSourceList) DeepCopy

                                                                                                                                                                                                  DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudSchedulerSourceList.

                                                                                                                                                                                                  func (*CloudSchedulerSourceList) DeepCopyInto

                                                                                                                                                                                                  func (in *CloudSchedulerSourceList) DeepCopyInto(out *CloudSchedulerSourceList)

                                                                                                                                                                                                    DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                    func (*CloudSchedulerSourceList) DeepCopyObject

                                                                                                                                                                                                    func (in *CloudSchedulerSourceList) DeepCopyObject() runtime.Object

                                                                                                                                                                                                      DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                                                                                                      type CloudSchedulerSourceSpec

                                                                                                                                                                                                      type CloudSchedulerSourceSpec struct {
                                                                                                                                                                                                      	// This brings in the PubSub based Source Specs. Includes:
                                                                                                                                                                                                      	// Sink, CloudEventOverrides, Secret and Project
                                                                                                                                                                                                      	duckv1alpha1.PubSubSpec `json:",inline"`
                                                                                                                                                                                                      
                                                                                                                                                                                                      	// Location where to create the Job in.
                                                                                                                                                                                                      	Location string `json:"location"`
                                                                                                                                                                                                      
                                                                                                                                                                                                      	// Schedule in cron format, for example: "* * * * *" would be run
                                                                                                                                                                                                      	// every minute.
                                                                                                                                                                                                      	Schedule string `json:"schedule"`
                                                                                                                                                                                                      
                                                                                                                                                                                                      	// What data to send
                                                                                                                                                                                                      	Data string `json:"data"`
                                                                                                                                                                                                      }

                                                                                                                                                                                                        CloudSchedulerSourceSpec is the spec for a CloudSchedulerSource resource.

                                                                                                                                                                                                        func (*CloudSchedulerSourceSpec) DeepCopy

                                                                                                                                                                                                          DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudSchedulerSourceSpec.

                                                                                                                                                                                                          func (*CloudSchedulerSourceSpec) DeepCopyInto

                                                                                                                                                                                                          func (in *CloudSchedulerSourceSpec) DeepCopyInto(out *CloudSchedulerSourceSpec)

                                                                                                                                                                                                            DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                            func (*CloudSchedulerSourceSpec) Validate

                                                                                                                                                                                                            func (current *CloudSchedulerSourceSpec) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                                                                                            type CloudSchedulerSourceStatus

                                                                                                                                                                                                            type CloudSchedulerSourceStatus struct {
                                                                                                                                                                                                            	// This brings in our GCP PubSub based events importers
                                                                                                                                                                                                            	// duck/v1beta1 Status, SinkURI, ProjectID, TopicID and SubscriptionID
                                                                                                                                                                                                            	duckv1alpha1.PubSubStatus `json:",inline"`
                                                                                                                                                                                                            
                                                                                                                                                                                                            	// JobName is the name of the created scheduler Job on success.
                                                                                                                                                                                                            	// +optional
                                                                                                                                                                                                            	JobName string `json:"jobName,omitempty"`
                                                                                                                                                                                                            }

                                                                                                                                                                                                              CloudSchedulerSourceStatus is the status for a CloudSchedulerSource resource.

                                                                                                                                                                                                              func (*CloudSchedulerSourceStatus) DeepCopy

                                                                                                                                                                                                                DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudSchedulerSourceStatus.

                                                                                                                                                                                                                func (*CloudSchedulerSourceStatus) DeepCopyInto

                                                                                                                                                                                                                  DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                                  func (*CloudSchedulerSourceStatus) GetCondition

                                                                                                                                                                                                                    GetCondition returns the condition currently associated with the given type, or nil.

                                                                                                                                                                                                                    func (*CloudSchedulerSourceStatus) GetTopLevelCondition

                                                                                                                                                                                                                    func (s *CloudSchedulerSourceStatus) GetTopLevelCondition() *apis.Condition

                                                                                                                                                                                                                      GetTopLevelCondition returns the top level condition.

                                                                                                                                                                                                                      func (*CloudSchedulerSourceStatus) InitializeConditions

                                                                                                                                                                                                                      func (s *CloudSchedulerSourceStatus) InitializeConditions()

                                                                                                                                                                                                                        InitializeConditions sets relevant unset conditions to Unknown state.

                                                                                                                                                                                                                        func (*CloudSchedulerSourceStatus) IsReady

                                                                                                                                                                                                                        func (s *CloudSchedulerSourceStatus) IsReady() bool

                                                                                                                                                                                                                          IsReady returns true if the resource is ready overall.

                                                                                                                                                                                                                          func (*CloudSchedulerSourceStatus) MarkJobNotReady

                                                                                                                                                                                                                          func (s *CloudSchedulerSourceStatus) MarkJobNotReady(reason, messageFormat string, messageA ...interface{})

                                                                                                                                                                                                                            MarkJobNotReady sets the condition that the CloudSchedulerSource Job has not been successfully created.

                                                                                                                                                                                                                            func (*CloudSchedulerSourceStatus) MarkJobReady

                                                                                                                                                                                                                            func (s *CloudSchedulerSourceStatus) MarkJobReady(jobName string)

                                                                                                                                                                                                                              MarkJobReady sets the condition for CloudSchedulerSource Job as Read and sets the Status.JobName to jobName.

                                                                                                                                                                                                                              type CloudStorageSource

                                                                                                                                                                                                                              type CloudStorageSource struct {
                                                                                                                                                                                                                              	metav1.TypeMeta   `json:",inline"`
                                                                                                                                                                                                                              	metav1.ObjectMeta `json:"metadata,omitempty"`
                                                                                                                                                                                                                              
                                                                                                                                                                                                                              	Spec   CloudStorageSourceSpec   `json:"spec"`
                                                                                                                                                                                                                              	Status CloudStorageSourceStatus `json:"status"`
                                                                                                                                                                                                                              }

                                                                                                                                                                                                                                CloudStorageSource is a specification for a Google Cloud CloudStorageSource Source resource.

                                                                                                                                                                                                                                func (*CloudStorageSource) CheckImmutableFields

                                                                                                                                                                                                                                func (current *CloudStorageSource) CheckImmutableFields(ctx context.Context, original *CloudStorageSource) *apis.FieldError

                                                                                                                                                                                                                                func (*CloudStorageSource) ConditionSet

                                                                                                                                                                                                                                func (s *CloudStorageSource) ConditionSet() *apis.ConditionSet

                                                                                                                                                                                                                                  ConditionSet returns the apis.ConditionSet of the embedding object.

                                                                                                                                                                                                                                  func (*CloudStorageSource) ConvertFrom

                                                                                                                                                                                                                                  func (sink *CloudStorageSource) ConvertFrom(ctx context.Context, from apis.Convertible) error

                                                                                                                                                                                                                                    ConvertFrom implements apis.Convertible. Converts from a higher version into v1alpha1.CloudStorageSource.

                                                                                                                                                                                                                                    func (*CloudStorageSource) ConvertTo

                                                                                                                                                                                                                                    func (source *CloudStorageSource) ConvertTo(ctx context.Context, to apis.Convertible) error

                                                                                                                                                                                                                                      ConvertTo implements apis.Convertible. Converts from v1alpha1.CloudStorageSource into a higher version.

                                                                                                                                                                                                                                      func (*CloudStorageSource) DeepCopy

                                                                                                                                                                                                                                      func (in *CloudStorageSource) DeepCopy() *CloudStorageSource

                                                                                                                                                                                                                                        DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageSource.

                                                                                                                                                                                                                                        func (*CloudStorageSource) DeepCopyInto

                                                                                                                                                                                                                                        func (in *CloudStorageSource) DeepCopyInto(out *CloudStorageSource)

                                                                                                                                                                                                                                          DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                                                          func (*CloudStorageSource) DeepCopyObject

                                                                                                                                                                                                                                          func (in *CloudStorageSource) DeepCopyObject() runtime.Object

                                                                                                                                                                                                                                            DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                                                                                                                                            func (*CloudStorageSource) GetGroupVersionKind

                                                                                                                                                                                                                                            func (storage *CloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind

                                                                                                                                                                                                                                            func (*CloudStorageSource) IdentitySpec

                                                                                                                                                                                                                                            func (s *CloudStorageSource) IdentitySpec() *duckv1alpha1.IdentitySpec

                                                                                                                                                                                                                                              Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.

                                                                                                                                                                                                                                              func (*CloudStorageSource) IdentityStatus

                                                                                                                                                                                                                                              func (s *CloudStorageSource) IdentityStatus() *duckv1alpha1.IdentityStatus

                                                                                                                                                                                                                                                IdentityStatus returns the IdentityStatus portion of the Status.

                                                                                                                                                                                                                                                func (*CloudStorageSource) PubSubSpec

                                                                                                                                                                                                                                                func (s *CloudStorageSource) PubSubSpec() *duckv1alpha1.PubSubSpec

                                                                                                                                                                                                                                                  PubSubSpec returns the PubSubSpec portion of the Spec.

                                                                                                                                                                                                                                                  func (*CloudStorageSource) PubSubStatus

                                                                                                                                                                                                                                                  func (s *CloudStorageSource) PubSubStatus() *duckv1alpha1.PubSubStatus

                                                                                                                                                                                                                                                    PubSubStatus returns the PubSubStatus portion of the Status.

                                                                                                                                                                                                                                                    func (*CloudStorageSource) SetDefaults

                                                                                                                                                                                                                                                    func (s *CloudStorageSource) SetDefaults(ctx context.Context)

                                                                                                                                                                                                                                                    func (*CloudStorageSource) Validate

                                                                                                                                                                                                                                                    func (current *CloudStorageSource) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                                                                                                                                    type CloudStorageSourceList

                                                                                                                                                                                                                                                    type CloudStorageSourceList struct {
                                                                                                                                                                                                                                                    	metav1.TypeMeta `json:",inline"`
                                                                                                                                                                                                                                                    	metav1.ListMeta `json:"metadata"`
                                                                                                                                                                                                                                                    
                                                                                                                                                                                                                                                    	Items []CloudStorageSource `json:"items"`
                                                                                                                                                                                                                                                    }

                                                                                                                                                                                                                                                      CloudStorageSourceList is a list of CloudStorageSource resources.

                                                                                                                                                                                                                                                      func (*CloudStorageSourceList) DeepCopy

                                                                                                                                                                                                                                                        DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageSourceList.

                                                                                                                                                                                                                                                        func (*CloudStorageSourceList) DeepCopyInto

                                                                                                                                                                                                                                                        func (in *CloudStorageSourceList) DeepCopyInto(out *CloudStorageSourceList)

                                                                                                                                                                                                                                                          DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                                                                          func (*CloudStorageSourceList) DeepCopyObject

                                                                                                                                                                                                                                                          func (in *CloudStorageSourceList) DeepCopyObject() runtime.Object

                                                                                                                                                                                                                                                            DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

                                                                                                                                                                                                                                                            type CloudStorageSourceSpec

                                                                                                                                                                                                                                                            type CloudStorageSourceSpec struct {
                                                                                                                                                                                                                                                            	// This brings in the PubSub based Source Specs. Includes:
                                                                                                                                                                                                                                                            	// Sink, CloudEventOverrides, Secret and Project
                                                                                                                                                                                                                                                            	duckv1alpha1.PubSubSpec `json:",inline"`
                                                                                                                                                                                                                                                            
                                                                                                                                                                                                                                                            	// Bucket to subscribe to.
                                                                                                                                                                                                                                                            	Bucket string `json:"bucket"`
                                                                                                                                                                                                                                                            
                                                                                                                                                                                                                                                            	// EventTypes to subscribe to. If unspecified, then subscribe to all events.
                                                                                                                                                                                                                                                            	// +optional
                                                                                                                                                                                                                                                            	EventTypes []string `json:"eventTypes,omitempty"`
                                                                                                                                                                                                                                                            
                                                                                                                                                                                                                                                            	// ObjectNamePrefix limits the notifications to objects with this prefix
                                                                                                                                                                                                                                                            	// +optional
                                                                                                                                                                                                                                                            	ObjectNamePrefix string `json:"objectNamePrefix,omitempty"`
                                                                                                                                                                                                                                                            
                                                                                                                                                                                                                                                            	// PayloadFormat specifies the contents of the message payload.
                                                                                                                                                                                                                                                            	// See https://cloud.google.com/storage/docs/pubsub-notifications#payload.
                                                                                                                                                                                                                                                            	// +optional
                                                                                                                                                                                                                                                            	PayloadFormat string `json:"payloadFormat,omitempty"`
                                                                                                                                                                                                                                                            }

                                                                                                                                                                                                                                                              CloudStorageSourceSpec is the spec for a CloudStorageSource resource.

                                                                                                                                                                                                                                                              func (*CloudStorageSourceSpec) DeepCopy

                                                                                                                                                                                                                                                                DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageSourceSpec.

                                                                                                                                                                                                                                                                func (*CloudStorageSourceSpec) DeepCopyInto

                                                                                                                                                                                                                                                                func (in *CloudStorageSourceSpec) DeepCopyInto(out *CloudStorageSourceSpec)

                                                                                                                                                                                                                                                                  DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                                                                                  func (*CloudStorageSourceSpec) SetDefaults

                                                                                                                                                                                                                                                                  func (ss *CloudStorageSourceSpec) SetDefaults(ctx context.Context)

                                                                                                                                                                                                                                                                  func (*CloudStorageSourceSpec) Validate

                                                                                                                                                                                                                                                                  func (current *CloudStorageSourceSpec) Validate(ctx context.Context) *apis.FieldError

                                                                                                                                                                                                                                                                  type CloudStorageSourceStatus

                                                                                                                                                                                                                                                                  type CloudStorageSourceStatus struct {
                                                                                                                                                                                                                                                                  	// This brings in the Status for our GCP PubSub event sources.
                                                                                                                                                                                                                                                                  	// duck/v1beta1 Status, SinkURI, ProjectID, TopicID and SubscriptionID
                                                                                                                                                                                                                                                                  	duckv1alpha1.PubSubStatus `json:",inline"`
                                                                                                                                                                                                                                                                  
                                                                                                                                                                                                                                                                  	// NotificationID is the ID that GCS identifies this notification as.
                                                                                                                                                                                                                                                                  	// +optional
                                                                                                                                                                                                                                                                  	NotificationID string `json:"notificationId,omitempty"`
                                                                                                                                                                                                                                                                  }

                                                                                                                                                                                                                                                                    CloudStorageSourceStatus is the status for a GCS resource.

                                                                                                                                                                                                                                                                    func (*CloudStorageSourceStatus) DeepCopy

                                                                                                                                                                                                                                                                      DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageSourceStatus.

                                                                                                                                                                                                                                                                      func (*CloudStorageSourceStatus) DeepCopyInto

                                                                                                                                                                                                                                                                      func (in *CloudStorageSourceStatus) DeepCopyInto(out *CloudStorageSourceStatus)

                                                                                                                                                                                                                                                                        DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

                                                                                                                                                                                                                                                                        func (*CloudStorageSourceStatus) GetCondition

                                                                                                                                                                                                                                                                          GetCondition returns the condition currently associated with the given type, or nil.

                                                                                                                                                                                                                                                                          func (*CloudStorageSourceStatus) GetTopLevelCondition

                                                                                                                                                                                                                                                                          func (s *CloudStorageSourceStatus) GetTopLevelCondition() *apis.Condition

                                                                                                                                                                                                                                                                            GetTopLevelCondition returns the top level condition.

                                                                                                                                                                                                                                                                            func (*CloudStorageSourceStatus) InitializeConditions

                                                                                                                                                                                                                                                                            func (s *CloudStorageSourceStatus) InitializeConditions()

                                                                                                                                                                                                                                                                              InitializeConditions sets relevant unset conditions to Unknown state.

                                                                                                                                                                                                                                                                              func (*CloudStorageSourceStatus) IsReady

                                                                                                                                                                                                                                                                              func (s *CloudStorageSourceStatus) IsReady() bool

                                                                                                                                                                                                                                                                                IsReady returns true if the resource is ready overall.

                                                                                                                                                                                                                                                                                func (*CloudStorageSourceStatus) MarkNotificationNotReady

                                                                                                                                                                                                                                                                                func (s *CloudStorageSourceStatus) MarkNotificationNotReady(reason, messageFormat string, messageA ...interface{})

                                                                                                                                                                                                                                                                                  MarkNotificationNotReady sets the condition that the GCS has not been configured to send Notifications and why.

                                                                                                                                                                                                                                                                                  func (*CloudStorageSourceStatus) MarkNotificationReady

                                                                                                                                                                                                                                                                                  func (s *CloudStorageSourceStatus) MarkNotificationReady(notificationID string)