v1beta1

package
v0.18.1 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2020 License: Apache-2.0 Imports: 25 Imported by: 22

Documentation

Overview

Package v1beta1 contains API Schema definitions for the events v1beta1 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 (
	// CloudSchedulerSourceJobName is the Pub/Sub message attribute key with the CloudSchedulerSource's job name.
	CloudSchedulerSourceJobName = "jobName"
)
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: "v1beta1"}

SchemeGroupVersion is group version used to register these objects

Functions

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 obj from a higher version of CloudAuditLogsSource to a v1beta1.CloudAuditLogsSource. Currently, we only support v1 as a higher version.

func (*CloudAuditLogsSource) ConvertTo

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

ConvertTo implements apis.Convertible. Converts source (from v1beta1.CloudAuditLogsSource) to a higher version of CloudAuditLogsSource. Currently, we only support v1 as a higher version.

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) GetConditionSet added in v0.16.0

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

func (s *CloudAuditLogsSource) GetStatus() *duckv1.Status

GetStatus retrieves the status of the CloudAuditLogsSource. Implements the KRShaped interface.

func (*CloudAuditLogsSource) IdentitySpec

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

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

func (*CloudAuditLogsSource) IdentityStatus

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

IdentityStatus returns the IdentityStatus portion of the Status.

func (*CloudAuditLogsSource) PubSubSpec

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

PubSubSpec returns the PubSubSpec portion of the Spec.

func (*CloudAuditLogsSource) PubSubStatus

func (s *CloudAuditLogsSource) PubSubStatus() *duckv1beta1.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:
	duckv1beta1.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 {
	duckv1beta1.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 added in v0.16.0

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 +genreconciler +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*CloudBuildSource) CheckImmutableFields added in v0.16.0

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

func (*CloudBuildSource) ConditionSet added in v0.16.0

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

ConditionSet returns the apis.ConditionSet of the embedding object.

func (*CloudBuildSource) ConvertFrom added in v0.16.0

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

ConvertFrom implements apis.Convertible. Converts obj from a higher version of CloudBuildSource to a v1beta1.CloudBuildSource. Currently, we only support v1 as a higher version.

func (*CloudBuildSource) ConvertTo added in v0.16.0

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

ConvertTo implements apis.Convertible. Converts source (from v1beta1.CloudBuildSource) to a higher version of CloudBuildSource. Currently, we only support v1 as a higher version.

func (*CloudBuildSource) DeepCopy added in v0.16.0

func (in *CloudBuildSource) DeepCopy() *CloudBuildSource

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

func (*CloudBuildSource) DeepCopyInto added in v0.16.0

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

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

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

func (*CloudBuildSource) GetConditionSet added in v0.16.0

func (*CloudBuildSource) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.

func (*CloudBuildSource) GetGroupVersionKind added in v0.16.0

func (*CloudBuildSource) GetGroupVersionKind() schema.GroupVersionKind

Methods for pubsubable interface

func (*CloudBuildSource) GetStatus added in v0.16.0

func (s *CloudBuildSource) GetStatus() *duckv1.Status

GetStatus retrieves the status of the CloudBuildSource. Implements the KRShaped interface.

func (*CloudBuildSource) IdentitySpec added in v0.16.0

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

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

func (*CloudBuildSource) IdentityStatus added in v0.16.0

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

IdentityStatus returns the IdentityStatus portion of the Status.

func (*CloudBuildSource) PubSubSpec added in v0.16.0

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

CloudBuildSourceSpec returns the CloudBuildSourceSpec portion of the Spec.

func (*CloudBuildSource) PubSubStatus added in v0.16.0

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

PubSubStatus returns the PubSubStatus portion of the Status.

func (*CloudBuildSource) SetDefaults added in v0.16.0

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

func (*CloudBuildSource) Validate added in v0.16.0

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

type CloudBuildSourceList added in v0.16.0

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

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

func (*CloudBuildSourceList) DeepCopyInto added in v0.16.0

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

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

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

type CloudBuildSourceSpec added in v0.16.0

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

CloudBuildSourceSpec defines the desired state of the CloudBuildSource.

func (*CloudBuildSourceSpec) DeepCopy added in v0.16.0

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

func (*CloudBuildSourceSpec) DeepCopyInto added in v0.16.0

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

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

func (*CloudBuildSourceSpec) Validate added in v0.16.0

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

type CloudBuildSourceStatus added in v0.16.0

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

CloudBuildSourceStatus defines the observed state of CloudBuildSource.

func (*CloudBuildSourceStatus) DeepCopy added in v0.16.0

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

func (*CloudBuildSourceStatus) DeepCopyInto added in v0.16.0

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

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

func (*CloudBuildSourceStatus) GetTopLevelCondition added in v0.16.0

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

GetTopLevelCondition returns the top level condition.

func (*CloudBuildSourceStatus) InitializeConditions added in v0.16.0

func (bs *CloudBuildSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CloudBuildSourceStatus) IsReady added in v0.16.0

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. Currently, we only support v1 as a higher version.

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. Currently, we only support v1 as a higher version.

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

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

func (s *CloudPubSubSource) GetStatus() *duckv1.Status

GetStatus retrieves the status of the CloudPubSubSource. Implements the KRShaped interface.

func (*CloudPubSubSource) IdentitySpec

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

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

func (*CloudPubSubSource) IdentityStatus

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

IdentityStatus returns the IdentityStatus portion of the Status.

func (*CloudPubSubSource) PubSubSpec

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

CloudPubSubSourceSpec returns the CloudPubSubSourceSpec portion of the Spec.

func (*CloudPubSubSource) PubSubStatus

func (s *CloudPubSubSource) PubSubStatus() *duckv1beta1.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
	duckv1beta1.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
	duckv1beta1.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. Currently, we only support v1 as a higher version.

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. Currently, we only support v1 as a higher version.

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) GetConditionSet added in v0.16.0

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

func (s *CloudSchedulerSource) GetStatus() *duckv1.Status

GetStatus retrieves the status of the CloudSchedulerSource. Implements the KRShaped interface.

func (*CloudSchedulerSource) IdentitySpec

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

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

func (*CloudSchedulerSource) IdentityStatus

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

IdentityStatus returns the IdentityStatus portion of the Status.

func (*CloudSchedulerSource) PubSubSpec

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

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

func (*CloudSchedulerSource) PubSubStatus

func (s *CloudSchedulerSource) PubSubStatus() *duckv1beta1.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
	duckv1beta1.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
	duckv1beta1.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 of CloudStorageSource to v1beta1.CloudStorageSource. Currently, we only support v1 as a higher version.

func (*CloudStorageSource) ConvertTo

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

ConvertTo implements apis.Convertible. Converts from v1beta1.CloudStorageSource to a higher version. Currently, we only support v1 as 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) GetConditionSet added in v0.16.0

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

func (s *CloudStorageSource) GetStatus() *duckv1.Status

GetStatus retrieves the status of the CloudStorageSource. Implements the KRShaped interface.

func (*CloudStorageSource) IdentitySpec

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

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

func (*CloudStorageSource) IdentityStatus

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

IdentityStatus returns the IdentityStatus portion of the Status.

func (*CloudStorageSource) PubSubSpec

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

PubSubSpec returns the PubSubSpec portion of the Spec.

func (*CloudStorageSource) PubSubStatus

func (s *CloudStorageSource) PubSubStatus() *duckv1beta1.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
	duckv1beta1.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
	duckv1beta1.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)

Jump to

Keyboard shortcuts

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