v1alpha1

package
v0.12.2 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

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 (
	// CloudEvent types used by CloudSchedulerSource.
	CloudSchedulerSourceExecute = "com.google.cloud.scheduler.job.execute"
	// CloudSchedulerSourceJobName is the Pub/Sub message attribute key with the CloudSchedulerSource's job name.
	CloudSchedulerSourceJobName = "jobName"
	// CloudSchedulerSourceName is the Pub/Sub message attribute key with the CloudSchedulerSource's name.
	CloudSchedulerSourceName = "schedulerName"
)
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 (
	// CloudEvent types used by CloudStorageSource.
	CloudStorageSourceFinalize       = "com.google.cloud.storage.object.finalize"
	CloudStorageSourceArchive        = "com.google.cloud.storage.object.archive"
	CloudStorageSourceDelete         = "com.google.cloud.storage.object.delete"
	CloudStorageSourceMetadataUpdate = "com.google.cloud.storage.object.metadataUpdate"
)
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 (
	CloudAuditLogsSourceEvent = "com.google.cloud.auditlog.event"
)
View Source
const (
	// CloudPubSubSourceConditionReady has status True when the CloudPubSubSource is
	// ready to send events.
	CloudPubSubSourceConditionReady = apis.ConditionReady
)
View Source
const (
	// CloudPubSubSource CloudEvent type
	CloudPubSubSourcePublish = "com.google.cloud.pubsub.topic.publish"
)
View Source
const (
	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 CloudAuditLogsSourceEventID added in v0.12.0

func CloudAuditLogsSourceEventID(id, logName, timestamp string) string

CloudAuditLogsSourceEventID returns the Cloud Audit Logs CloudEvent id value.

func CloudAuditLogsSourceEventSource added in v0.12.0

func CloudAuditLogsSourceEventSource(serviceName, parentResource string) string

CloudAuditLogsSourceEventSource returns the Cloud Audit Logs CloudEvent source value.

func CloudPubSubSourceEventSource added in v0.12.0

func CloudPubSubSourceEventSource(googleCloudProject, topic string) string

CloudPubSubSourceEventSource returns the Cloud Pub/Sub CloudEvent source value.

func CloudSchedulerSourceEventSource added in v0.12.0

func CloudSchedulerSourceEventSource(parent, scheduler string) string

func CloudStorageSourceEventSource added in v0.12.0

func CloudStorageSourceEventSource(bucket string) string

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 added in v0.12.0

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 added in v0.12.0

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

func (*CloudAuditLogsSource) ConditionSet added in v0.12.0

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

ConditionSet returns the apis.ConditionSet of the embedding object

func (*CloudAuditLogsSource) DeepCopy added in v0.12.0

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

func (*CloudAuditLogsSource) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

func (*CloudAuditLogsSource) GetGroupVersionKind added in v0.12.0

func (*CloudAuditLogsSource) GetGroupVersionKind() schema.GroupVersionKind

func (*CloudAuditLogsSource) PubSubSpec added in v0.12.0

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

PubSubSpec returns the PubSubSpec portion of the Spec.

func (*CloudAuditLogsSource) PubSubStatus added in v0.12.0

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

PubSubStatus returns the PubSubStatus portion of the Status.

func (*CloudAuditLogsSource) SetDefaults added in v0.12.0

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

func (*CloudAuditLogsSource) Validate added in v0.12.0

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

type CloudAuditLogsSourceList added in v0.12.0

type CloudAuditLogsSourceList struct {
	metav1.TypeMeta
	metav1.ListMeta

	Items []CloudAuditLogsSource `json:"items"`
}

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

func (*CloudAuditLogsSourceList) DeepCopy added in v0.12.0

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

func (*CloudAuditLogsSourceList) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

type CloudAuditLogsSourceSpec added in v0.12.0

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 added in v0.12.0

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

func (*CloudAuditLogsSourceSpec) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

type CloudAuditLogsSourceStatus added in v0.12.0

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 added in v0.12.0

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

func (*CloudAuditLogsSourceStatus) DeepCopyInto added in v0.12.0

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

func (*CloudAuditLogsSourceStatus) GetCondition added in v0.12.0

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

func (*CloudAuditLogsSourceStatus) GetTopLevelCondition added in v0.12.0

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

GetTopLevelCondition returns the top level condition.

func (*CloudAuditLogsSourceStatus) InitializeConditions added in v0.12.0

func (s *CloudAuditLogsSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CloudAuditLogsSourceStatus) IsReady added in v0.12.0

func (s *CloudAuditLogsSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*CloudAuditLogsSourceStatus) MarkPullSubscriptionFailed added in v0.12.0

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

MarkPullSubscriptionFailed sets the condition that the status of underlying PullSubscription is False and why.

func (*CloudAuditLogsSourceStatus) MarkPullSubscriptionReady added in v0.12.0

func (s *CloudAuditLogsSourceStatus) MarkPullSubscriptionReady()

MarkPullSubscriptionReady sets the condition that the underlying PullSubscription is ready.

func (*CloudAuditLogsSourceStatus) MarkPullSubscriptionUnknown added in v0.12.0

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

MarkPullSubscriptionUnknown sets the condition that the status of underlying PullSubscription is Unknown and why.

func (*CloudAuditLogsSourceStatus) MarkSinkNotReady added in v0.12.0

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 added in v0.12.0

func (s *CloudAuditLogsSourceStatus) MarkSinkReady()

func (*CloudAuditLogsSourceStatus) MarkTopicFailed added in v0.12.0

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

MarkTopicFailed sets the condition that the status of PubSub topic is False and why.

func (*CloudAuditLogsSourceStatus) MarkTopicReady added in v0.12.0

func (s *CloudAuditLogsSourceStatus) MarkTopicReady()

MarkTopicReady sets the condition that the underlying PubSub topic was created successfully.

func (*CloudAuditLogsSourceStatus) MarkTopicUnknown added in v0.12.0

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

MarkTopicUnknown sets the condition that the status of PubSub topic is Unknown and why.

type CloudPubSubSource added in v0.12.0

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 added in v0.12.0

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

func (*CloudPubSubSource) ConditionSet added in v0.12.0

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

ConditionSet returns the apis.ConditionSet of the embedding object

func (*CloudPubSubSource) DeepCopy added in v0.12.0

func (in *CloudPubSubSource) DeepCopy() *CloudPubSubSource

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

func (*CloudPubSubSource) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

func (*CloudPubSubSource) GetGroupVersionKind added in v0.12.0

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

GetGroupVersionKind returns the GroupVersionKind.

func (*CloudPubSubSource) PubSubSpec added in v0.12.0

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

CloudPubSubSourceSpec returns the CloudPubSubSourceSpec portion of the Spec.

func (*CloudPubSubSource) SetDefaults added in v0.12.0

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

func (*CloudPubSubSource) Validate added in v0.12.0

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

type CloudPubSubSourceList added in v0.12.0

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 added in v0.12.0

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

func (*CloudPubSubSourceList) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

type CloudPubSubSourceSpec added in v0.12.0

type CloudPubSubSourceSpec struct {
	// This brings in the PubSub based Source Specs. Includes:
	// Sink, CloudEventOverrides, Secret, PubSubSecret, 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 added in v0.12.0

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

func (*CloudPubSubSourceSpec) DeepCopyInto added in v0.12.0

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 added in v0.12.0

func (ps CloudPubSubSourceSpec) GetAckDeadline() time.Duration

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

func (CloudPubSubSourceSpec) GetRetentionDuration added in v0.12.0

func (ps CloudPubSubSourceSpec) GetRetentionDuration() time.Duration

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

func (*CloudPubSubSourceSpec) SetDefaults added in v0.12.0

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

func (*CloudPubSubSourceSpec) Validate added in v0.12.0

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

type CloudPubSubSourceStatus added in v0.12.0

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

CloudPubSubSourceStatus defines the observed state of CloudPubSubSource.

func (*CloudPubSubSourceStatus) DeepCopy added in v0.12.0

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

func (*CloudPubSubSourceStatus) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

func (*CloudPubSubSourceStatus) GetTopLevelCondition added in v0.12.0

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

GetTopLevelCondition returns the top level condition.

func (*CloudPubSubSourceStatus) InitializeConditions added in v0.12.0

func (ps *CloudPubSubSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CloudPubSubSourceStatus) IsReady added in v0.12.0

func (ps *CloudPubSubSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*CloudPubSubSourceStatus) MarkPullSubscriptionFailed added in v0.12.0

func (ps *CloudPubSubSourceStatus) MarkPullSubscriptionFailed(reason, messageFormat string, messageA ...interface{})

MarkPullSubscriptionFailed sets the condition that the underlying PullSubscription is False and why.

func (*CloudPubSubSourceStatus) MarkPullSubscriptionNotConfigured added in v0.12.0

func (ps *CloudPubSubSourceStatus) MarkPullSubscriptionNotConfigured()

MarkPullSubscriptionNotConfigured changes the PullSubscriptionReady condition to be unknown to reflect that the PullSubscription does not yet have a Status.

func (*CloudPubSubSourceStatus) MarkPullSubscriptionReady added in v0.12.0

func (ps *CloudPubSubSourceStatus) MarkPullSubscriptionReady()

MarkPullSubscriptionReady sets the condition that the underlying PullSubscription is ready.

func (*CloudPubSubSourceStatus) MarkPullSubscriptionUnknown added in v0.12.0

func (ps *CloudPubSubSourceStatus) MarkPullSubscriptionUnknown(reason, messageFormat string, messageA ...interface{})

MarkPullSubscriptionReady sets the condition that the underlying PullSubscription is Unknown and why.

func (*CloudPubSubSourceStatus) PropagatePullSubscriptionStatus added in v0.12.0

func (ps *CloudPubSubSourceStatus) PropagatePullSubscriptionStatus(pss *v1alpha1.PullSubscriptionStatus)

type CloudSchedulerSource added in v0.12.0

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) ConditionSet added in v0.12.0

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

ConditionSet returns the apis.ConditionSet of the embedding object

func (*CloudSchedulerSource) DeepCopy added in v0.12.0

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

func (*CloudSchedulerSource) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

func (*CloudSchedulerSource) GetGroupVersionKind added in v0.12.0

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

func (*CloudSchedulerSource) PubSubSpec added in v0.12.0

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

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

func (*CloudSchedulerSource) PubSubStatus added in v0.12.0

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

PubSubStatus returns the PubSubStatus portion of the Status.

func (*CloudSchedulerSource) SetDefaults added in v0.12.0

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

func (*CloudSchedulerSource) Validate added in v0.12.0

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

type CloudSchedulerSourceList added in v0.12.0

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 added in v0.12.0

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

func (*CloudSchedulerSourceList) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

type CloudSchedulerSourceSpec added in v0.12.0

type CloudSchedulerSourceSpec struct {
	// This brings in the PubSub based Source Specs. Includes:
	// Sink, CloudEventOverrides, Secret, PubSubSecret, 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 added in v0.12.0

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

func (*CloudSchedulerSourceSpec) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

type CloudSchedulerSourceStatus added in v0.12.0

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 added in v0.12.0

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

func (*CloudSchedulerSourceStatus) DeepCopyInto added in v0.12.0

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

func (*CloudSchedulerSourceStatus) GetCondition added in v0.12.0

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

func (*CloudSchedulerSourceStatus) GetTopLevelCondition added in v0.12.0

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

GetTopLevelCondition returns the top level condition.

func (*CloudSchedulerSourceStatus) InitializeConditions added in v0.12.0

func (s *CloudSchedulerSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CloudSchedulerSourceStatus) IsReady added in v0.12.0

func (s *CloudSchedulerSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*CloudSchedulerSourceStatus) MarkJobNotReady added in v0.12.0

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 added in v0.12.0

func (s *CloudSchedulerSourceStatus) MarkJobReady(jobName string)

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

func (*CloudSchedulerSourceStatus) MarkPullSubscriptionFailed added in v0.12.0

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

MarkPullSubscriptionFailed sets the condition that the underlying PullSubscription is False and why.

func (*CloudSchedulerSourceStatus) MarkPullSubscriptionReady added in v0.12.0

func (s *CloudSchedulerSourceStatus) MarkPullSubscriptionReady()

MarkPullSubscriptionReady sets the condition that the underlying PullSubscription is ready.

func (*CloudSchedulerSourceStatus) MarkPullSubscriptionUnknown added in v0.12.0

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

MarkPullSubscriptionUnknown sets the condition that the underlying PullSubscription is Unknown and why.

func (*CloudSchedulerSourceStatus) MarkTopicFailed added in v0.12.0

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

MarkTopicFailed sets the condition that the Topic was not created and why.

func (*CloudSchedulerSourceStatus) MarkTopicReady added in v0.12.0

func (s *CloudSchedulerSourceStatus) MarkTopicReady(topicID, projectID string)

MarkTopicReady sets the condition that the underlying Topic was created successfully and sets the Status.TopicID to the specified topic and Status.ProjectID to the specified project.

func (*CloudSchedulerSourceStatus) MarkTopicUnknown added in v0.12.0

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

MarkTopicUnknown sets the condition that the status of Topic is Unknown and why.

type CloudStorageSource added in v0.12.0

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) ConditionSet added in v0.12.0

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

ConditionSet returns the apis.ConditionSet of the embedding object

func (*CloudStorageSource) DeepCopy added in v0.12.0

func (in *CloudStorageSource) DeepCopy() *CloudStorageSource

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

func (*CloudStorageSource) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

func (*CloudStorageSource) GetGroupVersionKind added in v0.12.0

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

func (*CloudStorageSource) PubSubSpec added in v0.12.0

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

PubSubSpec returns the PubSubSpec portion of the Spec.

func (*CloudStorageSource) PubSubStatus added in v0.12.0

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

PubSubStatus returns the PubSubStatus portion of the Status.

func (*CloudStorageSource) SetDefaults added in v0.12.0

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

func (*CloudStorageSource) Validate added in v0.12.0

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

type CloudStorageSourceList added in v0.12.0

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 added in v0.12.0

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

func (*CloudStorageSourceList) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

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

type CloudStorageSourceSpec added in v0.12.0

type CloudStorageSourceSpec struct {
	// This brings in the PubSub based Source Specs. Includes:
	// Sink, CloudEventOverrides, Secret, PubSubSecret, and Project
	duckv1alpha1.PubSubSpec `json:",inline"`

	// ServiceAccountName holds the name of the Kubernetes service account
	// as which the underlying K8s resources should be run. If unspecified
	// this will default to the "default" service account for the namespace
	// in which the GCS exists.
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// 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 added in v0.12.0

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

func (*CloudStorageSourceSpec) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

func (*CloudStorageSourceSpec) Validate added in v0.12.0

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

type CloudStorageSourceStatus added in v0.12.0

type CloudStorageSourceStatus struct {
	// This brings in our GCP PubSub based events importers
	// 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 added in v0.12.0

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

func (*CloudStorageSourceStatus) DeepCopyInto added in v0.12.0

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 added in v0.12.0

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

func (*CloudStorageSourceStatus) GetTopLevelCondition added in v0.12.0

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

GetTopLevelCondition returns the top level condition.

func (*CloudStorageSourceStatus) InitializeConditions added in v0.12.0

func (s *CloudStorageSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CloudStorageSourceStatus) IsReady added in v0.12.0

func (s *CloudStorageSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*CloudStorageSourceStatus) MarkNotificationNotReady added in v0.12.0

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 added in v0.12.0

func (s *CloudStorageSourceStatus) MarkNotificationReady(notificationID string)

func (*CloudStorageSourceStatus) MarkPullSubscriptionFailed added in v0.12.0

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

MarkPullSubscriptionFailed sets the condition that the status of underlying PullSubscription is False and why.

func (*CloudStorageSourceStatus) MarkPullSubscriptionReady added in v0.12.0

func (s *CloudStorageSourceStatus) MarkPullSubscriptionReady()

MarkPullSubscriptionReady sets the condition that the underlying PullSubscription is ready.

func (*CloudStorageSourceStatus) MarkPullSubscriptionUnknown added in v0.12.0

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

MarkPullSubscriptionUnknown sets the condition that the status of underlying PullSubscription is Unknown and why.

func (*CloudStorageSourceStatus) MarkTopicFailed added in v0.12.0

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

MarkTopicFailed sets the condition that the status of PubSub topic is False why.

func (*CloudStorageSourceStatus) MarkTopicReady added in v0.12.0

func (s *CloudStorageSourceStatus) MarkTopicReady()

MarkTopicReady sets the condition that the underlying PubSub topic was created successfully.

func (*CloudStorageSourceStatus) MarkTopicUnknown added in v0.12.0

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

MarkTopicUnknown sets the condition that the status of PubSub topic is Unknown why.

Jump to

Keyboard shortcuts

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