v1alpha1

package
v2.18.1 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the eventing v1alpha1 API group +kubebuilder:object:generate=true +groupName=eventing.keda.sh

Index

Constants

View Source 
const (
	// CloudEventSourceConditionActiveReason defines the active condition reason for CloudEventSource
	CloudEventSourceConditionActiveReason = "CloudEventSourceActive"
	// CloudEventSourceConditionFailedReason defines the failed condition reason for CloudEventSource
	CloudEventSourceConditionFailedReason = "CloudEventSourceFailed"
	// CloudEventSourceConditionActiveMessage defines the active condition message for CloudEventSource
	CloudEventSourceConditionActiveMessage = "Is configured to send events to the configured destination"
	// CloudEventSourceConditionFailedMessage defines the failed condition message for CloudEventSource
	CloudEventSourceConditionFailedMessage = "Failed to send events to the configured destination"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "eventing.keda.sh", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var AllEventTypes = []CloudEventType{
	ScaledObjectFailedType, ScaledObjectReadyType, ScaledObjectRemovedType,
	ScaledJobFailedType, ScaledJobReadyType, ScaledJobRemovedType,
}

Functions

func GetCloudEventSourceInitializedConditions 

func GetCloudEventSourceInitializedConditions() *v1alpha1.Conditions

GetCloudEventSourceInitializedConditions returns CloudEventSource Conditions initialized to the default -> Status: Unknown

Types

type AzureEventGridTopicSpec added in v2.14.0 

type AzureEventGridTopicSpec struct {
	Endpoint string `json:"endpoint"`
}

func (*AzureEventGridTopicSpec) DeepCopy added in v2.14.0 

func (in *AzureEventGridTopicSpec) DeepCopy() *AzureEventGridTopicSpec

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

func (*AzureEventGridTopicSpec) DeepCopyInto added in v2.14.0 

func (in *AzureEventGridTopicSpec) DeepCopyInto(out *AzureEventGridTopicSpec)

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

type CloudEventHTTP 

type CloudEventHTTP struct {
	URI string `json:"uri"`
}

func (*CloudEventHTTP) DeepCopy 

func (in *CloudEventHTTP) DeepCopy() *CloudEventHTTP

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

func (*CloudEventHTTP) DeepCopyInto 

func (in *CloudEventHTTP) DeepCopyInto(out *CloudEventHTTP)

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

type CloudEventSource 

type CloudEventSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CloudEventSourceSpec   `json:"spec"`
	Status CloudEventSourceStatus `json:"status,omitempty"`
}

CloudEventSource defines how a KEDA event will be sent to event sink +kubebuilder:resource:path=cloudeventsources,scope=Namespaced +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Active",type="string",JSONPath=".status.conditions[?(@.type==\"Active\")].status"

func (*CloudEventSource) DeepCopy 

func (in *CloudEventSource) DeepCopy() *CloudEventSource

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

func (*CloudEventSource) DeepCopyInto 

func (in *CloudEventSource) DeepCopyInto(out *CloudEventSource)

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

func (*CloudEventSource) DeepCopyObject 

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

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

func (*CloudEventSource) GenerateIdentifier 

func (ces *CloudEventSource) GenerateIdentifier() string

GenerateIdentifier returns identifier for the object in for "kind.namespace.name"

func (*CloudEventSource) GetSpec added in v2.16.0 

func (ces *CloudEventSource) GetSpec() *CloudEventSourceSpec

func (*CloudEventSource) GetStatus added in v2.16.0 

func (ces *CloudEventSource) GetStatus() *CloudEventSourceStatus

func (*CloudEventSource) SetupWebhookWithManager added in v2.14.0 

func (ces *CloudEventSource) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*CloudEventSource) ValidateCreate added in v2.14.0 

func (ces *CloudEventSource) ValidateCreate(_ *bool) (admission.Warnings, error)

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*CloudEventSource) ValidateDelete added in v2.14.0 

func (ces *CloudEventSource) ValidateDelete(_ *bool) (admission.Warnings, error)

func (*CloudEventSource) ValidateUpdate added in v2.14.0 

func (ces *CloudEventSource) ValidateUpdate(old runtime.Object, _ *bool) (admission.Warnings, error)

type CloudEventSourceCustomValidator added in v2.18.0 

type CloudEventSourceCustomValidator struct{}

CloudEventSourceCustomValidator is a custom validator for CloudEventSource objects

func (*CloudEventSourceCustomValidator) DeepCopy added in v2.18.0 

func (in *CloudEventSourceCustomValidator) DeepCopy() *CloudEventSourceCustomValidator

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

func (*CloudEventSourceCustomValidator) DeepCopyInto added in v2.18.0 

func (in *CloudEventSourceCustomValidator) DeepCopyInto(out *CloudEventSourceCustomValidator)

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

func (CloudEventSourceCustomValidator) ValidateCreate added in v2.18.0 

func (cescv CloudEventSourceCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

func (CloudEventSourceCustomValidator) ValidateDelete added in v2.18.0 

func (cescv CloudEventSourceCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

func (CloudEventSourceCustomValidator) ValidateUpdate added in v2.18.0 

func (cescv CloudEventSourceCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (warnings admission.Warnings, err error)

type CloudEventSourceInterface added in v2.16.0 

type CloudEventSourceInterface interface {
	client.Object
	GenerateIdentifier() string
	GetSpec() *CloudEventSourceSpec
	GetStatus() *CloudEventSourceStatus
}

+kubebuilder:object:generate=false

type CloudEventSourceList 

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

CloudEventSourceList is a list of CloudEventSource resources

func (*CloudEventSourceList) DeepCopy 

func (in *CloudEventSourceList) DeepCopy() *CloudEventSourceList

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

func (*CloudEventSourceList) DeepCopyInto 

func (in *CloudEventSourceList) DeepCopyInto(out *CloudEventSourceList)

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

func (*CloudEventSourceList) DeepCopyObject 

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

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

type CloudEventSourceSpec 

type CloudEventSourceSpec struct {
	// +optional
	ClusterName string `json:"clusterName,omitempty"`

	Destination Destination `json:"destination"`

	// +optional
	AuthenticationRef *v1alpha1.AuthenticationRef `json:"authenticationRef,omitempty"`

	// +optional
	EventSubscription EventSubscription `json:"eventSubscription,omitempty"`
}

CloudEventSourceSpec defines the spec of CloudEventSource

func (*CloudEventSourceSpec) DeepCopy 

func (in *CloudEventSourceSpec) DeepCopy() *CloudEventSourceSpec

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

func (*CloudEventSourceSpec) DeepCopyInto 

func (in *CloudEventSourceSpec) DeepCopyInto(out *CloudEventSourceSpec)

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

type CloudEventSourceStatus 

type CloudEventSourceStatus struct {
	// +optional
	Conditions v1alpha1.Conditions `json:"conditions,omitempty"`
}

CloudEventSourceStatus defines the observed state of CloudEventSource +optional

func (*CloudEventSourceStatus) DeepCopy 

func (in *CloudEventSourceStatus) DeepCopy() *CloudEventSourceStatus

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

func (*CloudEventSourceStatus) DeepCopyInto 

func (in *CloudEventSourceStatus) DeepCopyInto(out *CloudEventSourceStatus)

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

type CloudEventType added in v2.14.0 

type CloudEventType string
const (
	// ScaledObjectReadyType is for event when a new ScaledObject is ready
	ScaledObjectReadyType CloudEventType = "keda.scaledobject.ready.v1"

	// ScaledObjectFailedType is for event when creating ScaledObject failed
	ScaledObjectFailedType CloudEventType = "keda.scaledobject.failed.v1"

	// ScaledObjectRemovedType is for event when removed ScaledObject
	ScaledObjectRemovedType CloudEventType = "keda.scaledobject.removed.v1"

	// ScaledJobReadyType is for event when a new ScaledJob is ready
	ScaledJobReadyType CloudEventType = "keda.scaledjob.ready.v1"

	// ScaledJobFailedType is for event when creating ScaledJob failed
	ScaledJobFailedType CloudEventType = "keda.scaledjob.failed.v1"

	// ScaledJobRemovedType is for event when removed ScaledJob
	ScaledJobRemovedType CloudEventType = "keda.scaledjob.removed.v1"

	// TriggerAuthenticationCreatedType is for event when a new TriggerAuthentication is created
	TriggerAuthenticationCreatedType CloudEventType = "keda.authentication.triggerauthentication.created.v1"

	// TriggerAuthenticationUpdatedType is for event when a TriggerAuthentication is updated
	TriggerAuthenticationUpdatedType CloudEventType = "keda.authentication.triggerauthentication.updated.v1"

	// TriggerAuthenticationRemovedType is for event when a TriggerAuthentication is deleted
	TriggerAuthenticationRemovedType CloudEventType = "keda.authentication.triggerauthentication.removed.v1"

	// ClusterTriggerAuthenticationCreatedType is for event when a new ClusterTriggerAuthentication is created
	ClusterTriggerAuthenticationCreatedType CloudEventType = "keda.authentication.clustertriggerauthentication.created.v1"

	// ClusterTriggerAuthenticationCreatedType is for event when a ClusterTriggerAuthentication is updated
	ClusterTriggerAuthenticationUpdatedType CloudEventType = "keda.authentication.clustertriggerauthentication.updated.v1"

	// ClusterTriggerAuthenticationRemovedType is for event when a ClusterTriggerAuthentication is deleted
	ClusterTriggerAuthenticationRemovedType CloudEventType = "keda.authentication.clustertriggerauthentication.removed.v1"
)

type ClusterCloudEventSource added in v2.16.0 

type ClusterCloudEventSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CloudEventSourceSpec   `json:"spec"`
	Status CloudEventSourceStatus `json:"status,omitempty"`
}

+kubebuilder:resource:path=clustercloudeventsources,scope=Cluster +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Active",type="string",JSONPath=".status.conditions[?(@.type==\"Active\")].status"

func (*ClusterCloudEventSource) DeepCopy added in v2.16.0 

func (in *ClusterCloudEventSource) DeepCopy() *ClusterCloudEventSource

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

func (*ClusterCloudEventSource) DeepCopyInto added in v2.16.0 

func (in *ClusterCloudEventSource) DeepCopyInto(out *ClusterCloudEventSource)

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

func (*ClusterCloudEventSource) DeepCopyObject added in v2.16.0 

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

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

func (*ClusterCloudEventSource) GenerateIdentifier added in v2.16.0 

func (cces *ClusterCloudEventSource) GenerateIdentifier() string

GenerateIdentifier returns identifier for the object in for "kind.cluster-scoped.name"

func (*ClusterCloudEventSource) GetSpec added in v2.16.0 

func (cces *ClusterCloudEventSource) GetSpec() *CloudEventSourceSpec

func (*ClusterCloudEventSource) GetStatus added in v2.16.0 

func (cces *ClusterCloudEventSource) GetStatus() *CloudEventSourceStatus

func (*ClusterCloudEventSource) SetupWebhookWithManager added in v2.16.0 

func (cces *ClusterCloudEventSource) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ClusterCloudEventSource) ValidateCreate added in v2.16.0 

func (cces *ClusterCloudEventSource) ValidateCreate(_ *bool) (admission.Warnings, error)

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ClusterCloudEventSource) ValidateDelete added in v2.16.0 

func (cces *ClusterCloudEventSource) ValidateDelete(_ *bool) (admission.Warnings, error)

func (*ClusterCloudEventSource) ValidateUpdate added in v2.16.0 

func (cces *ClusterCloudEventSource) ValidateUpdate(old runtime.Object, _ *bool) (admission.Warnings, error)

type ClusterCloudEventSourceCustomValidator added in v2.18.0 

type ClusterCloudEventSourceCustomValidator struct{}

ClusterCloudEventSourceCustomValidator is a custom validator for ClusterCloudEventSource objects

func (*ClusterCloudEventSourceCustomValidator) DeepCopy added in v2.18.0 

func (in *ClusterCloudEventSourceCustomValidator) DeepCopy() *ClusterCloudEventSourceCustomValidator

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

func (*ClusterCloudEventSourceCustomValidator) DeepCopyInto added in v2.18.0 

func (in *ClusterCloudEventSourceCustomValidator) DeepCopyInto(out *ClusterCloudEventSourceCustomValidator)

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

func (ClusterCloudEventSourceCustomValidator) ValidateCreate added in v2.18.0 

func (ccescv ClusterCloudEventSourceCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

func (ClusterCloudEventSourceCustomValidator) ValidateDelete added in v2.18.0 

func (ccescv ClusterCloudEventSourceCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

func (ClusterCloudEventSourceCustomValidator) ValidateUpdate added in v2.18.0 

func (ccescv ClusterCloudEventSourceCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (warnings admission.Warnings, err error)

type ClusterCloudEventSourceList added in v2.16.0 

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

ClusterCloudEventSourceList is a list of ClusterCloudEventSource resources

func (*ClusterCloudEventSourceList) DeepCopy added in v2.16.0 

func (in *ClusterCloudEventSourceList) DeepCopy() *ClusterCloudEventSourceList

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

func (*ClusterCloudEventSourceList) DeepCopyInto added in v2.16.0 

func (in *ClusterCloudEventSourceList) DeepCopyInto(out *ClusterCloudEventSourceList)

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

func (*ClusterCloudEventSourceList) DeepCopyObject added in v2.16.0 

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

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

type Destination 

type Destination struct {
	// +optional
	HTTP *CloudEventHTTP `json:"http"`

	// +optional
	AzureEventGridTopic *AzureEventGridTopicSpec `json:"azureEventGridTopic"`
}

Destination defines the various ways to emit events

func (*Destination) DeepCopy 

func (in *Destination) DeepCopy() *Destination

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

func (*Destination) DeepCopyInto 

func (in *Destination) DeepCopyInto(out *Destination)

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

type EventSubscription added in v2.14.0 

type EventSubscription struct {
	// +optional
	IncludedEventTypes []CloudEventType `json:"includedEventTypes,omitempty"`

	// +optional
	ExcludedEventTypes []CloudEventType `json:"excludedEventTypes,omitempty"`
}

EventSubscription defines filters for events

func (*EventSubscription) DeepCopy added in v2.14.0 

func (in *EventSubscription) DeepCopy() *EventSubscription

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

func (*EventSubscription) DeepCopyInto added in v2.14.0 

func (in *EventSubscription) DeepCopyInto(out *EventSubscription)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.