Documentation ¶
Overview ¶
Package v1 contains API Schema definitions for the events v1 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
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type CloudAuditLogsSource
- func (current *CloudAuditLogsSource) CheckImmutableFields(ctx context.Context, original *CloudAuditLogsSource) *apis.FieldError
- func (*CloudAuditLogsSource) ConditionSet() *apis.ConditionSet
- func (*CloudAuditLogsSource) ConvertFrom(_ context.Context, from apis.Convertible) error
- func (*CloudAuditLogsSource) ConvertTo(_ context.Context, to apis.Convertible) error
- func (in *CloudAuditLogsSource) DeepCopy() *CloudAuditLogsSource
- func (in *CloudAuditLogsSource) DeepCopyInto(out *CloudAuditLogsSource)
- func (in *CloudAuditLogsSource) DeepCopyObject() runtime.Object
- func (*CloudAuditLogsSource) GetConditionSet() apis.ConditionSet
- func (*CloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *CloudAuditLogsSource) GetStatus() *duckv1.Status
- func (s *CloudAuditLogsSource) IdentitySpec() *gcpduckv1.IdentitySpec
- func (s *CloudAuditLogsSource) IdentityStatus() *gcpduckv1.IdentityStatus
- func (s *CloudAuditLogsSource) PubSubSpec() *gcpduckv1.PubSubSpec
- func (s *CloudAuditLogsSource) PubSubStatus() *gcpduckv1.PubSubStatus
- func (s *CloudAuditLogsSource) SetDefaults(ctx context.Context)
- func (current *CloudAuditLogsSource) Validate(ctx context.Context) *apis.FieldError
- type CloudAuditLogsSourceList
- type CloudAuditLogsSourceSpec
- type CloudAuditLogsSourceStatus
- func (in *CloudAuditLogsSourceStatus) DeepCopy() *CloudAuditLogsSourceStatus
- func (in *CloudAuditLogsSourceStatus) DeepCopyInto(out *CloudAuditLogsSourceStatus)
- func (s *CloudAuditLogsSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *CloudAuditLogsSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *CloudAuditLogsSourceStatus) InitializeConditions()
- func (s *CloudAuditLogsSourceStatus) IsReady() bool
- func (s *CloudAuditLogsSourceStatus) MarkSinkNotReady(reason, messageFormat string, messageA ...interface{})
- func (s *CloudAuditLogsSourceStatus) MarkSinkReady()
- func (s *CloudAuditLogsSourceStatus) MarkSinkUnknown(reason, messageFormat string, messageA ...interface{})
- type CloudPubSubSource
- func (current *CloudPubSubSource) CheckImmutableFields(ctx context.Context, original *CloudPubSubSource) *apis.FieldError
- func (ps *CloudPubSubSource) ConditionSet() *apis.ConditionSet
- func (*CloudPubSubSource) ConvertFrom(_ context.Context, from apis.Convertible) error
- func (*CloudPubSubSource) ConvertTo(_ context.Context, to apis.Convertible) error
- func (in *CloudPubSubSource) DeepCopy() *CloudPubSubSource
- func (in *CloudPubSubSource) DeepCopyInto(out *CloudPubSubSource)
- func (in *CloudPubSubSource) DeepCopyObject() runtime.Object
- func (*CloudPubSubSource) GetConditionSet() apis.ConditionSet
- func (s *CloudPubSubSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *CloudPubSubSource) GetStatus() *duckv1.Status
- func (s *CloudPubSubSource) IdentitySpec() *gcpduckv1.IdentitySpec
- func (s *CloudPubSubSource) IdentityStatus() *gcpduckv1.IdentityStatus
- func (ps *CloudPubSubSource) PubSubSpec() *gcpduckv1.PubSubSpec
- func (s *CloudPubSubSource) PubSubStatus() *gcpduckv1.PubSubStatus
- func (ps *CloudPubSubSource) SetDefaults(ctx context.Context)
- func (current *CloudPubSubSource) Validate(ctx context.Context) *apis.FieldError
- type CloudPubSubSourceList
- type CloudPubSubSourceSpec
- func (in *CloudPubSubSourceSpec) DeepCopy() *CloudPubSubSourceSpec
- func (in *CloudPubSubSourceSpec) DeepCopyInto(out *CloudPubSubSourceSpec)
- func (ps CloudPubSubSourceSpec) GetAckDeadline() time.Duration
- func (ps CloudPubSubSourceSpec) GetRetentionDuration() time.Duration
- func (pss *CloudPubSubSourceSpec) SetDefaults(ctx context.Context)
- func (current *CloudPubSubSourceSpec) Validate(ctx context.Context) *apis.FieldError
- type CloudPubSubSourceStatus
- func (in *CloudPubSubSourceStatus) DeepCopy() *CloudPubSubSourceStatus
- func (in *CloudPubSubSourceStatus) DeepCopyInto(out *CloudPubSubSourceStatus)
- func (ps *CloudPubSubSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (ps *CloudPubSubSourceStatus) GetTopLevelCondition() *apis.Condition
- func (ps *CloudPubSubSourceStatus) InitializeConditions()
- func (ps *CloudPubSubSourceStatus) IsReady() bool
- type CloudSchedulerSource
- func (current *CloudSchedulerSource) CheckImmutableFields(ctx context.Context, original *CloudSchedulerSource) *apis.FieldError
- func (s *CloudSchedulerSource) ConditionSet() *apis.ConditionSet
- func (*CloudSchedulerSource) ConvertFrom(_ context.Context, from apis.Convertible) error
- func (*CloudSchedulerSource) ConvertTo(_ context.Context, to apis.Convertible) error
- func (in *CloudSchedulerSource) DeepCopy() *CloudSchedulerSource
- func (in *CloudSchedulerSource) DeepCopyInto(out *CloudSchedulerSource)
- func (in *CloudSchedulerSource) DeepCopyObject() runtime.Object
- func (*CloudSchedulerSource) GetConditionSet() apis.ConditionSet
- func (scheduler *CloudSchedulerSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *CloudSchedulerSource) GetStatus() *duckv1.Status
- func (s *CloudSchedulerSource) IdentitySpec() *gcpduckv1.IdentitySpec
- func (s *CloudSchedulerSource) IdentityStatus() *gcpduckv1.IdentityStatus
- func (s *CloudSchedulerSource) PubSubSpec() *gcpduckv1.PubSubSpec
- func (s *CloudSchedulerSource) PubSubStatus() *gcpduckv1.PubSubStatus
- func (s *CloudSchedulerSource) SetDefaults(ctx context.Context)
- func (current *CloudSchedulerSource) Validate(ctx context.Context) *apis.FieldError
- type CloudSchedulerSourceList
- type CloudSchedulerSourceSpec
- type CloudSchedulerSourceStatus
- func (in *CloudSchedulerSourceStatus) DeepCopy() *CloudSchedulerSourceStatus
- func (in *CloudSchedulerSourceStatus) DeepCopyInto(out *CloudSchedulerSourceStatus)
- func (s *CloudSchedulerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *CloudSchedulerSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *CloudSchedulerSourceStatus) InitializeConditions()
- func (s *CloudSchedulerSourceStatus) IsReady() bool
- func (s *CloudSchedulerSourceStatus) MarkJobNotReady(reason, messageFormat string, messageA ...interface{})
- func (s *CloudSchedulerSourceStatus) MarkJobReady(jobName string)
- func (s *CloudSchedulerSourceStatus) MarkJobUnknown(reason, messageFormat string, messageA ...interface{})
- type CloudStorageSource
- func (current *CloudStorageSource) CheckImmutableFields(ctx context.Context, original *CloudStorageSource) *apis.FieldError
- func (s *CloudStorageSource) ConditionSet() *apis.ConditionSet
- func (*CloudStorageSource) ConvertFrom(_ context.Context, from apis.Convertible) error
- func (*CloudStorageSource) ConvertTo(_ context.Context, to apis.Convertible) error
- func (in *CloudStorageSource) DeepCopy() *CloudStorageSource
- func (in *CloudStorageSource) DeepCopyInto(out *CloudStorageSource)
- func (in *CloudStorageSource) DeepCopyObject() runtime.Object
- func (*CloudStorageSource) GetConditionSet() apis.ConditionSet
- func (storage *CloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *CloudStorageSource) GetStatus() *duckv1.Status
- func (s *CloudStorageSource) IdentitySpec() *gcpduckv1.IdentitySpec
- func (s *CloudStorageSource) IdentityStatus() *gcpduckv1.IdentityStatus
- func (s *CloudStorageSource) PubSubSpec() *gcpduckv1.PubSubSpec
- func (s *CloudStorageSource) PubSubStatus() *gcpduckv1.PubSubStatus
- func (s *CloudStorageSource) SetDefaults(ctx context.Context)
- func (current *CloudStorageSource) Validate(ctx context.Context) *apis.FieldError
- type CloudStorageSourceList
- type CloudStorageSourceSpec
- type CloudStorageSourceStatus
- func (in *CloudStorageSourceStatus) DeepCopy() *CloudStorageSourceStatus
- func (in *CloudStorageSourceStatus) DeepCopyInto(out *CloudStorageSourceStatus)
- func (s *CloudStorageSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *CloudStorageSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *CloudStorageSourceStatus) InitializeConditions()
- func (s *CloudStorageSourceStatus) IsReady() bool
- func (s *CloudStorageSourceStatus) MarkNotificationNotReady(reason, messageFormat string, messageA ...interface{})
- func (s *CloudStorageSourceStatus) MarkNotificationReady(notificationID string)
- func (s *CloudStorageSourceStatus) MarkNotificationUnknown(reason, messageFormat string, messageA ...interface{})
Constants ¶
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" )
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" )
const ( // CloudPubSubSourceConditionReady has status True when the CloudPubSubSource is // ready to send events. CloudPubSubSourceConditionReady = apis.ConditionReady )
const (
// CloudSchedulerSourceJobName is the Pub/Sub message attribute key with the CloudSchedulerSource's job name.
CloudSchedulerSourceJobName = "jobName"
)
const ( // SinkReady has status True when CloudAuditLogsSource sink is ready. SinkReady apis.ConditionType = "SinkReady" )
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: events.GroupName, Version: "v1"}
SchemeGroupVersion is group version used to register these objects
Functions ¶
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 (*CloudAuditLogsSource) ConvertFrom(_ context.Context, from apis.Convertible) error
ConvertFrom implements apis.Convertible.
func (*CloudAuditLogsSource) ConvertTo ¶
func (*CloudAuditLogsSource) ConvertTo(_ context.Context, to apis.Convertible) error
ConvertTo implements apis.Convertible.
func (*CloudAuditLogsSource) DeepCopy ¶
func (in *CloudAuditLogsSource) DeepCopy() *CloudAuditLogsSource
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) GetConditionSet ¶
func (*CloudAuditLogsSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*CloudAuditLogsSource) GetGroupVersionKind ¶
func (*CloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind
func (*CloudAuditLogsSource) GetStatus ¶
func (s *CloudAuditLogsSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the CloudAuditLogsSource. Implements the KRShaped interface.
func (*CloudAuditLogsSource) IdentitySpec ¶
func (s *CloudAuditLogsSource) IdentitySpec() *gcpduckv1.IdentitySpec
Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.
func (*CloudAuditLogsSource) IdentityStatus ¶
func (s *CloudAuditLogsSource) IdentityStatus() *gcpduckv1.IdentityStatus
IdentityStatus returns the IdentityStatus portion of the Status.
func (*CloudAuditLogsSource) PubSubSpec ¶
func (s *CloudAuditLogsSource) PubSubSpec() *gcpduckv1.PubSubSpec
PubSubSpec returns the PubSubSpec portion of the Spec.
func (*CloudAuditLogsSource) PubSubStatus ¶
func (s *CloudAuditLogsSource) PubSubStatus() *gcpduckv1.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 ¶
func (in *CloudAuditLogsSourceList) DeepCopy() *CloudAuditLogsSourceList
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: gcpduckv1.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 ¶
func (in *CloudAuditLogsSourceSpec) DeepCopy() *CloudAuditLogsSourceSpec
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 { gcpduckv1.PubSubStatus `json:",inline"` // ID of the Stackdriver sink used to publish audit log messages. StackdriverSink string `json:"stackdriverSink,omitempty"` }
func (*CloudAuditLogsSourceStatus) DeepCopy ¶
func (in *CloudAuditLogsSourceStatus) DeepCopy() *CloudAuditLogsSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudAuditLogsSourceStatus.
func (*CloudAuditLogsSourceStatus) DeepCopyInto ¶
func (in *CloudAuditLogsSourceStatus) DeepCopyInto(out *CloudAuditLogsSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CloudAuditLogsSourceStatus) GetCondition ¶
func (s *CloudAuditLogsSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
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()
func (*CloudAuditLogsSourceStatus) MarkSinkUnknown ¶
func (s *CloudAuditLogsSourceStatus) MarkSinkUnknown(reason, messageFormat string, messageA ...interface{})
MarkSinkUnknown sets the condition that a CloudAuditLogsSource pubsub sink status is unknown and why.
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 (*CloudPubSubSource) ConvertFrom(_ context.Context, from apis.Convertible) error
ConvertFrom implements apis.Convertible.
func (*CloudPubSubSource) ConvertTo ¶
func (*CloudPubSubSource) ConvertTo(_ context.Context, to apis.Convertible) error
ConvertTo implements apis.Convertible.
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) GetConditionSet ¶
func (*CloudPubSubSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*CloudPubSubSource) GetGroupVersionKind ¶
func (s *CloudPubSubSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*CloudPubSubSource) GetStatus ¶
func (s *CloudPubSubSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the CloudPubSubSource. Implements the KRShaped interface.
func (*CloudPubSubSource) IdentitySpec ¶
func (s *CloudPubSubSource) IdentitySpec() *gcpduckv1.IdentitySpec
Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.
func (*CloudPubSubSource) IdentityStatus ¶
func (s *CloudPubSubSource) IdentityStatus() *gcpduckv1.IdentityStatus
IdentityStatus returns the IdentityStatus portion of the Status.
func (*CloudPubSubSource) PubSubSpec ¶
func (ps *CloudPubSubSource) PubSubSpec() *gcpduckv1.PubSubSpec
CloudPubSubSourceSpec returns the CloudPubSubSourceSpec portion of the Spec.
func (*CloudPubSubSource) PubSubStatus ¶
func (s *CloudPubSubSource) PubSubStatus() *gcpduckv1.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 ¶
func (in *CloudPubSubSourceList) DeepCopy() *CloudPubSubSourceList
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 gcpduckv1.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 ¶
func (in *CloudPubSubSourceSpec) DeepCopy() *CloudPubSubSourceSpec
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/v1 Status as well as SinkURI gcpduckv1.PubSubStatus `json:",inline"` }
CloudPubSubSourceStatus defines the observed state of CloudPubSubSource.
func (*CloudPubSubSourceStatus) DeepCopy ¶
func (in *CloudPubSubSourceStatus) DeepCopy() *CloudPubSubSourceStatus
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 ¶
func (ps *CloudPubSubSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
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 (*CloudSchedulerSource) ConvertFrom(_ context.Context, from apis.Convertible) error
ConvertFrom implements apis.Convertible.
func (*CloudSchedulerSource) ConvertTo ¶
func (*CloudSchedulerSource) ConvertTo(_ context.Context, to apis.Convertible) error
ConvertTo implements apis.Convertible.
func (*CloudSchedulerSource) DeepCopy ¶
func (in *CloudSchedulerSource) DeepCopy() *CloudSchedulerSource
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) GetConditionSet ¶
func (*CloudSchedulerSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*CloudSchedulerSource) GetGroupVersionKind ¶
func (scheduler *CloudSchedulerSource) GetGroupVersionKind() schema.GroupVersionKind
func (*CloudSchedulerSource) GetStatus ¶
func (s *CloudSchedulerSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the CloudSchedulerSource. Implements the KRShaped interface.
func (*CloudSchedulerSource) IdentitySpec ¶
func (s *CloudSchedulerSource) IdentitySpec() *gcpduckv1.IdentitySpec
Methods for identifiable interface IdentitySpec returns the IdentitySpec portion of the Spec.
func (*CloudSchedulerSource) IdentityStatus ¶
func (s *CloudSchedulerSource) IdentityStatus() *gcpduckv1.IdentityStatus
IdentityStatus returns the IdentityStatus portion of the Status.
func (*CloudSchedulerSource) PubSubSpec ¶
func (s *CloudSchedulerSource) PubSubSpec() *gcpduckv1.PubSubSpec
Methods for pubsubable interface PubSubSpec returns the PubSubSpec portion of the Spec.
func (*CloudSchedulerSource) PubSubStatus ¶
func (s *CloudSchedulerSource) PubSubStatus() *gcpduckv1.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 ¶
func (in *CloudSchedulerSourceList) DeepCopy() *CloudSchedulerSourceList
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 gcpduckv1.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 ¶
func (in *CloudSchedulerSourceSpec) DeepCopy() *CloudSchedulerSourceSpec
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/v1 Status, SinkURI, ProjectID, TopicID and SubscriptionID gcpduckv1.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 ¶
func (in *CloudSchedulerSourceStatus) DeepCopy() *CloudSchedulerSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudSchedulerSourceStatus.
func (*CloudSchedulerSourceStatus) DeepCopyInto ¶
func (in *CloudSchedulerSourceStatus) DeepCopyInto(out *CloudSchedulerSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CloudSchedulerSourceStatus) GetCondition ¶
func (s *CloudSchedulerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
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.
func (*CloudSchedulerSourceStatus) MarkJobUnknown ¶
func (s *CloudSchedulerSourceStatus) MarkJobUnknown(reason, messageFormat string, messageA ...interface{})
MarkJobNotUnknown sets the condition that the status of CloudSchedulerSource Job is unknown.
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 (*CloudStorageSource) ConvertFrom(_ context.Context, from apis.Convertible) error
ConvertFrom implements apis.Convertible.
func (*CloudStorageSource) ConvertTo ¶
func (*CloudStorageSource) ConvertTo(_ context.Context, to apis.Convertible) error
ConvertTo implements apis.Convertible.
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) GetConditionSet ¶
func (*CloudStorageSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*CloudStorageSource) GetGroupVersionKind ¶
func (storage *CloudStorageSource) GetGroupVersionKind() schema.GroupVersionKind
func (*CloudStorageSource) GetStatus ¶
func (s *CloudStorageSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the CloudStorageSource. Implements the KRShaped interface.
func (*CloudStorageSource) IdentitySpec ¶
func (s *CloudStorageSource) IdentitySpec() *gcpduckv1.IdentitySpec
Methods for identifiable interface. IdentitySpec returns the IdentitySpec portion of the Spec.
func (*CloudStorageSource) IdentityStatus ¶
func (s *CloudStorageSource) IdentityStatus() *gcpduckv1.IdentityStatus
IdentityStatus returns the IdentityStatus portion of the Status.
func (*CloudStorageSource) PubSubSpec ¶
func (s *CloudStorageSource) PubSubSpec() *gcpduckv1.PubSubSpec
PubSubSpec returns the PubSubSpec portion of the Spec.
func (*CloudStorageSource) PubSubStatus ¶
func (s *CloudStorageSource) PubSubStatus() *gcpduckv1.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 ¶
func (in *CloudStorageSourceList) DeepCopy() *CloudStorageSourceList
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 gcpduckv1.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"` }
CloudStorageSourceSpec is the spec for a CloudStorageSource resource.
func (*CloudStorageSourceSpec) DeepCopy ¶
func (in *CloudStorageSourceSpec) DeepCopy() *CloudStorageSourceSpec
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/v1 Status, SinkURI, ProjectID, TopicID and SubscriptionID gcpduckv1.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 ¶
func (in *CloudStorageSourceStatus) DeepCopy() *CloudStorageSourceStatus
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 ¶
func (s *CloudStorageSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
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)
func (*CloudStorageSourceStatus) MarkNotificationUnknown ¶
func (s *CloudStorageSourceStatus) MarkNotificationUnknown(reason, messageFormat string, messageA ...interface{})
MarkNotificationNotReady sets the condition that the status of GCS is unknown and why.
Source Files ¶
- cloudauditlogssource_conversion.go
- cloudauditlogssource_defaults.go
- cloudauditlogssource_lifecycle.go
- cloudauditlogssource_types.go
- cloudauditlogssource_validation.go
- cloudpubsubsource_conversion.go
- cloudpubsubsource_defaults.go
- cloudpubsubsource_lifecycle.go
- cloudpubsubsource_types.go
- cloudpubsubsource_validation.go
- cloudschedulersource_conversion.go
- cloudschedulersource_defaults.go
- cloudschedulersource_lifecycle.go
- cloudschedulersource_types.go
- cloudschedulersource_validation.go
- cloudstoragesource_conversion.go
- cloudstoragesource_defaults.go
- cloudstoragesource_lifecycle.go
- cloudstoragesource_types.go
- cloudstoragesource_validation.go
- doc.go
- register.go
- zz_generated.deepcopy.go