v1alpha1

package
v2.4.0 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the camel v1alpha1 API group +kubebuilder:object:generate=true +groupName=camel.apache.org

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 is deprecated: use the v1 API instead Deprecated

Package v1alpha1 contains Camel unstable API Schema definitions Package v1alpha1 is deprecated: use the v1 API instead Deprecated +kubebuilder:object:generate=true +groupName=camel.apache.org

Index

Constants

View Source 
const (
	// ErrorHandlerRefName the reference name to use when looking for an error handler.
	ErrorHandlerRefName = "camel.k.errorHandler.ref"
	// ErrorHandlerRefDefaultName the default name of the error handler.
	ErrorHandlerRefDefaultName = "defaultErrorHandler"
	// ErrorHandlerAppPropertiesPrefix the prefix used for the error handler bean.
	ErrorHandlerAppPropertiesPrefix = "camel.beans.defaultErrorHandler"
)
View Source 
const (
	// KameletBindingKind --.
	KameletBindingKind string = "KameletBinding"

	// KameletBindingPhaseNone --.
	KameletBindingPhaseNone KameletBindingPhase = ""
	// KameletBindingPhaseCreating --.
	KameletBindingPhaseCreating KameletBindingPhase = "Creating"
	// KameletBindingPhaseError --.
	KameletBindingPhaseError KameletBindingPhase = "Error"
	// KameletBindingPhaseReady --.
	KameletBindingPhaseReady KameletBindingPhase = "Ready"
)
View Source 
const (
	// AnnotationIcon label used by icons.
	AnnotationIcon = "camel.apache.org/kamelet.icon"
	// KameletBundledLabel label used by bundling.
	KameletBundledLabel = "camel.apache.org/kamelet.bundled"
	// KameletReadOnlyLabel label used to identify readonly Kamelets.
	KameletReadOnlyLabel = "camel.apache.org/kamelet.readonly"
	// KameletTypeLabel label used to identify Kamelet type.
	KameletTypeLabel = "camel.apache.org/kamelet.type"
	// KameletGroupLabel label used to group Kamelets.
	KameletGroupLabel = "camel.apache.org/kamelet.group"

	// KameletTypeSink type Sink.
	KameletTypeSink = "sink"
	// KameletTypeSource type Source.
	KameletTypeSource = "source"
	// KameletTypeAction type Action.
	KameletTypeAction = "action"
)
View Source 
const (
	// KameletConditionReasonInvalidName --.
	KameletConditionReasonInvalidName string = "InvalidName"
	// KameletConditionReasonInvalidProperty --.
	KameletConditionReasonInvalidProperty string = "InvalidProperty"
	// KameletConditionReasonInvalidTemplate --.
	KameletConditionReasonInvalidTemplate string = "InvalidTemplate"
)
View Source 
const (
	// KameletKind --.
	KameletKind string = "Kamelet"

	// KameletPhaseNone --.
	KameletPhaseNone KameletPhase = ""
	// KameletPhaseReady --.
	KameletPhaseReady KameletPhase = "Ready"
	// KameletPhaseError --.
	KameletPhaseError KameletPhase = "Error"
)

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "camel.apache.org", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	// AddToScheme is a shortcut to SchemeBuilder.AddToScheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (

	// KameletIDProperty used to identify.
	KameletIDProperty = "id"
)

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource.

func ValidKameletName 

func ValidKameletName(name string) bool

func ValidKameletProperties 

func ValidKameletProperties(kamelet *Kamelet) bool

Types

type BeanProperties 

type BeanProperties struct {
	RawMessage `json:",inline,omitempty"`
}

BeanProperties represent an unstructured object properties to be set on a bean.

func (*BeanProperties) DeepCopy 

func (in *BeanProperties) DeepCopy() *BeanProperties

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

func (*BeanProperties) DeepCopyInto 

func (in *BeanProperties) DeepCopyInto(out *BeanProperties)

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

type DataTypeReference 

type DataTypeReference struct {
	// the data type component scheme
	Scheme string `json:"scheme,omitempty"`
	// the data type format name
	Format string `json:"format,omitempty"`
}

DataTypeReference references to the specification of a data type by its scheme and format name.

func (*DataTypeReference) DeepCopy 

func (in *DataTypeReference) DeepCopy() *DataTypeReference

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

func (*DataTypeReference) DeepCopyInto 

func (in *DataTypeReference) DeepCopyInto(out *DataTypeReference)

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

type DataTypeSpec 

type DataTypeSpec struct {
	// the data type component scheme
	Scheme string `json:"scheme,omitempty"`
	// the data type format name
	Format string `json:"format,omitempty"`
	// optional description
	Description string `json:"description,omitempty"`
	// media type as expected for HTTP media types (ie, application/json)
	MediaType string `json:"mediaType,omitempty"`
	// the list of Camel or Maven dependencies required by the data type
	Dependencies []string `json:"dependencies,omitempty"`
	// one to many header specifications
	Headers map[string]HeaderSpec `json:"headers,omitempty"`
	// the expected schema for the data type
	Schema *JSONSchemaProps `json:"schema,omitempty"`
}

DataTypeSpec represents the specification for a data type.

func (*DataTypeSpec) DeepCopy 

func (in *DataTypeSpec) DeepCopy() *DataTypeSpec

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

func (*DataTypeSpec) DeepCopyInto 

func (in *DataTypeSpec) DeepCopyInto(out *DataTypeSpec)

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

type DataTypesSpec 

type DataTypesSpec struct {
	// the default data type for this Kamelet
	Default string `json:"default,omitempty"`
	// one to many data type specifications
	Types map[string]DataTypeSpec `json:"types,omitempty"`
	// one to many header specifications
	Headers map[string]HeaderSpec `json:"headers,omitempty"`
}

DataTypesSpec represents the specification for a set of data types.

func (*DataTypesSpec) DeepCopy 

func (in *DataTypesSpec) DeepCopy() *DataTypesSpec

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

func (*DataTypesSpec) DeepCopyInto 

func (in *DataTypesSpec) DeepCopyInto(out *DataTypesSpec)

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

type Endpoint 

type Endpoint struct {
	// Ref can be used to declare a Kubernetes resource as source/sink endpoint
	Ref *corev1.ObjectReference `json:"ref,omitempty"`
	// URI can be used to specify the (Camel) endpoint explicitly
	URI *string `json:"uri,omitempty"`
	// Properties are a key value representation of endpoint properties
	Properties *EndpointProperties `json:"properties,omitempty"`
	// Types defines the data type of the data produced/consumed by the endpoint and references a given data type specification.
	// Deprecated: In favor of using DataTypes
	Types map[TypeSlot]EventTypeSpec `json:"types,omitempty"`
	// DataTypes defines the data type of the data produced/consumed by the endpoint and references a given data type specification.
	DataTypes map[TypeSlot]DataTypeReference `json:"dataTypes,omitempty"`
}

Endpoint represents a source/sink external entity (could be any Kubernetes resource or Camel URI).

func (*Endpoint) DeepCopy 

func (in *Endpoint) DeepCopy() *Endpoint

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

func (*Endpoint) DeepCopyInto 

func (in *Endpoint) DeepCopyInto(out *Endpoint)

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

type EndpointProperties 

type EndpointProperties struct {
	RawMessage `json:",inline"`
}

EndpointProperties is a key/value struct represented as JSON raw to allow numeric/boolean values.

func (*EndpointProperties) DeepCopy 

func (in *EndpointProperties) DeepCopy() *EndpointProperties

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

func (*EndpointProperties) DeepCopyInto 

func (in *EndpointProperties) DeepCopyInto(out *EndpointProperties)

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

func (*EndpointProperties) GetPropertyMap 

func (p *EndpointProperties) GetPropertyMap() (map[string]string, error)

GetPropertyMap returns the EndpointProperties as map.

type EndpointType 

type EndpointType string

EndpointType represents the type (ie, source or sink). 

const (
	// EndpointTypeSource source endpoint.
	EndpointTypeSource EndpointType = "source"
	// EndpointTypeAction action endpoint.
	EndpointTypeAction EndpointType = "action"
	// EndpointTypeSink sink endpoint.
	EndpointTypeSink EndpointType = "sink"
	// EndpointTypeErrorHandler error handler endpoint.
	EndpointTypeErrorHandler EndpointType = "errorHandler"
)

type ErrorHandler 

type ErrorHandler interface {
	Type() ErrorHandlerType
	Endpoint() *Endpoint
	Configuration() (map[string]interface{}, error)
	Validate() error
}

ErrorHandler is a generic interface that represent any type of error handler specification.

type ErrorHandlerLog 

type ErrorHandlerLog struct {
	ErrorHandlerNone
	Parameters *ErrorHandlerParameters `json:"parameters,omitempty"`
}

ErrorHandlerLog represent a default (log) error handler type.

func (ErrorHandlerLog) Configuration 

func (e ErrorHandlerLog) Configuration() (map[string]interface{}, error)

Configuration --.

func (*ErrorHandlerLog) DeepCopy 

func (in *ErrorHandlerLog) DeepCopy() *ErrorHandlerLog

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

func (*ErrorHandlerLog) DeepCopyInto 

func (in *ErrorHandlerLog) DeepCopyInto(out *ErrorHandlerLog)

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

func (ErrorHandlerLog) Endpoint 

func (e ErrorHandlerLog) Endpoint() *Endpoint

Endpoint --.

func (ErrorHandlerLog) Type 

func (e ErrorHandlerLog) Type() ErrorHandlerType

Type --.

func (ErrorHandlerLog) Validate 

func (e ErrorHandlerLog) Validate() error

Validate --.

type ErrorHandlerNone 

type ErrorHandlerNone struct {
	// contains filtered or unexported fields
}

ErrorHandlerNone --.

func (ErrorHandlerNone) Configuration 

func (e ErrorHandlerNone) Configuration() (map[string]interface{}, error)

Configuration --.

func (*ErrorHandlerNone) DeepCopy 

func (in *ErrorHandlerNone) DeepCopy() *ErrorHandlerNone

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

func (*ErrorHandlerNone) DeepCopyInto 

func (in *ErrorHandlerNone) DeepCopyInto(out *ErrorHandlerNone)

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

func (ErrorHandlerNone) Endpoint 

func (e ErrorHandlerNone) Endpoint() *Endpoint

Endpoint --.

func (ErrorHandlerNone) Type 

func (e ErrorHandlerNone) Type() ErrorHandlerType

Type --.

func (ErrorHandlerNone) Validate 

func (e ErrorHandlerNone) Validate() error

Validate --.

type ErrorHandlerParameters 

type ErrorHandlerParameters struct {
	RawMessage `json:",inline,omitempty"`
}

ErrorHandlerParameters represent an unstructured object for error handler parameters.

func (*ErrorHandlerParameters) DeepCopy 

func (in *ErrorHandlerParameters) DeepCopy() *ErrorHandlerParameters

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

func (*ErrorHandlerParameters) DeepCopyInto 

func (in *ErrorHandlerParameters) DeepCopyInto(out *ErrorHandlerParameters)

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

type ErrorHandlerSink 

type ErrorHandlerSink struct {
	ErrorHandlerLog
	DLCEndpoint *Endpoint `json:"endpoint,omitempty"`
}

ErrorHandlerSink represents a sink error handler type which behave like a dead letter channel.

func (ErrorHandlerSink) Configuration 

func (e ErrorHandlerSink) Configuration() (map[string]interface{}, error)

Configuration --.

func (*ErrorHandlerSink) DeepCopy 

func (in *ErrorHandlerSink) DeepCopy() *ErrorHandlerSink

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

func (*ErrorHandlerSink) DeepCopyInto 

func (in *ErrorHandlerSink) DeepCopyInto(out *ErrorHandlerSink)

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

func (ErrorHandlerSink) Endpoint 

func (e ErrorHandlerSink) Endpoint() *Endpoint

Endpoint --.

func (ErrorHandlerSink) Type 

func (e ErrorHandlerSink) Type() ErrorHandlerType

Type --.

func (ErrorHandlerSink) Validate 

func (e ErrorHandlerSink) Validate() error

Validate --.

type ErrorHandlerSpec 

type ErrorHandlerSpec struct {
	RawMessage `json:",inline,omitempty"`
}

ErrorHandlerSpec represents an unstructured object for an error handler.

func (*ErrorHandlerSpec) DeepCopy 

func (in *ErrorHandlerSpec) DeepCopy() *ErrorHandlerSpec

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

func (*ErrorHandlerSpec) DeepCopyInto 

func (in *ErrorHandlerSpec) DeepCopyInto(out *ErrorHandlerSpec)

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

type ErrorHandlerType 

type ErrorHandlerType string

ErrorHandlerType a type of error handler (ie, sink). 

const (

	// ErrorHandlerTypeNone used to ignore any error event.
	ErrorHandlerTypeNone ErrorHandlerType = "none"
	// ErrorHandlerTypeLog used to log the event producing the error.
	ErrorHandlerTypeLog ErrorHandlerType = "log"
	// ErrorHandlerTypeSink used to send the event to a further sink (for future processing). This was previously known as dead-letter-channel.
	ErrorHandlerTypeSink ErrorHandlerType = "sink"
)

type EventTypeSpec 

type EventTypeSpec struct {
	// media type as expected for HTTP media types (ie, application/json)
	MediaType string `json:"mediaType,omitempty"`
	// the expected schema for the event
	Schema *JSONSchemaProps `json:"schema,omitempty"`
}

EventTypeSpec represents a specification for an event type. Deprecated: In favor of using DataTypeSpec.

func (*EventTypeSpec) DeepCopy 

func (in *EventTypeSpec) DeepCopy() *EventTypeSpec

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

func (*EventTypeSpec) DeepCopyInto 

func (in *EventTypeSpec) DeepCopyInto(out *EventTypeSpec)

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

type ExternalDocumentation 

type ExternalDocumentation struct {
	Description string `json:"description,omitempty"`
	URL         string `json:"url,omitempty"`
}

ExternalDocumentation allows referencing an external resource for extended documentation.

func (*ExternalDocumentation) DeepCopy 

func (in *ExternalDocumentation) DeepCopy() *ExternalDocumentation

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

func (*ExternalDocumentation) DeepCopyInto 

func (in *ExternalDocumentation) DeepCopyInto(out *ExternalDocumentation)

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

type HeaderSpec 

type HeaderSpec struct {
	Type        string `json:"type,omitempty"`
	Title       string `json:"title,omitempty"`
	Description string `json:"description,omitempty"`
	Required    bool   `json:"required,omitempty"`
	Default     string `json:"default,omitempty"`
}

HeaderSpec represents the specification for a header used in the Kamelet.

func (*HeaderSpec) DeepCopy 

func (in *HeaderSpec) DeepCopy() *HeaderSpec

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

func (*HeaderSpec) DeepCopyInto 

func (in *HeaderSpec) DeepCopyInto(out *HeaderSpec)

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

type JSON 

type JSON struct {
	RawMessage `json:",inline"`
}

+kubebuilder:validation:Type="" JSON represents any valid JSON value. These types are supported: bool, int64, float64, string, []interface{}, map[string]interface{} and nil.

func (*JSON) DeepCopy 

func (in *JSON) DeepCopy() *JSON

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

func (*JSON) DeepCopyInto 

func (in *JSON) DeepCopyInto(out *JSON)

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

type JSONSchemaProp 

type JSONSchemaProp struct {
	ID          string `json:"id,omitempty"`
	Deprecated  bool   `json:"deprecated,omitempty"`
	Description string `json:"description,omitempty"`
	Type        string `json:"type,omitempty"`
	// format is an OpenAPI v3 format string. Unknown formats are ignored. The following formats are validated:
	//
	// - bsonobjectid: a bson object ID, i.e. a 24 characters hex string
	// - uri: an URI as parsed by Golang net/url.ParseRequestURI
	// - email: an email address as parsed by Golang net/mail.ParseAddress
	// - hostname: a valid representation for an Internet host name, as defined by RFC 1034, section 3.1 [RFC1034].
	// - ipv4: an IPv4 IP as parsed by Golang net.ParseIP
	// - ipv6: an IPv6 IP as parsed by Golang net.ParseIP
	// - cidr: a CIDR as parsed by Golang net.ParseCIDR
	// - mac: a MAC address as parsed by Golang net.ParseMAC
	// - uuid: an UUID that allows uppercase defined by the regex (?i)^[0-9a-f]{8}-?[0-9a-f]{4}-?[0-9a-f]{4}-?[0-9a-f]{4}-?[0-9a-f]{12}$
	// - uuid3: an UUID3 that allows uppercase defined by the regex (?i)^[0-9a-f]{8}-?[0-9a-f]{4}-?3[0-9a-f]{3}-?[0-9a-f]{4}-?[0-9a-f]{12}$
	// - uuid4: an UUID4 that allows uppercase defined by the regex (?i)^[0-9a-f]{8}-?[0-9a-f]{4}-?4[0-9a-f]{3}-?[89ab][0-9a-f]{3}-?[0-9a-f]{12}$
	// - uuid5: an UUID5 that allows uppercase defined by the regex (?i)^[0-9a-f]{8}-?[0-9a-f]{4}-?5[0-9a-f]{3}-?[89ab][0-9a-f]{3}-?[0-9a-f]{12}$
	// - isbn: an ISBN10 or ISBN13 number string like "0321751043" or "978-0321751041"
	// - isbn10: an ISBN10 number string like "0321751043"
	// - isbn13: an ISBN13 number string like "978-0321751041"
	// - creditcard: a credit card number defined by the regex ^(?:4[0-9]{12}(?:[0-9]{3})?|5[1-5][0-9]{14}|6(?:011|5[0-9][0-9])[0-9]{12}|3[47][0-9]{13}|3(?:0[0-5]|[68][0-9])[0-9]{11}|(?:2131|1800|35\\d{3})\\d{11})$ with any non digit characters mixed in
	// - ssn: a U.S. social security number following the regex ^\\d{3}[- ]?\\d{2}[- ]?\\d{4}$
	// - hexcolor: an hexadecimal color code like "#FFFFFF" following the regex ^#?([0-9a-fA-F]{3}|[0-9a-fA-F]{6})$
	// - rgbcolor: an RGB color code like rgb like "rgb(255,255,255)"
	// - byte: base64 encoded binary data
	// - password: any kind of string
	// - date: a date string like "2006-01-02" as defined by full-date in RFC3339
	// - duration: a duration string like "22 ns" as parsed by Golang time.ParseDuration or compatible with Scala duration format
	// - datetime: a date time string like "2014-12-15T19:30:20.000Z" as defined by date-time in RFC3339.
	Format string `json:"format,omitempty"`
	Title  string `json:"title,omitempty"`
	// default is a default value for undefined object fields.
	Default          *JSON        `json:"default,omitempty"`
	Maximum          *json.Number `json:"maximum,omitempty"`
	ExclusiveMaximum bool         `json:"exclusiveMaximum,omitempty"`
	Minimum          *json.Number `json:"minimum,omitempty"`
	ExclusiveMinimum bool         `json:"exclusiveMinimum,omitempty"`
	MaxLength        *int64       `json:"maxLength,omitempty"`
	MinLength        *int64       `json:"minLength,omitempty"`
	Pattern          string       `json:"pattern,omitempty"`
	MaxItems         *int64       `json:"maxItems,omitempty"`
	MinItems         *int64       `json:"minItems,omitempty"`
	UniqueItems      bool         `json:"uniqueItems,omitempty"`
	MaxProperties    *int64       `json:"maxProperties,omitempty"`
	MinProperties    *int64       `json:"minProperties,omitempty"`
	MultipleOf       *json.Number `json:"multipleOf,omitempty"`
	Enum             []JSON       `json:"enum,omitempty"`
	Example          *JSON        `json:"example,omitempty"`
	Nullable         bool         `json:"nullable,omitempty"`
	// XDescriptors is a list of extended properties that trigger a custom behavior in external systems
	XDescriptors []string `json:"x-descriptors,omitempty"`
}

func (*JSONSchemaProp) DeepCopy 

func (in *JSONSchemaProp) DeepCopy() *JSONSchemaProp

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

func (*JSONSchemaProp) DeepCopyInto 

func (in *JSONSchemaProp) DeepCopyInto(out *JSONSchemaProp)

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

type JSONSchemaProps 

type JSONSchemaProps struct {
	ID           string                    `json:"id,omitempty"`
	Description  string                    `json:"description,omitempty"`
	Title        string                    `json:"title,omitempty"`
	Properties   map[string]JSONSchemaProp `json:"properties,omitempty"`
	Required     []string                  `json:"required,omitempty"`
	Example      *JSON                     `json:"example,omitempty"`
	ExternalDocs *ExternalDocumentation    `json:"externalDocs,omitempty"`
	Schema       JSONSchemaURL             `json:"$schema,omitempty"`
	Type         string                    `json:"type,omitempty"`
}

JSONSchemaProps is a JSON-Schema following Specification Draft 4 (http://json-schema.org/).

func (*JSONSchemaProps) DeepCopy 

func (in *JSONSchemaProps) DeepCopy() *JSONSchemaProps

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

func (*JSONSchemaProps) DeepCopyInto 

func (in *JSONSchemaProps) DeepCopyInto(out *JSONSchemaProps)

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

type JSONSchemaURL 

type JSONSchemaURL string

JSONSchemaURL represents a schema url.

type Kamelet 

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

	// the desired specification.
	Spec KameletSpec `json:"spec,omitempty"`
	// the actual status of the resource.
	Status KameletStatus `json:"status,omitempty"`
}

Kamelet is the Schema for the kamelets API.

func NewKamelet 

func NewKamelet(namespace string, name string) Kamelet

NewKamelet creates a new Kamelet.

func (*Kamelet) DeepCopy 

func (in *Kamelet) DeepCopy() *Kamelet

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

func (*Kamelet) DeepCopyInto 

func (in *Kamelet) DeepCopyInto(out *Kamelet)

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

func (*Kamelet) DeepCopyObject 

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

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

func (*Kamelet) SortedDefinitionPropertiesKeys 

func (k *Kamelet) SortedDefinitionPropertiesKeys() []string

SortedDefinitionPropertiesKeys returns the sorted keys of the Kamelet definition properties.

func (*Kamelet) SortedTypesKeys 

func (k *Kamelet) SortedTypesKeys() []TypeSlot

SortedTypesKeys returns the sorted keys of the Kamelet spec types.

type KameletBinding 

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

	// the specification of a KameletBinding
	Spec KameletBindingSpec `json:"spec,omitempty"`
	// the status of a KameletBinding
	Status KameletBindingStatus `json:"status,omitempty"`
}

KameletBinding is the Schema for the kamelets binding API.

func NewKameletBinding 

func NewKameletBinding(namespace string, name string) KameletBinding

NewKameletBinding --.

func (*KameletBinding) DeepCopy 

func (in *KameletBinding) DeepCopy() *KameletBinding

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

func (*KameletBinding) DeepCopyInto 

func (in *KameletBinding) DeepCopyInto(out *KameletBinding)

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

func (*KameletBinding) DeepCopyObject 

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

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

func (*KameletBinding) SetOperatorID 

func (in *KameletBinding) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation.

type KameletBindingCondition 

type KameletBindingCondition struct {
	// Type of kameletBinding condition.
	Type KameletBindingConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`
	// A human readable message indicating details about the transition.
	Message string `json:"message,omitempty"`
	// Pods collect health and conditions information from the owned PODs
	Pods []v1.PodCondition `json:"pods,omitempty"`
}

KameletBindingCondition describes the state of a resource at a certain point.

func (*KameletBindingCondition) DeepCopy 

func (in *KameletBindingCondition) DeepCopy() *KameletBindingCondition

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

func (*KameletBindingCondition) DeepCopyInto 

func (in *KameletBindingCondition) DeepCopyInto(out *KameletBindingCondition)

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

func (KameletBindingCondition) GetLastTransitionTime 

func (c KameletBindingCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --.

func (KameletBindingCondition) GetLastUpdateTime 

func (c KameletBindingCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --.

func (KameletBindingCondition) GetMessage 

func (c KameletBindingCondition) GetMessage() string

GetMessage --.

func (KameletBindingCondition) GetReason 

func (c KameletBindingCondition) GetReason() string

GetReason --.

func (KameletBindingCondition) GetStatus 

func (c KameletBindingCondition) GetStatus() corev1.ConditionStatus

GetStatus --.

func (KameletBindingCondition) GetType 

func (c KameletBindingCondition) GetType() string

GetType --.

type KameletBindingConditionType 

type KameletBindingConditionType string

KameletBindingConditionType --. 

const (
	// KameletBindingConditionReady --.
	KameletBindingConditionReady KameletBindingConditionType = "Ready"
	// KameletBindingIntegrationConditionError is used to report the error on the generated Integration.
	KameletBindingIntegrationConditionError KameletBindingConditionType = "IntegrationError"
)

type KameletBindingList 

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

KameletBindingList contains a list of KameletBinding.

func NewKameletBindingList 

func NewKameletBindingList() KameletBindingList

NewKameletBindingList --.

func (*KameletBindingList) DeepCopy 

func (in *KameletBindingList) DeepCopy() *KameletBindingList

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

func (*KameletBindingList) DeepCopyInto 

func (in *KameletBindingList) DeepCopyInto(out *KameletBindingList)

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

func (*KameletBindingList) DeepCopyObject 

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

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

type KameletBindingPhase 

type KameletBindingPhase string

KameletBindingPhase --.

type KameletBindingSpec 

type KameletBindingSpec struct {
	// Integration is an optional integration used to specify custom parameters
	Integration *v1.IntegrationSpec `json:"integration,omitempty"`
	// Source is the starting point of the integration defined by this binding
	Source Endpoint `json:"source,omitempty"`
	// Sink is the destination of the integration defined by this binding
	Sink Endpoint `json:"sink,omitempty"`
	// ErrorHandler is an optional handler called upon an error occurring in the integration
	ErrorHandler *ErrorHandlerSpec `json:"errorHandler,omitempty"`
	// Steps contains an optional list of intermediate steps that are executed between the Source and the Sink
	Steps []Endpoint `json:"steps,omitempty"`
	// Replicas is the number of desired replicas for the binding
	Replicas *int32 `json:"replicas,omitempty"`
	// Custom SA to use for the binding
	ServiceAccountName string `json:"serviceAccountName,omitempty"`
}

KameletBindingSpec defines the binding between a source and a sink. It can include custom parameters and additional intermediate steps and error handling.

func (*KameletBindingSpec) DeepCopy 

func (in *KameletBindingSpec) DeepCopy() *KameletBindingSpec

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

func (*KameletBindingSpec) DeepCopyInto 

func (in *KameletBindingSpec) DeepCopyInto(out *KameletBindingSpec)

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

type KameletBindingStatus 

type KameletBindingStatus struct {
	// ObservedGeneration is the most recent generation observed for this KameletBinding.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Phase --
	Phase KameletBindingPhase `json:"phase,omitempty"`
	// Conditions --
	Conditions []KameletBindingCondition `json:"conditions,omitempty"`
	// Replicas is the number of actual replicas of the binding
	Replicas *int32 `json:"replicas,omitempty"`
	// Selector allows to identify pods belonging to the binding
	Selector string `json:"selector,omitempty"`
}

KameletBindingStatus specify the status of a binding.

func (*KameletBindingStatus) DeepCopy 

func (in *KameletBindingStatus) DeepCopy() *KameletBindingStatus

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

func (*KameletBindingStatus) DeepCopyInto 

func (in *KameletBindingStatus) DeepCopyInto(out *KameletBindingStatus)

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

func (*KameletBindingStatus) GetCondition 

func (in *KameletBindingStatus) GetCondition(condType KameletBindingConditionType) *KameletBindingCondition

GetCondition returns the condition with the provided type.

func (*KameletBindingStatus) GetConditions 

func (in *KameletBindingStatus) GetConditions() []v1.ResourceCondition

GetConditions --.

func (*KameletBindingStatus) RemoveCondition 

func (in *KameletBindingStatus) RemoveCondition(condType KameletBindingConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*KameletBindingStatus) SetCondition 

func (in *KameletBindingStatus) SetCondition(condType KameletBindingConditionType, status corev1.ConditionStatus, reason string, message string)

SetCondition --.

func (*KameletBindingStatus) SetConditions 

func (in *KameletBindingStatus) SetConditions(conditions ...KameletBindingCondition)

SetConditions updates the resource to include the provided conditions.

If a condition that we are about to add already exists and has the same status and reason then we are not going to update.

func (*KameletBindingStatus) SetErrorCondition 

func (in *KameletBindingStatus) SetErrorCondition(condType KameletBindingConditionType, reason string, err error)

SetErrorCondition --.

type KameletCondition 

type KameletCondition struct {
	// Type of kamelet condition.
	Type KameletConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`
	// A human-readable message indicating details about the transition.
	Message string `json:"message,omitempty"`
}

KameletCondition describes the state of a resource at a certain point.

func (*KameletCondition) DeepCopy 

func (in *KameletCondition) DeepCopy() *KameletCondition

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

func (*KameletCondition) DeepCopyInto 

func (in *KameletCondition) DeepCopyInto(out *KameletCondition)

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

func (KameletCondition) GetLastTransitionTime 

func (c KameletCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --.

func (KameletCondition) GetLastUpdateTime 

func (c KameletCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --.

func (KameletCondition) GetMessage 

func (c KameletCondition) GetMessage() string

GetMessage --.

func (KameletCondition) GetReason 

func (c KameletCondition) GetReason() string

GetReason --.

func (KameletCondition) GetStatus 

func (c KameletCondition) GetStatus() corev1.ConditionStatus

GetStatus --.

func (KameletCondition) GetType 

func (c KameletCondition) GetType() string

GetType --.

type KameletConditionType 

type KameletConditionType string

KameletConditionType --. 

const (
	// KameletConditionReady --.
	KameletConditionReady KameletConditionType = "Ready"
)

type KameletList 

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

KameletList contains a list of Kamelet.

func NewKameletList 

func NewKameletList() KameletList

NewKameletList creates a new list of Kamelets.

func (*KameletList) DeepCopy 

func (in *KameletList) DeepCopy() *KameletList

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

func (*KameletList) DeepCopyInto 

func (in *KameletList) DeepCopyInto(out *KameletList)

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

func (*KameletList) DeepCopyObject 

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

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

type KameletPhase 

type KameletPhase string

KameletPhase --.

type KameletProperty 

type KameletProperty struct {
	// the name of the property
	Name string `json:"name,omitempty"`
	// the default value of the property (if any)
	Default string `json:"default,omitempty"`
}

KameletProperty specify the behavior of a property in a Kamelet.

func (*KameletProperty) DeepCopy 

func (in *KameletProperty) DeepCopy() *KameletProperty

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

func (*KameletProperty) DeepCopyInto 

func (in *KameletProperty) DeepCopyInto(out *KameletProperty)

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

type KameletSpec 

type KameletSpec struct {
	// defines the formal configuration of the Kamelet
	Definition *JSONSchemaProps `json:"definition,omitempty"`
	// sources in any Camel DSL supported
	Sources []camelv1.SourceSpec `json:"sources,omitempty"`
	// the main source in YAML DSL
	Template *Template `json:"template,omitempty"`
	// data specification types for the events consumed/produced by the Kamelet
	// Deprecated: In favor of using DataTypes
	Types map[TypeSlot]EventTypeSpec `json:"types,omitempty"`
	// data specification types for the events consumed/produced by the Kamelet
	DataTypes map[TypeSlot]DataTypesSpec `json:"dataTypes,omitempty"`
	// Camel dependencies needed by the Kamelet
	Dependencies []string `json:"dependencies,omitempty"`
}

KameletSpec specifies the configuration required to execute a Kamelet.

func (*KameletSpec) DeepCopy 

func (in *KameletSpec) DeepCopy() *KameletSpec

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

func (*KameletSpec) DeepCopyInto 

func (in *KameletSpec) DeepCopyInto(out *KameletSpec)

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

type KameletStatus 

type KameletStatus struct {
	// ObservedGeneration is the most recent generation observed for this Kamelet.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Phase --
	Phase KameletPhase `json:"phase,omitempty"`
	// Conditions --
	Conditions []KameletCondition `json:"conditions,omitempty"`
	// Properties --
	Properties []KameletProperty `json:"properties,omitempty"`
}

KameletStatus defines the observed state of Kamelet.

func (*KameletStatus) DeepCopy 

func (in *KameletStatus) DeepCopy() *KameletStatus

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

func (*KameletStatus) DeepCopyInto 

func (in *KameletStatus) DeepCopyInto(out *KameletStatus)

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

func (*KameletStatus) GetCondition 

func (in *KameletStatus) GetCondition(condType KameletConditionType) *KameletCondition

GetCondition returns the condition with the provided type.

func (*KameletStatus) GetConditions 

func (in *KameletStatus) GetConditions() []v1.ResourceCondition

GetConditions --.

func (*KameletStatus) RemoveCondition 

func (in *KameletStatus) RemoveCondition(condType KameletConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*KameletStatus) SetCondition 

func (in *KameletStatus) SetCondition(condType KameletConditionType, status corev1.ConditionStatus, reason string, message string)

SetCondition --.

func (*KameletStatus) SetConditions 

func (in *KameletStatus) SetConditions(conditions ...KameletCondition)

SetConditions updates the resource to include the provided conditions.

If a condition that we are about to add already exists and has the same status and reason then we are not going to update.

func (*KameletStatus) SetErrorCondition 

func (in *KameletStatus) SetErrorCondition(condType KameletConditionType, reason string, err error)

SetErrorCondition --.

type RawMessage 

type RawMessage []byte

RawMessage is a raw encoded JSON value. It implements Marshaler and Unmarshaler and can be used to delay JSON decoding or precompute a JSON encoding. +kubebuilder:validation:Type="" +kubebuilder:validation:Format="" +kubebuilder:pruning:PreserveUnknownFields

func (RawMessage) DeepCopy 

func (in RawMessage) DeepCopy() RawMessage

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

func (RawMessage) DeepCopyInto 

func (in RawMessage) DeepCopyInto(out *RawMessage)

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

func (RawMessage) MarshalJSON 

func (m RawMessage) MarshalJSON() ([]byte, error)

MarshalJSON returns m as the JSON encoding of m.

func (*RawMessage) String 

func (m *RawMessage) String() string

String returns a string representation of RawMessage.

func (*RawMessage) UnmarshalJSON 

func (m *RawMessage) UnmarshalJSON(data []byte) error

UnmarshalJSON sets *m to a copy of data.

type Template 

type Template struct {
	// an unstructured raw message
	RawMessage `json:",inline"`
}

Template is an unstructured object representing a Kamelet template in YAML/JSON DSL.

func (*Template) DeepCopy 

func (in *Template) DeepCopy() *Template

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

func (*Template) DeepCopyInto 

func (in *Template) DeepCopyInto(out *Template)

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

type TypeSlot 

type TypeSlot string

TypeSlot represent a kind of data (ie, input, output, ...). 

const (
	// TypeSlotIn is used for the input events.
	TypeSlotIn TypeSlot = "in"
	// TypeSlotOut is used for the output events.
	TypeSlotOut TypeSlot = "out"
	// TypeSlotError is used for the error events.
	TypeSlotError TypeSlot = "error"
)

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.