v1

package
v2.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 License: Apache-2.0 Imports: 14 Imported by: 3

Documentation

Overview

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

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

Index

Constants

View Source 
const (
	// BuildKind --
	BuildKind string = "Build"

	// BuildPhaseNone --
	BuildPhaseNone BuildPhase = ""
	// BuildPhaseInitialization --
	BuildPhaseInitialization BuildPhase = "Initialization"
	// BuildPhaseScheduling --
	BuildPhaseScheduling BuildPhase = "Scheduling"
	// BuildPhasePending --
	BuildPhasePending BuildPhase = "Pending"
	// BuildPhaseRunning --
	BuildPhaseRunning BuildPhase = "Running"
	// BuildPhaseSucceeded --
	BuildPhaseSucceeded BuildPhase = "Succeeded"
	// BuildPhaseFailed --
	BuildPhaseFailed BuildPhase = "Failed"
	// BuildPhaseInterrupted --
	BuildPhaseInterrupted = "Interrupted"
	// BuildPhaseError --
	BuildPhaseError BuildPhase = "Error"
)
View Source 
const (
	// TraitAnnotationPrefix represents the prefix used for traits annotations
	TraitAnnotationPrefix = "trait.camel.apache.org/"
	// OperatorIDAnnotation operator id annotation label
	OperatorIDAnnotation = "camel.apache.org/operator.id"
	// SecondaryPlatformAnnotation secondary platform annotation label
	SecondaryPlatformAnnotation = "camel.apache.org/secondary.platform"
	// PlatformSelectorAnnotation platform id annotation label
	PlatformSelectorAnnotation = "camel.apache.org/platform.id"
)
View Source 
const (
	// BuildStrategyRoutine performs the build in a routine (will be executed as a process inside the same Camel K operator `Pod`).
	// A routine may be preferred to a `pod` strategy since it is in general quicker to execute. It is executed as
	// a parallel process, so you may need to consider the quantity of concurrent build process running simultaneously.
	// Only available for Quarkus JVM mode.
	BuildStrategyRoutine BuildStrategy = "routine"
	// BuildStrategyPod performs the build in a `Pod` (will schedule a new builder `Pod` which will take care of the build action).
	// This strategy has the limitation that every build will have to download all the dependencies required by the Maven build which should be
	// mitigated by the presence of a Maven proxy.
	// Available for both Quarkus JVM and Native mode.
	BuildStrategyPod BuildStrategy = "pod"

	// BuildOrderStrategyFIFO performs the builds with first in first out strategy based on the creation timestamp.
	// The strategy allows builds to run in parallel to each other but oldest builds will be run first.
	BuildOrderStrategyFIFO BuildOrderStrategy = "fifo"
	// BuildOrderStrategyDependencies runs builds ordered by its required dependencies.
	// Strategy looks at the list of dependencies required by an Integration and queues builds that may reuse base images produced by other
	// scheduled builds in order to leverage the incremental build option. The strategy allows non-matching builds to run in parallel to each other.
	BuildOrderStrategyDependencies BuildOrderStrategy = "dependencies"
	// BuildOrderStrategySequential runs builds strictly sequential so that only one single build per operator namespace is running at a time.
	BuildOrderStrategySequential BuildOrderStrategy = "sequential"
)
View Source 
const (
	// ServiceTypeUser service user type label marker
	ServiceTypeUser = "user"

	// CapabilityRest defines the REST API service exposure capability
	CapabilityRest = "rest"
	// CapabilityHealth defines the health monitoring capability
	CapabilityHealth = "health"
	// CapabilityCron defines the cron execution capability
	CapabilityCron = "cron"
	// CapabilityPlatformHTTP defines the http service exposure capability
	CapabilityPlatformHTTP = "platform-http"
	// CapabilityCircuitBreaker defines the circuit breaker capability
	CapabilityCircuitBreaker = "circuit-breaker"
	// CapabilityTracing defines the tracing (opentracing) capability
	CapabilityTracing = "tracing"
	// CapabilityTelemetry defines the telemetry (opentelemetry) capability
	CapabilityTelemetry = "telemetry"
	// CapabilityMaster defines the master capability
	CapabilityMaster = "master"
	// CapabilityResumeKafka defines the resume capability
	CapabilityResumeKafka = "resume-kafka"
	// CapabilityAwsSecretsManager defines the aws secrets manager capability
	CapabilityAwsSecretsManager = "aws-secrets-manager"
	// CapabilityGcpSecretManager defines the gcp secret manager capability
	CapabilityGcpSecretManager = "gcp-secret-manager"
	// CapabilityAzureKeyVault defines the azure key vault capability
	CapabilityAzureKeyVault = "azure-key-vault"
	// CapabilityHashicorpVault defines the Hashicorp Vault capability
	CapabilityHashicorpVault = "hashicorp-vault"
)
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 (
	// IntegrationKind --
	IntegrationKind string = "Integration"

	// IntegrationPhaseNone --
	IntegrationPhaseNone IntegrationPhase = ""
	// IntegrationPhaseWaitingForPlatform --
	IntegrationPhaseWaitingForPlatform IntegrationPhase = "Waiting For Platform"
	// IntegrationPhaseInitialization --
	IntegrationPhaseInitialization IntegrationPhase = "Initialization"
	// IntegrationPhaseBuildingKit --
	IntegrationPhaseBuildingKit IntegrationPhase = "Building Kit"
	// IntegrationPhaseDeploying --
	IntegrationPhaseDeploying IntegrationPhase = "Deploying"
	// IntegrationPhaseRunning --
	IntegrationPhaseRunning IntegrationPhase = "Running"
	// IntegrationPhaseError --
	IntegrationPhaseError IntegrationPhase = "Error"

	// IntegrationConditionKitAvailable --
	IntegrationConditionKitAvailable IntegrationConditionType = "IntegrationKitAvailable"
	// IntegrationConditionPlatformAvailable --
	IntegrationConditionPlatformAvailable IntegrationConditionType = "IntegrationPlatformAvailable"
	// IntegrationConditionDeploymentAvailable --
	IntegrationConditionDeploymentAvailable IntegrationConditionType = "DeploymentAvailable"
	// IntegrationConditionServiceAvailable --
	IntegrationConditionServiceAvailable IntegrationConditionType = "ServiceAvailable"
	// IntegrationConditionKnativeServiceAvailable --
	IntegrationConditionKnativeServiceAvailable IntegrationConditionType = "KnativeServiceAvailable"
	// IntegrationConditionKnativeAvailable --
	IntegrationConditionKnativeAvailable IntegrationConditionType = "KnativeAvailable"
	// IntegrationConditionCronJobAvailable --
	IntegrationConditionCronJobAvailable IntegrationConditionType = "CronJobAvailable"
	// IntegrationConditionExposureAvailable --
	IntegrationConditionExposureAvailable IntegrationConditionType = "ExposureAvailable"
	// IntegrationConditionPrometheusAvailable --
	IntegrationConditionPrometheusAvailable IntegrationConditionType = "PrometheusAvailable"
	// IntegrationConditionJolokiaAvailable --
	IntegrationConditionJolokiaAvailable IntegrationConditionType = "JolokiaAvailable"
	// IntegrationConditionProbesAvailable --
	IntegrationConditionProbesAvailable IntegrationConditionType = "ProbesAvailable"
	// IntegrationConditionReady --
	IntegrationConditionReady IntegrationConditionType = "Ready"

	// IntegrationConditionKitAvailableReason --
	IntegrationConditionKitAvailableReason string = "IntegrationKitAvailable"
	// IntegrationConditionPlatformAvailableReason --
	IntegrationConditionPlatformAvailableReason string = "IntegrationPlatformAvailable"
	// IntegrationConditionDeploymentAvailableReason --
	IntegrationConditionDeploymentAvailableReason string = "DeploymentAvailable"
	// IntegrationConditionDeploymentNotAvailableReason --
	IntegrationConditionDeploymentNotAvailableReason string = "DeploymentNotAvailable"
	// IntegrationConditionServiceAvailableReason --
	IntegrationConditionServiceAvailableReason string = "ServiceAvailable"
	// IntegrationConditionServiceNotAvailableReason --
	IntegrationConditionServiceNotAvailableReason string = "ServiceNotAvailable"
	// IntegrationConditionContainerNotAvailableReason --
	IntegrationConditionContainerNotAvailableReason string = "ContainerNotAvailable"
	// IntegrationConditionRouteAvailableReason --
	IntegrationConditionRouteAvailableReason string = "RouteAvailable"
	// IntegrationConditionRouteNotAvailableReason --
	IntegrationConditionRouteNotAvailableReason string = "RouteNotAvailable"
	// IntegrationConditionIngressAvailableReason --
	IntegrationConditionIngressAvailableReason string = "IngressAvailable"
	// IntegrationConditionIngressNotAvailableReason --
	IntegrationConditionIngressNotAvailableReason string = "IngressNotAvailable"
	// IntegrationConditionKnativeServiceAvailableReason --
	IntegrationConditionKnativeServiceAvailableReason string = "KnativeServiceAvailable"
	// IntegrationConditionKnativeServiceNotAvailableReason --
	IntegrationConditionKnativeServiceNotAvailableReason string = "KnativeServiceNotAvailable"
	// IntegrationConditionKnativeNotInstalledReason --
	IntegrationConditionKnativeNotInstalledReason string = "KnativeNotInstalled"
	// IntegrationConditionCronJobAvailableReason --
	IntegrationConditionCronJobAvailableReason string = "CronJobAvailableReason"
	// IntegrationConditionCronJobNotAvailableReason --
	IntegrationConditionCronJobNotAvailableReason string = "CronJobNotAvailableReason"
	// IntegrationConditionPrometheusAvailableReason --
	IntegrationConditionPrometheusAvailableReason string = "PrometheusAvailable"
	// IntegrationConditionJolokiaAvailableReason --
	IntegrationConditionJolokiaAvailableReason string = "JolokiaAvailable"
	// IntegrationConditionProbesAvailableReason --
	IntegrationConditionProbesAvailableReason string = "ProbesAvailable"

	// IntegrationConditionKnativeServiceReadyReason --
	IntegrationConditionKnativeServiceReadyReason string = "KnativeServiceReady"
	// IntegrationConditionDeploymentReadyReason --
	IntegrationConditionDeploymentReadyReason string = "DeploymentReady"
	// IntegrationConditionDeploymentProgressingReason --
	IntegrationConditionDeploymentProgressingReason string = "DeploymentProgressing"
	// IntegrationConditionCronJobCreatedReason --
	IntegrationConditionCronJobCreatedReason string = "CronJobCreated"
	// IntegrationConditionCronJobActiveReason --
	IntegrationConditionCronJobActiveReason string = "CronJobActive"
	// IntegrationConditionLastJobSucceededReason --
	IntegrationConditionLastJobSucceededReason string = "LastJobSucceeded"
	// IntegrationConditionLastJobFailedReason --
	IntegrationConditionLastJobFailedReason string = "LastJobFailed"
	// IntegrationConditionRuntimeNotReadyReason --
	IntegrationConditionRuntimeNotReadyReason string = "RuntimeNotReady"
	// IntegrationConditionErrorReason --
	IntegrationConditionErrorReason string = "Error"

	// IntegrationConditionInitializationFailedReason --
	IntegrationConditionInitializationFailedReason string = "InitializationFailed"
	// IntegrationConditionUnsupportedLanguageReason --
	IntegrationConditionUnsupportedLanguageReason string = "UnsupportedLanguage"

	// IntegrationConditionKameletsAvailable --
	IntegrationConditionKameletsAvailable IntegrationConditionType = "KameletsAvailable"
	// IntegrationConditionKameletsAvailableReason --
	IntegrationConditionKameletsAvailableReason string = "KameletsAvailable"
	// IntegrationConditionKameletsNotAvailableReason --
	IntegrationConditionKameletsNotAvailableReason string = "KameletsNotAvailable"
)
View Source 
const (
	// IntegrationKitKind --
	IntegrationKitKind string = "IntegrationKit"

	// IntegrationKitTypeLabel labels the kit type
	IntegrationKitTypeLabel = "camel.apache.org/kit.type"

	// IntegrationKitTypePlatform identifies a kit created by the platform
	IntegrationKitTypePlatform = "platform"
	// IntegrationKitTypeUser identifies a kit created by the user
	IntegrationKitTypeUser = "user"
	// IntegrationKitTypeExternal identifies a kit created by any third party
	IntegrationKitTypeExternal = "external"

	// IntegrationKitLayoutLabel labels the kit layout
	IntegrationKitLayoutLabel = "camel.apache.org/kit.layout"

	// IntegrationKitLayoutFastJar labels a kit using the Quarkus fast-jar packaging
	IntegrationKitLayoutFastJar = "fast-jar"
	// IntegrationKitLayoutNative labels a kit using the Quarkus native packaging
	IntegrationKitLayoutNative = "native"

	// IntegrationKitPriorityLabel labels the kit priority
	IntegrationKitPriorityLabel = "camel.apache.org/kit.priority"

	// IntegrationKitPhaseNone --
	IntegrationKitPhaseNone IntegrationKitPhase = ""
	// IntegrationKitPhaseInitialization --
	IntegrationKitPhaseInitialization IntegrationKitPhase = "Initialization"
	// IntegrationKitPhaseWaitingForPlatform --
	IntegrationKitPhaseWaitingForPlatform IntegrationKitPhase = "Waiting For Platform"
	// IntegrationKitPhaseBuildSubmitted --
	IntegrationKitPhaseBuildSubmitted IntegrationKitPhase = "Build Submitted"
	// IntegrationKitPhaseBuildRunning --
	IntegrationKitPhaseBuildRunning IntegrationKitPhase = "Build Running"
	// IntegrationKitPhaseWaitingForCatalog --
	IntegrationKitPhaseWaitingForCatalog IntegrationKitPhase = "Waiting For Catalog"
	// IntegrationKitPhaseReady --
	IntegrationKitPhaseReady IntegrationKitPhase = "Ready"
	// IntegrationKitPhaseError --
	IntegrationKitPhaseError IntegrationKitPhase = "Error"

	// IntegrationKitConditionPlatformAvailable --
	IntegrationKitConditionPlatformAvailable IntegrationKitConditionType = "IntegrationPlatformAvailable"
	// IntegrationKitConditionCatalogAvailable --
	IntegrationKitConditionCatalogAvailable IntegrationKitConditionType = "CamelCatalogAvailable"
	// IntegrationKitConditionPlatformAvailableReason --
	IntegrationKitConditionPlatformAvailableReason string = "IntegrationPlatformAvailable"
)
View Source 
const (
	// IntegrationPlatformKind is the Kind name of the IntegrationPlatform CR
	IntegrationPlatformKind string = "IntegrationPlatform"

	// IntegrationPlatformPhaseNone when the IntegrationPlatform does not exist
	IntegrationPlatformPhaseNone IntegrationPlatformPhase = ""
	// IntegrationPlatformPhaseCreating when the IntegrationPlatform is under creation process
	IntegrationPlatformPhaseCreating IntegrationPlatformPhase = "Creating"
	// IntegrationPlatformPhaseWarming when the IntegrationPlatform is warming (ie, creating Kaniko cache)
	IntegrationPlatformPhaseWarming IntegrationPlatformPhase = "Warming"
	// IntegrationPlatformPhaseReady when the IntegrationPlatform is ready
	IntegrationPlatformPhaseReady IntegrationPlatformPhase = "Ready"
	// IntegrationPlatformPhaseError when the IntegrationPlatform had some error (see Conditions)
	IntegrationPlatformPhaseError IntegrationPlatformPhase = "Error"
	// IntegrationPlatformPhaseDuplicate when the IntegrationPlatform is duplicated
	IntegrationPlatformPhaseDuplicate IntegrationPlatformPhase = "Duplicate"

	// IntegrationPlatformConditionReady is the condition if the IntegrationPlatform is ready.
	IntegrationPlatformConditionReady = "Ready"

	// IntegrationPlatformConditionCreatedReason represents the reason that the IntegrationPlatform is created.
	IntegrationPlatformConditionCreatedReason = "IntegrationPlatformCreated"
)
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"
)
View Source 
const (
	// PipeKind --
	PipeKind string = "Pipe"

	// PipePhaseNone --
	PipePhaseNone PipePhase = ""
	// PipePhaseCreating --
	PipePhaseCreating PipePhase = "Creating"
	// PipePhaseError --
	PipePhaseError PipePhase = "Error"
	// PipePhaseReady --
	PipePhaseReady PipePhase = "Ready"
)
View Source 
const (
	// CamelCatalogKind --
	CamelCatalogKind string = "CamelCatalog"
)
View Source 
const IntegrationLabel = "camel.apache.org/integration"

Variables

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

	// 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 AllIntegrationPlatformClusters = []IntegrationPlatformCluster{IntegrationPlatformClusterOpenShift, IntegrationPlatformClusterKubernetes}

AllIntegrationPlatformClusters --

View Source 
var AllTraitProfiles = []TraitProfile{TraitProfileKubernetes, TraitProfileKnative, TraitProfileOpenShift}

AllTraitProfiles contains all allowed profiles

View Source 
var BuildOrderStrategies = []BuildOrderStrategy{
	BuildOrderStrategyFIFO,
	BuildOrderStrategyDependencies,
	BuildOrderStrategySequential,
}

BuildOrderStrategies is a list of order strategies allowed for the build

View Source 
var BuildStrategies = []BuildStrategy{
	BuildStrategyRoutine,
	BuildStrategyPod,
}

BuildStrategies is a list of strategies allowed for the build

View Source 
var IntegrationPlatformBuildPublishStrategies = []IntegrationPlatformBuildPublishStrategy{
	IntegrationPlatformBuildPublishStrategyBuildah,
	IntegrationPlatformBuildPublishStrategyKaniko,
	IntegrationPlatformBuildPublishStrategyS2I,
	IntegrationPlatformBuildPublishStrategySpectrum,
}

IntegrationPlatformBuildPublishStrategies the list of all available publish strategies

View Source 
var (

	// KameletIDProperty used to identify
	KameletIDProperty = "id"
)
View Source 
var Languages = []Language{
	LanguageJavaSource,
	LanguageGroovy,
	LanguageJavaScript,
	LanguageXML,
	LanguageKotlin,
	LanguageYaml,
	LanguageKamelet,
	LanguageJavaShell,
}

Languages is the list of all supported languages

Functions

func GetOperatorIDAnnotation 

func GetOperatorIDAnnotation(obj metav1.Object) string

GetOperatorIDAnnotation to safely get the operator id annotation value.

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func SetAnnotation 

func SetAnnotation(obj *metav1.ObjectMeta, name string, value string)

SetAnnotation safely sets the annotation on the given runtime object.

func SetBuilderConfigurationTasks 

func SetBuilderConfigurationTasks(tasks []Task, conf *BuildConfiguration)

SetBuilderConfigurationTasks set the configuration required for the builder in the list of tasks.

func ValidKameletName 

func ValidKameletName(name string) bool

func ValidKameletProperties 

func ValidKameletProperties(kamelet *Kamelet) bool

Types

type AddonTrait 

type AddonTrait struct {
	// Generic raw message, typically a map containing the keys (trait parameters) and the values (either single text or array)
	RawMessage `json:",inline"`
}

AddonTrait represents the configuration of an addon trait

func (*AddonTrait) DeepCopy 

func (in *AddonTrait) DeepCopy() *AddonTrait

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

func (*AddonTrait) DeepCopyInto 

func (in *AddonTrait) DeepCopyInto(out *AddonTrait)

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

type Artifact 

type Artifact struct {
	// the identification (GAV for maven dependencies or file name for other file types)
	ID string `json:"id" yaml:"id"`
	// where it is located in the builder `Pod`
	Location string `json:"location,omitempty" yaml:"location,omitempty"`
	// the expected location in the runtime
	Target string `json:"target,omitempty" yaml:"target,omitempty"`
	// a checksum (SHA1) of the content
	Checksum string `json:"checksum,omitempty" yaml:"checksum,omitempty"`
}

Artifact represents a materialized artifact (a jar dependency or in general a file used by the build)

func (*Artifact) DeepCopy 

func (in *Artifact) DeepCopy() *Artifact

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

func (*Artifact) DeepCopyInto 

func (in *Artifact) DeepCopyInto(out *Artifact)

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

func (*Artifact) String 

func (in *Artifact) String() string

type BaseTask 

type BaseTask struct {
	// name of the task
	Name string `json:"name,omitempty"`
}

BaseTask is a base for the struct hierarchy

func (*BaseTask) DeepCopy 

func (in *BaseTask) DeepCopy() *BaseTask

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

func (*BaseTask) DeepCopyInto 

func (in *BaseTask) DeepCopyInto(out *BaseTask)

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

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 Build 

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

	Spec   BuildSpec   `json:"spec,omitempty"`
	Status BuildStatus `json:"status,omitempty"`
}

Build is the Schema for the builds API

func NewBuild 

func NewBuild(namespace string, name string) *Build

func (*Build) BuilderConfiguration 

func (build *Build) BuilderConfiguration() *BuildConfiguration

BuilderConfiguration returns the builder configuration for this Build.

func (*Build) BuilderDependencies 

func (build *Build) BuilderDependencies() []string

BuilderDependencies returns the list of dependencies configured on by the builder task for this Build.

func (*Build) BuilderPodNamespace 

func (build *Build) BuilderPodNamespace() string

BuilderPodNamespace returns the namespace of the operator in charge to reconcile this Build.

func (*Build) DeepCopy 

func (in *Build) DeepCopy() *Build

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

func (*Build) DeepCopyInto 

func (in *Build) DeepCopyInto(out *Build)

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

func (*Build) DeepCopyObject 

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

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

func (*Build) SetBuilderConfiguration 

func (build *Build) SetBuilderConfiguration(conf *BuildConfiguration)

SetBuilderConfiguration set the configuration required for this Build.

type BuildCondition 

type BuildCondition struct {
	// Type of integration condition.
	Type BuildConditionType `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"`
}

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

func (*BuildCondition) DeepCopy 

func (in *BuildCondition) DeepCopy() *BuildCondition

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

func (*BuildCondition) DeepCopyInto 

func (in *BuildCondition) DeepCopyInto(out *BuildCondition)

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

func (BuildCondition) GetLastTransitionTime 

func (c BuildCondition) GetLastTransitionTime() metav1.Time

func (BuildCondition) GetLastUpdateTime 

func (c BuildCondition) GetLastUpdateTime() metav1.Time

func (BuildCondition) GetMessage 

func (c BuildCondition) GetMessage() string

func (BuildCondition) GetReason 

func (c BuildCondition) GetReason() string

func (BuildCondition) GetStatus 

func (c BuildCondition) GetStatus() corev1.ConditionStatus

func (BuildCondition) GetType 

func (c BuildCondition) GetType() string

type BuildConditionType 

type BuildConditionType string

BuildConditionType --

type BuildConfiguration 

type BuildConfiguration struct {
	// The container image to be used to run the build.
	ToolImage string `json:"toolImage,omitempty"`
	// The namespace where to run the builder Pod (must be the same of the operator in charge of this Build reconciliation).
	BuilderPodNamespace string `json:"operatorNamespace,omitempty"`
	// the strategy to adopt
	Strategy BuildStrategy `property:"strategy" json:"strategy,omitempty"`
	// the build order strategy to adopt
	OrderStrategy BuildOrderStrategy `property:"order-strategy" json:"orderStrategy,omitempty"`
	// The minimum amount of CPU required. Only used for `pod` strategy
	RequestCPU string `property:"request-cpu" json:"requestCPU,omitempty"`
	// The minimum amount of memory required. Only used for `pod` strategy
	RequestMemory string `property:"request-memory" json:"requestMemory,omitempty"`
	// The maximum amount of CPU required. Only used for `pod` strategy
	LimitCPU string `property:"limit-cpu" json:"limitCPU,omitempty"`
	// The maximum amount of memory required. Only used for `pod` strategy
	LimitMemory string `property:"limit-memory" json:"limitMemory,omitempty"`
}

BuildConfiguration represent the configuration required to build the runtime

func BuilderConfigurationTasks 

func BuilderConfigurationTasks(tasks []Task) *BuildConfiguration

BuilderConfigurationTasks returns the builder configuration from the task list.

func (*BuildConfiguration) DeepCopy 

func (in *BuildConfiguration) DeepCopy() *BuildConfiguration

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

func (*BuildConfiguration) DeepCopyInto 

func (in *BuildConfiguration) DeepCopyInto(out *BuildConfiguration)

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

func (*BuildConfiguration) IsEmpty 

func (bc *BuildConfiguration) IsEmpty() bool

IsEmpty -- .

type BuildList 

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

BuildList contains a list of Build

func NewBuildList 

func NewBuildList() BuildList

func (*BuildList) DeepCopy 

func (in *BuildList) DeepCopy() *BuildList

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

func (*BuildList) DeepCopyInto 

func (in *BuildList) DeepCopyInto(out *BuildList)

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

func (*BuildList) DeepCopyObject 

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

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

func (BuildList) HasMatchingBuild 

func (bl BuildList) HasMatchingBuild(build *Build) (bool, *Build)

HasMatchingBuild visit all items in the list of builds and search for a scheduled build that matches the given build's dependencies.

func (BuildList) HasRunningBuilds 

func (bl BuildList) HasRunningBuilds() bool

func (BuildList) HasScheduledBuildsBefore 

func (bl BuildList) HasScheduledBuildsBefore(build *Build) (bool, *Build)

type BuildOrderStrategy 

type BuildOrderStrategy string

BuildOrderStrategy specifies how builds are reconciled and queued. +kubebuilder:validation:Enum=dependencies;fifo;sequential

type BuildPhase 

type BuildPhase string

BuildPhase --

func (*BuildPhase) String 

func (buildPhase *BuildPhase) String() string

type BuildSpec 

type BuildSpec struct {
	// The sequence of tasks (pipeline) to be performed.
	Tasks []Task `json:"tasks,omitempty"`
	// The configuration that should be used to perform the Build.
	// Deprecated: no longer in use in Camel K 2 - maintained for backward compatibility
	Configuration BuildConfiguration `json:"configuration,omitempty"`
	// The container image to be used to run the build.
	// Deprecated: no longer in use in Camel K 2 - maintained for backward compatibility
	ToolImage string `json:"toolImage,omitempty"`
	// The namespace where to run the builder Pod (must be the same of the operator in charge of this Build reconciliation).
	// Deprecated: no longer in use in Camel K 2 - maintained for backward compatibility
	BuilderPodNamespace string `json:"operatorNamespace,omitempty"`
	// Timeout defines the Build maximum execution duration.
	// The Build deadline is set to the Build start time plus the Timeout duration.
	// If the Build deadline is exceeded, the Build context is canceled,
	// and its phase set to BuildPhaseFailed.
	// +kubebuilder:validation:Format=duration
	Timeout metav1.Duration `json:"timeout,omitempty"`
	// the maximum amount of parallel running builds started by this operator instance
	// Deprecated: no longer in use in Camel K 2 - maintained for backward compatibility
	MaxRunningBuilds int32 `json:"maxRunningBuilds,omitempty"`
}

BuildSpec defines the list of tasks to be execute for a Build. From Camel K version 2, it would be more appropiate to think it as pipeline.

func (*BuildSpec) DeepCopy 

func (in *BuildSpec) DeepCopy() *BuildSpec

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

func (*BuildSpec) DeepCopyInto 

func (in *BuildSpec) DeepCopyInto(out *BuildSpec)

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

type BuildStatus 

type BuildStatus struct {
	// ObservedGeneration is the most recent generation observed for this Build.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// describes the phase
	Phase BuildPhase `json:"phase,omitempty"`
	// the image name built
	Image string `json:"image,omitempty"`
	// the digest from image
	Digest string `json:"digest,omitempty"`
	// the base image used for this build
	BaseImage string `json:"baseImage,omitempty"`
	// a list of artifacts contained in the build
	Artifacts []Artifact `json:"artifacts,omitempty"`
	// the error description (if any)
	Error string `json:"error,omitempty"`
	// the reason of the failure (if any)
	Failure *Failure `json:"failure,omitempty"`
	// the time when it started
	StartedAt *metav1.Time `json:"startedAt,omitempty"`
	// a list of conditions occurred during the build
	Conditions []BuildCondition `json:"conditions,omitempty"`
	// how long it took for the build
	// Change to Duration / ISO 8601 when CRD uses OpenAPI spec v3
	// https://github.com/OAI/OpenAPI-Specification/issues/845
	Duration string `json:"duration,omitempty"`
}

BuildStatus defines the observed state of Build

func (*BuildStatus) DeepCopy 

func (in *BuildStatus) DeepCopy() *BuildStatus

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

func (*BuildStatus) DeepCopyInto 

func (in *BuildStatus) DeepCopyInto(out *BuildStatus)

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

func (*BuildStatus) Failed 

func (in *BuildStatus) Failed(err error) BuildStatus

func (*BuildStatus) GetCondition 

func (in *BuildStatus) GetCondition(condType BuildConditionType) *BuildCondition

GetCondition returns the condition with the provided type.

func (*BuildStatus) GetConditions 

func (in *BuildStatus) GetConditions() []ResourceCondition

func (*BuildStatus) IsFinished 

func (in *BuildStatus) IsFinished() bool

func (*BuildStatus) RemoveCondition 

func (in *BuildStatus) RemoveCondition(condType BuildConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*BuildStatus) SetCondition 

func (in *BuildStatus) SetCondition(condType BuildConditionType, status corev1.ConditionStatus, reason string, message string)

func (*BuildStatus) SetConditions 

func (in *BuildStatus) SetConditions(conditions ...BuildCondition)

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 (*BuildStatus) SetErrorCondition 

func (in *BuildStatus) SetErrorCondition(condType BuildConditionType, reason string, err error)

type BuildStrategy 

type BuildStrategy string

BuildStrategy specifies how the Build should be executed. It will trigger a Maven process (either as an Operator routine or Kubernetes Pod execution) that will take care of producing the expected Camel/Camel-Quarkus runtime. +kubebuilder:validation:Enum=routine;pod

type BuildahTask 

type BuildahTask struct {
	BaseTask    `json:",inline"`
	PublishTask `json:",inline"`
	// The platform of build image
	Platform string `json:"platform,omitempty"`
	// log more information
	Verbose *bool `json:"verbose,omitempty"`
	// docker image to use
	ExecutorImage string `json:"executorImage,omitempty"`
}

BuildahTask is used to configure Buildah

func (*BuildahTask) DeepCopy 

func (in *BuildahTask) DeepCopy() *BuildahTask

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

func (*BuildahTask) DeepCopyInto 

func (in *BuildahTask) DeepCopyInto(out *BuildahTask)

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

type BuilderTask 

type BuilderTask struct {
	BaseTask `json:",inline"`
	// The configuration that should be used to perform the Build.
	Configuration BuildConfiguration `json:"configuration,omitempty"`
	// the base image layer
	BaseImage string `json:"baseImage,omitempty"`
	// the configuration required for the runtime application
	Runtime RuntimeSpec `json:"runtime,omitempty"`
	// the list of dependencies to use for this build
	Dependencies []string `json:"dependencies,omitempty"`
	// the list of steps to execute (see pkg/builder/)
	Steps []string `json:"steps,omitempty"`
	// the configuration required by Maven for the application build phase
	Maven MavenBuildSpec `json:"maven,omitempty"`
	// workspace directory to use
	BuildDir string `json:"buildDir,omitempty"`
	// the sources to add at build time
	Sources []SourceSpec `json:"sources,omitempty"`
}

BuilderTask is the generic task in charge of building the application image

func FindBuilderTask 

func FindBuilderTask(tasks []Task) (*BuilderTask, bool)

FindBuilderTask returns the 1st builder task from the task list.

func (*BuilderTask) DeepCopy 

func (in *BuilderTask) DeepCopy() *BuilderTask

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

func (*BuilderTask) DeepCopyInto 

func (in *BuilderTask) DeepCopyInto(out *BuilderTask)

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

type CamelArtifact 

type CamelArtifact struct {
	// Base Camel Artifact dependency
	CamelArtifactDependency `json:",inline" yaml:",inline"`
	// accepted URI schemes
	Schemes []CamelScheme `json:"schemes,omitempty" yaml:"schemes,omitempty"`
	// accepted languages
	Languages []string `json:"languages,omitempty" yaml:"languages,omitempty"`
	// accepted data formats
	DataFormats []string `json:"dataformats,omitempty" yaml:"dataformats,omitempty"`
	// required dependencies
	Dependencies []CamelArtifactDependency `json:"dependencies,omitempty" yaml:"dependencies,omitempty"`
	// the Java types used by the artifact feature (ie, component, data format, ...)
	JavaTypes []string `json:"javaTypes,omitempty" yaml:"javaTypes,omitempty"`
}

CamelArtifact represent the configuration for a feature offered by Camel

func (*CamelArtifact) DeepCopy 

func (in *CamelArtifact) DeepCopy() *CamelArtifact

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

func (*CamelArtifact) DeepCopyInto 

func (in *CamelArtifact) DeepCopyInto(out *CamelArtifact)

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

func (*CamelArtifact) GetConsumerDependencies 

func (in *CamelArtifact) GetConsumerDependencies(schemeID string) []CamelArtifactDependency

func (*CamelArtifact) GetConsumerDependencyIDs 

func (in *CamelArtifact) GetConsumerDependencyIDs(schemeID string) []string

func (*CamelArtifact) GetDependencyID 

func (in *CamelArtifact) GetDependencyID() string

GetDependencyID returns a Camel K recognizable maven dependency for the artifact

func (*CamelArtifact) GetProducerDependencies 

func (in *CamelArtifact) GetProducerDependencies(schemeID string) []CamelArtifactDependency

func (*CamelArtifact) GetProducerDependencyIDs 

func (in *CamelArtifact) GetProducerDependencyIDs(schemeID string) []string

func (*CamelArtifact) GetScheme 

func (in *CamelArtifact) GetScheme(schemeID string) *CamelScheme

type CamelArtifactDependency 

type CamelArtifactDependency struct {
	// the maven dependency
	MavenArtifact `json:",inline" yaml:",inline"`
	// provide a list of artifacts to exclude for this dependency
	Exclusions []CamelArtifactExclusion `json:"exclusions,omitempty" yaml:"exclusions,omitempty"`
}

CamelArtifactDependency represent a maven's dependency

func (*CamelArtifactDependency) DeepCopy 

func (in *CamelArtifactDependency) DeepCopy() *CamelArtifactDependency

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

func (*CamelArtifactDependency) DeepCopyInto 

func (in *CamelArtifactDependency) DeepCopyInto(out *CamelArtifactDependency)

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

type CamelArtifactExclusion 

type CamelArtifactExclusion struct {
	// Maven Group
	GroupID string `json:"groupId" yaml:"groupId"`
	// Maven Artifact
	ArtifactID string `json:"artifactId" yaml:"artifactId"`
}

CamelArtifactExclusion represents an exclusion clause

func (*CamelArtifactExclusion) DeepCopy 

func (in *CamelArtifactExclusion) DeepCopy() *CamelArtifactExclusion

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

func (*CamelArtifactExclusion) DeepCopyInto 

func (in *CamelArtifactExclusion) DeepCopyInto(out *CamelArtifactExclusion)

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

type CamelCatalog 

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

	// the actual state of the catalog
	Status CamelCatalogStatus `json:"status,omitempty" yaml:"status,omitempty"`
	// the desired state of the catalog
	Spec CamelCatalogSpec `json:"spec,omitempty" yaml:"spec,omitempty"`
}

CamelCatalog represents the languages, components, data formats and capabilities enabled on a given runtime provider. The catalog may be statically generated.

func NewCamelCatalog 

func NewCamelCatalog(namespace string, name string) CamelCatalog

NewCamelCatalog --

func NewCamelCatalogWithSpecs 

func NewCamelCatalogWithSpecs(namespace string, name string, spec CamelCatalogSpec) CamelCatalog

NewCamelCatalogWithSpecs --

func (*CamelCatalog) DeepCopy 

func (in *CamelCatalog) DeepCopy() *CamelCatalog

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

func (*CamelCatalog) DeepCopyInto 

func (in *CamelCatalog) DeepCopyInto(out *CamelCatalog)

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

func (*CamelCatalog) DeepCopyObject 

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

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

type CamelCatalogCondition 

type CamelCatalogCondition struct {
	// Type of CamelCatalog condition.
	Type CamelCatalogConditionType `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"`
}

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

func (*CamelCatalogCondition) DeepCopy 

func (in *CamelCatalogCondition) DeepCopy() *CamelCatalogCondition

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

func (*CamelCatalogCondition) DeepCopyInto 

func (in *CamelCatalogCondition) DeepCopyInto(out *CamelCatalogCondition)

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

func (CamelCatalogCondition) GetLastTransitionTime 

func (c CamelCatalogCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --

func (CamelCatalogCondition) GetLastUpdateTime 

func (c CamelCatalogCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --

func (CamelCatalogCondition) GetMessage 

func (c CamelCatalogCondition) GetMessage() string

GetMessage --

func (CamelCatalogCondition) GetReason 

func (c CamelCatalogCondition) GetReason() string

GetReason --

func (CamelCatalogCondition) GetStatus 

func (c CamelCatalogCondition) GetStatus() corev1.ConditionStatus

GetStatus --

func (CamelCatalogCondition) GetType 

func (c CamelCatalogCondition) GetType() string

GetType --

type CamelCatalogConditionType 

type CamelCatalogConditionType string

CamelCatalogConditionType -- 

const (
	// CamelCatalogConditionReady --
	CamelCatalogConditionReady CamelCatalogConditionType = "Ready"
)

type CamelCatalogList 

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

CamelCatalogList contains a list of CamelCatalog

func NewCamelCatalogList 

func NewCamelCatalogList() CamelCatalogList

NewCamelCatalogList --

func (*CamelCatalogList) DeepCopy 

func (in *CamelCatalogList) DeepCopy() *CamelCatalogList

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

func (*CamelCatalogList) DeepCopyInto 

func (in *CamelCatalogList) DeepCopyInto(out *CamelCatalogList)

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

func (*CamelCatalogList) DeepCopyObject 

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

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

type CamelCatalogPhase 

type CamelCatalogPhase string

CamelCatalogPhase -- 

const (
	// CamelCatalogPhaseNone --
	CamelCatalogPhaseNone CamelCatalogPhase = ""
	// CamelCatalogPhaseReady --
	CamelCatalogPhaseReady CamelCatalogPhase = "Ready"
	// CamelCatalogPhaseError --
	CamelCatalogPhaseError CamelCatalogPhase = "Error"
)

type CamelCatalogSpec 

type CamelCatalogSpec struct {
	// the runtime targeted for the catalog
	Runtime RuntimeSpec `json:"runtime" yaml:"runtime"`
	// artifacts required by this catalog
	Artifacts map[string]CamelArtifact `json:"artifacts" yaml:"artifacts"`
	// loaders required by this catalog
	Loaders map[string]CamelLoader `json:"loaders" yaml:"loaders"`
}

CamelCatalogSpec specify what features a Camel runtime provides

func (*CamelCatalogSpec) DeepCopy 

func (in *CamelCatalogSpec) DeepCopy() *CamelCatalogSpec

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

func (*CamelCatalogSpec) DeepCopyInto 

func (in *CamelCatalogSpec) DeepCopyInto(out *CamelCatalogSpec)

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

func (*CamelCatalogSpec) GetCamelQuarkusVersion 

func (c *CamelCatalogSpec) GetCamelQuarkusVersion() string

GetCamelQuarkusVersion returns the Camel Quarkus version the runtime is based on.

func (*CamelCatalogSpec) GetCamelVersion 

func (c *CamelCatalogSpec) GetCamelVersion() string

GetCamelVersion returns the Camel version the runtime is based on.

func (*CamelCatalogSpec) GetQuarkusToolingImage 

func (c *CamelCatalogSpec) GetQuarkusToolingImage() string

GetQuarkusToolingImage returns the Quarkus tooling image required to build an application based on this catalog.

func (*CamelCatalogSpec) GetQuarkusVersion 

func (c *CamelCatalogSpec) GetQuarkusVersion() string

GetQuarkusVersion returns the Quarkus version the runtime is based on.

func (*CamelCatalogSpec) GetRuntimeVersion 

func (c *CamelCatalogSpec) GetRuntimeVersion() string

GetRuntimeVersion returns the Camel K runtime version of the catalog.

func (*CamelCatalogSpec) HasCapability 

func (c *CamelCatalogSpec) HasCapability(capability string) bool

HasCapability checks if the given capability is present in the catalog.

type CamelCatalogStatus 

type CamelCatalogStatus struct {
	// ObservedGeneration is the most recent generation observed for this Catalog.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// the actual phase
	Phase CamelCatalogPhase `json:"phase,omitempty"`
	// a list of events happened for the CamelCatalog
	Conditions []CamelCatalogCondition `json:"conditions,omitempty"`
	// the container image available for building an application with this catalog
	Image string `json:"image,omitempty"`
}

CamelCatalogStatus defines the observed state of CamelCatalog. As the catalog is a static resource, we expect it to be empty.

func (*CamelCatalogStatus) DeepCopy 

func (in *CamelCatalogStatus) DeepCopy() *CamelCatalogStatus

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

func (*CamelCatalogStatus) DeepCopyInto 

func (in *CamelCatalogStatus) DeepCopyInto(out *CamelCatalogStatus)

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

func (*CamelCatalogStatus) GetCondition 

func (in *CamelCatalogStatus) GetCondition(condType CamelCatalogConditionType) *CamelCatalogCondition

GetCondition returns the condition with the provided type.

func (*CamelCatalogStatus) GetConditions 

func (in *CamelCatalogStatus) GetConditions() []ResourceCondition

GetConditions --

func (*CamelCatalogStatus) RemoveCondition 

func (in *CamelCatalogStatus) RemoveCondition(condType CamelCatalogConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*CamelCatalogStatus) SetCondition 

func (in *CamelCatalogStatus) SetCondition(condType CamelCatalogConditionType, status corev1.ConditionStatus, reason string, message string)

SetCondition --

func (*CamelCatalogStatus) SetConditions 

func (in *CamelCatalogStatus) SetConditions(conditions ...CamelCatalogCondition)

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 (*CamelCatalogStatus) SetErrorCondition 

func (in *CamelCatalogStatus) SetErrorCondition(condType CamelCatalogConditionType, reason string, err error)

SetErrorCondition --

type CamelLoader 

type CamelLoader struct {
	// the base Maven artifact required
	MavenArtifact `json:",inline" yaml:",inline"`
	// a list of DSLs supported
	Languages []string `json:"languages,omitempty" yaml:"languages,omitempty"`
	// a list of additional dependencies required beside the base one
	Dependencies []MavenArtifact `json:"dependencies,omitempty" yaml:"dependencies,omitempty"`
	// the metadata of the loader
	Metadata map[string]string `json:"metadata,omitempty" yaml:"metadata,omitempty"`
}

CamelLoader represents the configuration required to load a DSL

func (*CamelLoader) DeepCopy 

func (in *CamelLoader) DeepCopy() *CamelLoader

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

func (*CamelLoader) DeepCopyInto 

func (in *CamelLoader) DeepCopyInto(out *CamelLoader)

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

type CamelScheme 

type CamelScheme struct {
	// the ID (ie, timer in a timer:xyz URI)
	ID string `json:"id" yaml:"id"`
	// is a passive scheme
	Passive bool `json:"passive" yaml:"passive"`
	// is a HTTP based scheme
	HTTP bool `json:"http" yaml:"http"`
	// required scope for consumer
	Consumer CamelSchemeScope `json:"consumer,omitempty" yaml:"consumer,omitempty"`
	// required scope for producers
	Producer CamelSchemeScope `json:"producer,omitempty" yaml:"producer,omitempty"`
}

CamelScheme represents the scheme used to identify a component in a URI (ie, timer in a timer:xyz endpoint URI)

func (*CamelScheme) DeepCopy 

func (in *CamelScheme) DeepCopy() *CamelScheme

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

func (*CamelScheme) DeepCopyInto 

func (in *CamelScheme) DeepCopyInto(out *CamelScheme)

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

type CamelSchemeScope 

type CamelSchemeScope struct {
	// list of dependencies needed for this scope
	Dependencies []CamelArtifactDependency `json:"dependencies,omitempty" yaml:"dependencies,omitempty"`
}

CamelSchemeScope contains scoped information about a scheme

func (*CamelSchemeScope) DeepCopy 

func (in *CamelSchemeScope) DeepCopy() *CamelSchemeScope

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

func (*CamelSchemeScope) DeepCopyInto 

func (in *CamelSchemeScope) DeepCopyInto(out *CamelSchemeScope)

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

type Capability 

type Capability struct {
	Dependencies []MavenArtifact `json:"dependencies" yaml:"dependencies"`
}

Capability is a particular feature which requires a well known set of dependencies

func (*Capability) DeepCopy 

func (in *Capability) DeepCopy() *Capability

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

func (*Capability) DeepCopyInto 

func (in *Capability) DeepCopyInto(out *Capability)

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

type Configurable 

type Configurable interface {
	Configurations() []ConfigurationSpec
}

Configurable --

type ConfigurationSpec 

type ConfigurationSpec struct {
	// represents the type of configuration, ie: property, configmap, secret, ...
	Type string `json:"type"`
	// the value to assign to the configuration (syntax may vary depending on the `Type`)
	Value string `json:"value"`
}

ConfigurationSpec represents a generic configuration specification

func (*ConfigurationSpec) DeepCopy 

func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

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

func (*ConfigurationSpec) DeepCopyInto 

func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)

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

func (*ConfigurationSpec) String 

func (in *ConfigurationSpec) String() string

type DataSpec 

type DataSpec struct {
	// the name of the specification
	Name string `json:"name,omitempty"`
	// the path where the file is stored
	Path string `json:"path,omitempty"`
	// the source code (plain text)
	Content string `json:"content,omitempty"`
	// the source code (binary)
	RawContent []byte `json:"rawContent,omitempty"`
	// the confimap reference holding the source content
	ContentRef string `json:"contentRef,omitempty"`
	// the confimap key holding the source content
	ContentKey string `json:"contentKey,omitempty"`
	// the content type (tipically text or binary)
	ContentType string `json:"contentType,omitempty"`
	// if the content is compressed (base64 encrypted)
	Compression bool `json:"compression,omitempty"`
}

DataSpec represents the way the source is materialized in the running `Pod`

func (*DataSpec) DeepCopy 

func (in *DataSpec) DeepCopy() *DataSpec

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

func (*DataSpec) DeepCopyInto 

func (in *DataSpec) DeepCopyInto(out *DataSpec)

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"`
	// 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 Failure 

type Failure struct {
	// a short text specifying the reason
	Reason string `json:"reason"`
	// the time when the failure has happened
	Time metav1.Time `json:"time"`
	// the recovery attempted for this failure
	Recovery FailureRecovery `json:"recovery"`
}

Failure represent a message specifying the reason and the time of an event failure

func (*Failure) DeepCopy 

func (in *Failure) DeepCopy() *Failure

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

func (*Failure) DeepCopyInto 

func (in *Failure) DeepCopyInto(out *Failure)

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

type FailureRecovery 

type FailureRecovery struct {
	// attempt number
	Attempt int `json:"attempt"`
	// maximum number of attempts
	AttemptMax int `json:"attemptMax"`
	// time of the attempt execution
	// +optional
	AttemptTime metav1.Time `json:"attemptTime"`
}

FailureRecovery defines the attempts to recover a failure

func (*FailureRecovery) DeepCopy 

func (in *FailureRecovery) DeepCopy() *FailureRecovery

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

func (*FailureRecovery) DeepCopyInto 

func (in *FailureRecovery) DeepCopyInto(out *FailureRecovery)

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

type Flow 

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

Flow is an unstructured object representing a Camel Flow in YAML/JSON DSL

func (*Flow) DeepCopy 

func (in *Flow) DeepCopy() *Flow

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

func (*Flow) DeepCopyInto 

func (in *Flow) DeepCopyInto(out *Flow)

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 HealthCheck 

type HealthCheck struct {
	Status HealthCheckStatus     `json:"status,omitempty" yaml:"status,omitempty"`
	Checks []HealthCheckResponse `json:"checks,omitempty" yaml:"checks,omitempty"`
}

func (*HealthCheck) DeepCopy 

func (in *HealthCheck) DeepCopy() *HealthCheck

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

func (*HealthCheck) DeepCopyInto 

func (in *HealthCheck) DeepCopyInto(out *HealthCheck)

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

type HealthCheckResponse 

type HealthCheckResponse struct {
	Name   string            `json:"name,omitempty" yaml:"name,omitempty"`
	Status HealthCheckStatus `json:"status,omitempty" yaml:"status,omitempty"`
	Data   RawMessage        `json:"data,omitempty" yaml:"data,omitempty"`
}

func (*HealthCheckResponse) DeepCopy 

func (in *HealthCheckResponse) DeepCopy() *HealthCheckResponse

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

func (*HealthCheckResponse) DeepCopyInto 

func (in *HealthCheckResponse) DeepCopyInto(out *HealthCheckResponse)

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

type HealthCheckStatus 

type HealthCheckStatus string
const (
	HealthCheckStatusDown HealthCheckStatus = "DOWN"
	HealthCheckStatusUp   HealthCheckStatus = "UP"
)

type Integration 

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

	// the desired Integration specification
	Spec IntegrationSpec `json:"spec,omitempty"`
	// the status of the Integration
	Status IntegrationStatus `json:"status,omitempty"`
}

Integration is the Schema for the integrations API

func NewIntegration 

func NewIntegration(namespace string, name string) Integration

func (*Integration) Configurations 

func (in *Integration) Configurations() []ConfigurationSpec

func (*Integration) DeepCopy 

func (in *Integration) DeepCopy() *Integration

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

func (*Integration) DeepCopyInto 

func (in *Integration) DeepCopyInto(out *Integration)

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

func (*Integration) DeepCopyObject 

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

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

func (*Integration) GetIntegrationKitNamespace 

func (in *Integration) GetIntegrationKitNamespace(p *IntegrationPlatform) string

func (*Integration) Initialize 

func (in *Integration) Initialize()

func (*Integration) IsConditionTrue 

func (in *Integration) IsConditionTrue(conditionType IntegrationConditionType) bool

IsConditionTrue checks if the condition with the given type is true.

func (*Integration) SetIntegrationKit 

func (in *Integration) SetIntegrationKit(kit *IntegrationKit)

func (*Integration) SetIntegrationPlatform 

func (in *Integration) SetIntegrationPlatform(platform *IntegrationPlatform)

func (*Integration) SetOperatorID 

func (in *Integration) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation

func (*Integration) SetReadyCondition 

func (in *Integration) SetReadyCondition(status corev1.ConditionStatus, reason, message string)

SetReadyCondition sets Ready condition with the given status, reason, and message.

func (*Integration) SetReadyConditionError 

func (in *Integration) SetReadyConditionError(err string)

SetReadyConditionError sets Ready condition to False with the given error message.

func (*Integration) Sources 

func (in *Integration) Sources() []SourceSpec

Sources return a new slice containing all the sources associated to the integration

type IntegrationCondition 

type IntegrationCondition struct {
	// Type of integration condition.
	Type IntegrationConditionType `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"`
	// First time the condition status transitioned to True.
	FirstTruthyTime *metav1.Time `json:"firstTruthyTime,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 []PodCondition `json:"pods,omitempty"`
}

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

func (*IntegrationCondition) DeepCopy 

func (in *IntegrationCondition) DeepCopy() *IntegrationCondition

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

func (*IntegrationCondition) DeepCopyInto 

func (in *IntegrationCondition) DeepCopyInto(out *IntegrationCondition)

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

func (IntegrationCondition) GetLastTransitionTime 

func (c IntegrationCondition) GetLastTransitionTime() metav1.Time

func (IntegrationCondition) GetLastUpdateTime 

func (c IntegrationCondition) GetLastUpdateTime() metav1.Time

func (IntegrationCondition) GetMessage 

func (c IntegrationCondition) GetMessage() string

func (IntegrationCondition) GetReason 

func (c IntegrationCondition) GetReason() string

func (IntegrationCondition) GetStatus 

func (c IntegrationCondition) GetStatus() corev1.ConditionStatus

func (IntegrationCondition) GetType 

func (c IntegrationCondition) GetType() string

type IntegrationConditionType 

type IntegrationConditionType string

IntegrationConditionType --

type IntegrationKit 

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

	// the desired configuration
	Spec IntegrationKitSpec `json:"spec,omitempty"`
	// the actual status
	Status IntegrationKitStatus `json:"status,omitempty"`
}

IntegrationKit defines a container image and additional configuration needed to run an `Integration`. An `IntegrationKit` is a generic image generally built from the requirements of an `Integration`, but agnostic to it, in order to be reused by any other `Integration` which has the same required set of capabilities. An `IntegrationKit` may be used for other kits as a base container layer, when the `incremental` build option is enabled.

func NewIntegrationKit 

func NewIntegrationKit(namespace string, name string) *IntegrationKit

func (*IntegrationKit) Configurations 

func (in *IntegrationKit) Configurations() []ConfigurationSpec

func (*IntegrationKit) DeepCopy 

func (in *IntegrationKit) DeepCopy() *IntegrationKit

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

func (*IntegrationKit) DeepCopyInto 

func (in *IntegrationKit) DeepCopyInto(out *IntegrationKit)

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

func (*IntegrationKit) DeepCopyObject 

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

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

func (*IntegrationKit) HasHigherPriorityThan 

func (in *IntegrationKit) HasHigherPriorityThan(kit *IntegrationKit) bool

func (*IntegrationKit) SetIntegrationPlatform 

func (in *IntegrationKit) SetIntegrationPlatform(platform *IntegrationPlatform)

func (*IntegrationKit) SetOperatorID 

func (in *IntegrationKit) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation

type IntegrationKitCondition 

type IntegrationKitCondition struct {
	// Type of integration condition.
	Type IntegrationKitConditionType `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"`
}

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

func (*IntegrationKitCondition) DeepCopy 

func (in *IntegrationKitCondition) DeepCopy() *IntegrationKitCondition

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

func (*IntegrationKitCondition) DeepCopyInto 

func (in *IntegrationKitCondition) DeepCopyInto(out *IntegrationKitCondition)

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

func (IntegrationKitCondition) GetLastTransitionTime 

func (c IntegrationKitCondition) GetLastTransitionTime() metav1.Time

func (IntegrationKitCondition) GetLastUpdateTime 

func (c IntegrationKitCondition) GetLastUpdateTime() metav1.Time

func (IntegrationKitCondition) GetMessage 

func (c IntegrationKitCondition) GetMessage() string

func (IntegrationKitCondition) GetReason 

func (c IntegrationKitCondition) GetReason() string

func (IntegrationKitCondition) GetStatus 

func (c IntegrationKitCondition) GetStatus() corev1.ConditionStatus

func (IntegrationKitCondition) GetType 

func (c IntegrationKitCondition) GetType() string

type IntegrationKitConditionType 

type IntegrationKitConditionType string

IntegrationKitConditionType --

type IntegrationKitList 

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

IntegrationKitList contains a list of IntegrationKit

func NewIntegrationKitList 

func NewIntegrationKitList() IntegrationKitList

func (*IntegrationKitList) DeepCopy 

func (in *IntegrationKitList) DeepCopy() *IntegrationKitList

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

func (*IntegrationKitList) DeepCopyInto 

func (in *IntegrationKitList) DeepCopyInto(out *IntegrationKitList)

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

func (*IntegrationKitList) DeepCopyObject 

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

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

type IntegrationKitPhase 

type IntegrationKitPhase string

IntegrationKitPhase --

type IntegrationKitSpec 

type IntegrationKitSpec struct {
	// the container image as identified in the container registry
	Image string `json:"image,omitempty"`
	// a list of Camel dependecies used by this kit
	Dependencies []string `json:"dependencies,omitempty"`
	// the profile which is expected by this kit
	Profile TraitProfile `json:"profile,omitempty"`
	// traits that the kit will execute
	Traits IntegrationKitTraits `json:"traits,omitempty"`
	// Deprecated:
	// Use camel trait (camel.properties) to manage properties
	// Use mount trait (mount.configs) to manage configs
	// Use mount trait (mount.resources) to manage resources
	// Use mount trait (mount.volumes) to manage volumes
	// configuration used by the kit
	Configuration []ConfigurationSpec `json:"configuration,omitempty"`
	// Maven repositories that can be used by the kit
	Repositories []string `json:"repositories,omitempty"`
	// the sources to add at build time
	Sources []SourceSpec `json:"sources,omitempty"`
}

IntegrationKitSpec defines a container image and additional configurations required to kick off an `Integration` with certain features

func (*IntegrationKitSpec) Configurations 

func (in *IntegrationKitSpec) Configurations() []ConfigurationSpec

func (*IntegrationKitSpec) DeepCopy 

func (in *IntegrationKitSpec) DeepCopy() *IntegrationKitSpec

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

func (*IntegrationKitSpec) DeepCopyInto 

func (in *IntegrationKitSpec) DeepCopyInto(out *IntegrationKitSpec)

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

type IntegrationKitStatus 

type IntegrationKitStatus struct {
	// ObservedGeneration is the most recent generation observed for this IntegrationKit.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// phase of the kit
	Phase IntegrationKitPhase `json:"phase,omitempty"`
	// base image used by the kit
	BaseImage string `json:"baseImage,omitempty"`
	// actual image name of the kit
	Image string `json:"image,omitempty"`
	// actual image digest of the kit
	Digest string `json:"digest,omitempty"`
	// list of artifacts used by the kit
	Artifacts []Artifact `json:"artifacts,omitempty"`
	// failure reason (if any)
	Failure *Failure `json:"failure,omitempty"`
	// the runtime version for which this kit was configured
	RuntimeVersion string `json:"runtimeVersion,omitempty"`
	// the runtime provider for which this kit was configured
	RuntimeProvider RuntimeProvider `json:"runtimeProvider,omitempty"`
	// the platform for which this kit was configured
	Platform string `json:"platform,omitempty"`
	// the Camel K operator version for which this kit was configured
	Version string `json:"version,omitempty"`
	// a list of conditions which happened for the events related the kit
	Conditions []IntegrationKitCondition `json:"conditions,omitempty"`
}

IntegrationKitStatus defines the observed state of IntegrationKit

func (*IntegrationKitStatus) DeepCopy 

func (in *IntegrationKitStatus) DeepCopy() *IntegrationKitStatus

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

func (*IntegrationKitStatus) DeepCopyInto 

func (in *IntegrationKitStatus) DeepCopyInto(out *IntegrationKitStatus)

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

func (*IntegrationKitStatus) GetCondition 

func (in *IntegrationKitStatus) GetCondition(condType IntegrationKitConditionType) *IntegrationKitCondition

GetCondition returns the condition with the provided type.

func (*IntegrationKitStatus) GetConditions 

func (in *IntegrationKitStatus) GetConditions() []ResourceCondition

func (*IntegrationKitStatus) RemoveCondition 

func (in *IntegrationKitStatus) RemoveCondition(condType IntegrationKitConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*IntegrationKitStatus) SetCondition 

func (in *IntegrationKitStatus) SetCondition(condType IntegrationKitConditionType, status corev1.ConditionStatus, reason string, message string)

func (*IntegrationKitStatus) SetConditions 

func (in *IntegrationKitStatus) SetConditions(conditions ...IntegrationKitCondition)

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 (*IntegrationKitStatus) SetErrorCondition 

func (in *IntegrationKitStatus) SetErrorCondition(condType IntegrationKitConditionType, reason string, err error)

type IntegrationKitTraits 

type IntegrationKitTraits struct {
	// The builder trait is internally used to determine the best strategy to build and configure IntegrationKits.
	Builder *trait.BuilderTrait `property:"builder" json:"builder,omitempty"`
	// The Camel trait sets up Camel configuration.
	Camel *trait.CamelTrait `property:"camel" json:"camel,omitempty"`
	// The Quarkus trait configures the Quarkus runtime.
	// It's enabled by default.
	// NOTE: Compiling to a native executable, i.e. when using `package-type=native`, is only supported for kamelets, as well as YAML and XML integrations. It also requires at least 4GiB of memory, so the Pod running the native build, that is either the operator Pod, or the build Pod (depending on the build strategy configured for the platform), must have enough memory available.
	Quarkus *trait.QuarkusTrait `property:"quarkus" json:"quarkus,omitempty"`
	// The Registry trait sets up Maven to use the Image registry as a Maven repository.
	Registry *trait.RegistryTrait `property:"registry" json:"registry,omitempty"`
	// The collection of addon trait configurations
	Addons map[string]AddonTrait `json:"addons,omitempty"`
}

IntegrationKitTraits defines traits assigned to an `IntegrationKit`

func (*IntegrationKitTraits) DeepCopy 

func (in *IntegrationKitTraits) DeepCopy() *IntegrationKitTraits

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

func (*IntegrationKitTraits) DeepCopyInto 

func (in *IntegrationKitTraits) DeepCopyInto(out *IntegrationKitTraits)

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

type IntegrationList 

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

IntegrationList contains a list of Integration

func NewIntegrationList 

func NewIntegrationList() IntegrationList

func (*IntegrationList) DeepCopy 

func (in *IntegrationList) DeepCopy() *IntegrationList

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

func (*IntegrationList) DeepCopyInto 

func (in *IntegrationList) DeepCopyInto(out *IntegrationList)

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

func (*IntegrationList) DeepCopyObject 

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

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

type IntegrationPhase 

type IntegrationPhase string

IntegrationPhase --

type IntegrationPlatform 

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

	Spec   IntegrationPlatformSpec   `json:"spec,omitempty"`
	Status IntegrationPlatformStatus `json:"status,omitempty"`
}

IntegrationPlatform is the resource used to drive the Camel K operator behavior. It defines the behavior of all Custom Resources (`IntegrationKit`, `Integration`, `Kamelet`) in the given namespace. When the Camel K operator is installed in `global` mode, you will need to specify an `IntegrationPlatform` in each namespace where you want the Camel K operator to be executed

func NewIntegrationPlatform 

func NewIntegrationPlatform(namespace string, name string) IntegrationPlatform

NewIntegrationPlatform --

func (*IntegrationPlatform) AddConfiguration 

func (in *IntegrationPlatform) AddConfiguration(confType string, confValue string)

AddConfiguration --

func (*IntegrationPlatform) Configurations 

func (in *IntegrationPlatform) Configurations() []ConfigurationSpec

Configurations --

func (*IntegrationPlatform) DeepCopy 

func (in *IntegrationPlatform) DeepCopy() *IntegrationPlatform

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

func (*IntegrationPlatform) DeepCopyInto 

func (in *IntegrationPlatform) DeepCopyInto(out *IntegrationPlatform)

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

func (*IntegrationPlatform) DeepCopyObject 

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

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

func (*IntegrationPlatform) GetActualValue 

func (in *IntegrationPlatform) GetActualValue(extractor func(spec IntegrationPlatformSpec) string) string

GetActualValue can be used to extract information the platform spec or its derived config in the status

func (*IntegrationPlatform) ResyncStatusFullConfig 

func (in *IntegrationPlatform) ResyncStatusFullConfig()

ResyncStatusFullConfig copies the spec configuration into the status field.

func (*IntegrationPlatform) SetOperatorID 

func (in *IntegrationPlatform) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation

type IntegrationPlatformBuildPublishStrategy 

type IntegrationPlatformBuildPublishStrategy string

IntegrationPlatformBuildPublishStrategy defines the strategy used to package and publish an Integration base image 

const (
	// IntegrationPlatformBuildPublishStrategyBuildah uses Buildah project (https://buildah.io/)
	// in order to push the incremental images to the image repository. It can be used with `pod` BuildStrategy.
	IntegrationPlatformBuildPublishStrategyBuildah IntegrationPlatformBuildPublishStrategy = "Buildah"
	// IntegrationPlatformBuildPublishStrategyKaniko uses Kaniko project (https://github.com/GoogleContainerTools/kaniko)
	// in order to push the incremental images to the image repository. It can be used with `pod` BuildStrategy.
	IntegrationPlatformBuildPublishStrategyKaniko IntegrationPlatformBuildPublishStrategy = "Kaniko"
	// IntegrationPlatformBuildPublishStrategyS2I uses the Source to Images (S2I) feature
	// (https://docs.openshift.com/container-platform/4.9/openshift_images/create-images.html#images-create-s2i_create-images)
	// provided by an OpenShift cluster in order to create and push the images to the registry. It is the default choice on OpenShift cluster
	IntegrationPlatformBuildPublishStrategyS2I IntegrationPlatformBuildPublishStrategy = "S2I"
	// IntegrationPlatformBuildPublishStrategySpectrum uses Spectrum project (https://github.com/container-tools/spectrum)
	// in order to push the incremental images to the image repository. It is the default choice on vanilla Kubernetes cluster
	IntegrationPlatformBuildPublishStrategySpectrum IntegrationPlatformBuildPublishStrategy = "Spectrum"
)

type IntegrationPlatformBuildSpec 

type IntegrationPlatformBuildSpec struct {
	// the configuration required to build an Integration container image
	BuildConfiguration BuildConfiguration `json:"buildConfiguration,omitempty"`
	// the strategy to adopt for publishing an Integration container image
	PublishStrategy IntegrationPlatformBuildPublishStrategy `json:"publishStrategy,omitempty"`
	// the Camel K Runtime dependency version
	RuntimeVersion string `json:"runtimeVersion,omitempty"`
	// the runtime used. Likely Camel Quarkus (we used to have main runtime which has been discontinued since version 1.5)
	RuntimeProvider RuntimeProvider `json:"runtimeProvider,omitempty"`
	// a base image that can be used as base layer for all images.
	// It can be useful if you want to provide some custom base image with further utility softwares
	BaseImage string `json:"baseImage,omitempty"`
	// the image registry used to push/pull Integration images
	Registry RegistrySpec `json:"registry,omitempty"`
	// the timeout (in seconds) to use when creating the build tools container image
	BuildCatalogToolTimeout *metav1.Duration `json:"buildCatalogToolTimeout,omitempty"`
	// how much time to wait before time out the pipeline process
	Timeout *metav1.Duration `json:"timeout,omitempty"`
	// Maven configuration used to build the Camel/Camel-Quarkus applications
	Maven MavenSpec `json:"maven,omitempty"`
	// Generic options that can used by any publish strategy
	PublishStrategyOptions map[string]string `json:"PublishStrategyOptions,omitempty"`
	// the maximum amount of parallel running pipelines started by this operator instance
	MaxRunningBuilds int32 `json:"maxRunningBuilds,omitempty"`
}

IntegrationPlatformBuildSpec contains platform related build information. This configuration can be used to tune the behavior of the Integration/IntegrationKit image builds. You can define the build strategy, the image registry to use and the Maven configuration to adopt.

func (*IntegrationPlatformBuildSpec) AddOption 

func (b *IntegrationPlatformBuildSpec) AddOption(option string, value string)

AddOption add a publish strategy option

func (*IntegrationPlatformBuildSpec) DeepCopy 

func (in *IntegrationPlatformBuildSpec) DeepCopy() *IntegrationPlatformBuildSpec

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

func (*IntegrationPlatformBuildSpec) DeepCopyInto 

func (in *IntegrationPlatformBuildSpec) DeepCopyInto(out *IntegrationPlatformBuildSpec)

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

func (IntegrationPlatformBuildSpec) GetBuildCatalogToolTimeout 

func (b IntegrationPlatformBuildSpec) GetBuildCatalogToolTimeout() metav1.Duration

GetBuildCatalogToolTimeout returns the specified duration or a default one

func (IntegrationPlatformBuildSpec) GetTimeout 

func (b IntegrationPlatformBuildSpec) GetTimeout() metav1.Duration

GetTimeout returns the specified duration or a default one

func (IntegrationPlatformBuildSpec) IsOptionEnabled 

func (b IntegrationPlatformBuildSpec) IsOptionEnabled(option string) bool

IsOptionEnabled tells if provided option key is present in PublishStrategyOptions and enabled

type IntegrationPlatformCluster 

type IntegrationPlatformCluster string

IntegrationPlatformCluster is the kind of orchestration cluster the platform is installed into 

const (
	// IntegrationPlatformClusterOpenShift is used when targeting an OpenShift cluster
	IntegrationPlatformClusterOpenShift IntegrationPlatformCluster = "OpenShift"
	// IntegrationPlatformClusterKubernetes is used when targeting a Kubernetes cluster
	IntegrationPlatformClusterKubernetes IntegrationPlatformCluster = "Kubernetes"
)

type IntegrationPlatformCondition 

type IntegrationPlatformCondition struct {
	// Type of integration condition.
	Type IntegrationPlatformConditionType `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"`
}

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

func (*IntegrationPlatformCondition) DeepCopy 

func (in *IntegrationPlatformCondition) DeepCopy() *IntegrationPlatformCondition

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

func (*IntegrationPlatformCondition) DeepCopyInto 

func (in *IntegrationPlatformCondition) DeepCopyInto(out *IntegrationPlatformCondition)

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

func (IntegrationPlatformCondition) GetLastTransitionTime 

func (c IntegrationPlatformCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --

func (IntegrationPlatformCondition) GetLastUpdateTime 

func (c IntegrationPlatformCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --

func (IntegrationPlatformCondition) GetMessage 

func (c IntegrationPlatformCondition) GetMessage() string

GetMessage --

func (IntegrationPlatformCondition) GetReason 

func (c IntegrationPlatformCondition) GetReason() string

GetReason --

func (IntegrationPlatformCondition) GetStatus 

func (c IntegrationPlatformCondition) GetStatus() corev1.ConditionStatus

GetStatus --

func (IntegrationPlatformCondition) GetType 

func (c IntegrationPlatformCondition) GetType() string

GetType --

type IntegrationPlatformConditionType 

type IntegrationPlatformConditionType string

IntegrationPlatformConditionType defines the type of condition

type IntegrationPlatformKameletRepositorySpec 

type IntegrationPlatformKameletRepositorySpec struct {
	// the remote repository in the format github:ORG/REPO/PATH_TO_KAMELETS_FOLDER
	URI string `json:"uri,omitempty"`
}

IntegrationPlatformKameletRepositorySpec defines the location of the Kamelet catalog to use

func (*IntegrationPlatformKameletRepositorySpec) DeepCopy 

func (in *IntegrationPlatformKameletRepositorySpec) DeepCopy() *IntegrationPlatformKameletRepositorySpec

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

func (*IntegrationPlatformKameletRepositorySpec) DeepCopyInto 

func (in *IntegrationPlatformKameletRepositorySpec) DeepCopyInto(out *IntegrationPlatformKameletRepositorySpec)

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

type IntegrationPlatformKameletSpec 

type IntegrationPlatformKameletSpec struct {
	// remote repository used to retrieve Kamelet catalog
	Repositories []IntegrationPlatformKameletRepositorySpec `json:"repositories,omitempty"`
}

IntegrationPlatformKameletSpec define the behavior for all the Kamelets controller by the IntegrationPlatform

func (*IntegrationPlatformKameletSpec) DeepCopy 

func (in *IntegrationPlatformKameletSpec) DeepCopy() *IntegrationPlatformKameletSpec

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

func (*IntegrationPlatformKameletSpec) DeepCopyInto 

func (in *IntegrationPlatformKameletSpec) DeepCopyInto(out *IntegrationPlatformKameletSpec)

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

type IntegrationPlatformList 

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

IntegrationPlatformList contains a list of IntegrationPlatform

func NewIntegrationPlatformList 

func NewIntegrationPlatformList() IntegrationPlatformList

NewIntegrationPlatformList --

func (*IntegrationPlatformList) DeepCopy 

func (in *IntegrationPlatformList) DeepCopy() *IntegrationPlatformList

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

func (*IntegrationPlatformList) DeepCopyInto 

func (in *IntegrationPlatformList) DeepCopyInto(out *IntegrationPlatformList)

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

func (*IntegrationPlatformList) DeepCopyObject 

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

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

type IntegrationPlatformPhase 

type IntegrationPlatformPhase string

IntegrationPlatformPhase is the phase of an IntegrationPlatform

type IntegrationPlatformSpec 

type IntegrationPlatformSpec struct {
	// what kind of cluster you're running (ie, plain Kubernetes or OpenShift)
	Cluster IntegrationPlatformCluster `json:"cluster,omitempty"`
	// the profile you wish to use. It will apply certain traits which are required by the specific profile chosen.
	// It usually relates the Cluster with the optional definition of special profiles (ie, Knative)
	Profile TraitProfile `json:"profile,omitempty"`
	// specify how to build the Integration/IntegrationKits
	Build IntegrationPlatformBuildSpec `json:"build,omitempty"`
	// list of traits to be executed for all the Integration/IntegrationKits built from this IntegrationPlatform
	Traits Traits `json:"traits,omitempty"`
	// Deprecated:
	// Use camel trait (camel.properties) to manage properties
	// Use mount trait (mount.configs) to manage configs
	// Use mount trait (mount.resources) to manage resources
	// Use mount trait (mount.volumes) to manage volumes
	// list of configuration properties to be attached to all the Integration/IntegrationKits built from this IntegrationPlatform
	Configuration []ConfigurationSpec `json:"configuration,omitempty"`
	// configuration to be executed to all Kamelets controlled by this IntegrationPlatform
	Kamelet IntegrationPlatformKameletSpec `json:"kamelet,omitempty"`
}

IntegrationPlatformSpec defines the desired state of IntegrationPlatform

func (*IntegrationPlatformSpec) Configurations 

func (in *IntegrationPlatformSpec) Configurations() []ConfigurationSpec

Configurations --

func (*IntegrationPlatformSpec) DeepCopy 

func (in *IntegrationPlatformSpec) DeepCopy() *IntegrationPlatformSpec

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

func (*IntegrationPlatformSpec) DeepCopyInto 

func (in *IntegrationPlatformSpec) DeepCopyInto(out *IntegrationPlatformSpec)

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

type IntegrationPlatformStatus 

type IntegrationPlatformStatus struct {
	IntegrationPlatformSpec `json:",inline"`
	// ObservedGeneration is the most recent generation observed for this IntegrationPlatform.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// defines in what phase the IntegrationPlatform is found
	Phase IntegrationPlatformPhase `json:"phase,omitempty"`
	// which are the conditions met (particularly useful when in ERROR phase)
	Conditions []IntegrationPlatformCondition `json:"conditions,omitempty"`
	// the Camel K operator version controlling this IntegrationPlatform
	Version string `json:"version,omitempty"`
	// generic information related to the build of Camel K operator software
	Info map[string]string `json:"info,omitempty"`
}

IntegrationPlatformStatus defines the observed state of IntegrationPlatform

func (*IntegrationPlatformStatus) DeepCopy 

func (in *IntegrationPlatformStatus) DeepCopy() *IntegrationPlatformStatus

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

func (*IntegrationPlatformStatus) DeepCopyInto 

func (in *IntegrationPlatformStatus) DeepCopyInto(out *IntegrationPlatformStatus)

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

func (*IntegrationPlatformStatus) GetCondition 

func (in *IntegrationPlatformStatus) GetCondition(condType IntegrationPlatformConditionType) *IntegrationPlatformCondition

GetCondition returns the condition with the provided type.

func (*IntegrationPlatformStatus) GetConditions 

func (in *IntegrationPlatformStatus) GetConditions() []ResourceCondition

GetConditions --

func (*IntegrationPlatformStatus) RemoveCondition 

func (in *IntegrationPlatformStatus) RemoveCondition(condType IntegrationPlatformConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*IntegrationPlatformStatus) SetCondition 

func (in *IntegrationPlatformStatus) SetCondition(condType IntegrationPlatformConditionType, status corev1.ConditionStatus, reason string, message string)

SetCondition sets the condition with the given status, reason, and message.

func (*IntegrationPlatformStatus) SetConditions 

func (in *IntegrationPlatformStatus) SetConditions(conditions ...IntegrationPlatformCondition)

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 (*IntegrationPlatformStatus) SetErrorCondition 

func (in *IntegrationPlatformStatus) SetErrorCondition(condType IntegrationPlatformConditionType, reason string, err error)

SetErrorCondition sets the condition with the given reason and error message.

type IntegrationSpec 

type IntegrationSpec struct {
	// the number of `Pods` needed for the running Integration
	Replicas *int32 `json:"replicas,omitempty"`
	// the sources which contain the Camel routes to run
	Sources []SourceSpec `json:"sources,omitempty"`
	// a source in YAML DSL language which contain the routes to run
	Flows []Flow `json:"flows,omitempty"`
	// the reference of the `IntegrationKit` which is used for this Integration
	IntegrationKit *corev1.ObjectReference `json:"integrationKit,omitempty"`
	// the list of Camel or Maven dependencies required by the Integration
	Dependencies []string `json:"dependencies,omitempty"`
	// the profile needed to run this Integration
	Profile TraitProfile `json:"profile,omitempty"`
	// the traits needed to run this Integration
	Traits Traits `json:"traits,omitempty"`
	// Pod template customization
	PodTemplate *PodSpecTemplate `json:"template,omitempty"`
	// Deprecated:
	// Use camel trait (camel.properties) to manage properties
	// Use mount trait (mount.configs) to manage configs
	// Use mount trait (mount.resources) to manage resources
	// Use mount trait (mount.volumes) to manage volumes
	Configuration []ConfigurationSpec `json:"configuration,omitempty"`
	// additional Maven repositories to be used
	Repositories []string `json:"repositories,omitempty"`
	// custom SA to use for the Integration
	ServiceAccountName string `json:"serviceAccountName,omitempty"`
}

IntegrationSpec specifies the configuration of an Integration. The Integration will be watched by the operator which will be in charge to run the related application, according to the configuration specified.

func (*IntegrationSpec) AddConfiguration 

func (in *IntegrationSpec) AddConfiguration(confType string, confValue string)

func (*IntegrationSpec) AddDependency 

func (in *IntegrationSpec) AddDependency(dependency string)

func (*IntegrationSpec) AddFlows 

func (in *IntegrationSpec) AddFlows(flows ...Flow)

func (*IntegrationSpec) AddSource 

func (in *IntegrationSpec) AddSource(name string, content string, language Language)

func (*IntegrationSpec) AddSources 

func (in *IntegrationSpec) AddSources(sources ...SourceSpec)

func (*IntegrationSpec) Configurations 

func (in *IntegrationSpec) Configurations() []ConfigurationSpec

func (*IntegrationSpec) DeepCopy 

func (in *IntegrationSpec) DeepCopy() *IntegrationSpec

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

func (*IntegrationSpec) DeepCopyInto 

func (in *IntegrationSpec) DeepCopyInto(out *IntegrationSpec)

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

func (*IntegrationSpec) GetConfigurationProperty 

func (in *IntegrationSpec) GetConfigurationProperty(property string) string

GetConfigurationProperty returns a configuration property

type IntegrationStatus 

type IntegrationStatus struct {
	// ObservedGeneration is the most recent generation observed for this Integration.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// the actual phase
	Phase IntegrationPhase `json:"phase,omitempty"`
	// the digest calculated for this Integration
	Digest string `json:"digest,omitempty"`
	// the container image used
	Image string `json:"image,omitempty"`
	// a list of dependencies needed by the application
	Dependencies []string `json:"dependencies,omitempty"`
	// the profile needed to run this Integration
	Profile TraitProfile `json:"profile,omitempty"`
	// the reference of the `IntegrationKit` which is used for this Integration
	IntegrationKit *corev1.ObjectReference `json:"integrationKit,omitempty"`
	// The IntegrationPlatform watching this Integration
	Platform string `json:"platform,omitempty"`
	// a list of sources generated for this Integration
	GeneratedSources []SourceSpec `json:"generatedSources,omitempty"`
	// the runtime version targeted for this Integration
	RuntimeVersion string `json:"runtimeVersion,omitempty"`
	// the runtime provider targeted for this Integration
	RuntimeProvider RuntimeProvider `json:"runtimeProvider,omitempty"`
	// Deprecated:
	// a list of configuration specification
	Configuration []ConfigurationSpec `json:"configuration,omitempty"`
	// a list of events happened for the Integration
	Conditions []IntegrationCondition `json:"conditions,omitempty"`
	// the operator version
	Version string `json:"version,omitempty"`
	// the number of replicas
	Replicas *int32 `json:"replicas,omitempty"`
	// label selector
	Selector string `json:"selector,omitempty"`
	// features offered by the Integration
	Capabilities []string `json:"capabilities,omitempty"`
	// the timestamp representing the last time when this integration was initialized.
	InitializationTimestamp *metav1.Time `json:"lastInitTimestamp,omitempty"`
}

IntegrationStatus defines the observed state of Integration

func (*IntegrationStatus) AddConfigurationsIfMissing 

func (in *IntegrationStatus) AddConfigurationsIfMissing(configurations ...ConfigurationSpec)

func (*IntegrationStatus) AddOrReplaceGeneratedSources 

func (in *IntegrationStatus) AddOrReplaceGeneratedSources(sources ...SourceSpec)

func (*IntegrationStatus) Configurations 

func (in *IntegrationStatus) Configurations() []ConfigurationSpec

func (*IntegrationStatus) DeepCopy 

func (in *IntegrationStatus) DeepCopy() *IntegrationStatus

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

func (*IntegrationStatus) DeepCopyInto 

func (in *IntegrationStatus) DeepCopyInto(out *IntegrationStatus)

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

func (*IntegrationStatus) GetCondition 

func (in *IntegrationStatus) GetCondition(condType IntegrationConditionType) *IntegrationCondition

GetCondition returns the condition with the provided type.

func (*IntegrationStatus) GetConditions 

func (in *IntegrationStatus) GetConditions() []ResourceCondition

func (*IntegrationStatus) RemoveCondition 

func (in *IntegrationStatus) RemoveCondition(condType IntegrationConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*IntegrationStatus) SetCondition 

func (in *IntegrationStatus) SetCondition(condType IntegrationConditionType, status corev1.ConditionStatus, reason string, message string)

func (*IntegrationStatus) SetConditions 

func (in *IntegrationStatus) SetConditions(conditions ...IntegrationCondition)

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 (*IntegrationStatus) SetErrorCondition 

func (in *IntegrationStatus) SetErrorCondition(condType IntegrationConditionType, reason string, err error)

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 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 []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() []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 KanikoTask 

type KanikoTask struct {
	BaseTask    `json:",inline"`
	PublishTask `json:",inline"`
	// log more information
	Verbose *bool `json:"verbose,omitempty"`
	// use a cache
	Cache KanikoTaskCache `json:"cache,omitempty"`
	// docker image to use
	ExecutorImage string `json:"executorImage,omitempty"`
}

KanikoTask is used to configure Kaniko

func (*KanikoTask) DeepCopy 

func (in *KanikoTask) DeepCopy() *KanikoTask

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

func (*KanikoTask) DeepCopyInto 

func (in *KanikoTask) DeepCopyInto(out *KanikoTask)

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

type KanikoTaskCache 

type KanikoTaskCache struct {
	// true if a cache is enabled
	Enabled *bool `json:"enabled,omitempty"`
	// the PVC used to store the cache
	PersistentVolumeClaim string `json:"persistentVolumeClaim,omitempty"`
}

KanikoTaskCache is used to configure Kaniko cache

func (*KanikoTaskCache) DeepCopy 

func (in *KanikoTaskCache) DeepCopy() *KanikoTaskCache

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

func (*KanikoTaskCache) DeepCopyInto 

func (in *KanikoTaskCache) DeepCopyInto(out *KanikoTaskCache)

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

type Language 

type Language string

Language represents a supported language (Camel DSL) 

const (
	// LanguageJavaSource used for Java
	LanguageJavaSource Language = "java"
	// LanguageGroovy used for Groovy
	LanguageGroovy Language = "groovy"
	// LanguageJavaScript  used for Javascript
	LanguageJavaScript Language = "js"
	// LanguageXML used for XML
	LanguageXML Language = "xml"
	// LanguageKotlin used for Kotlin
	LanguageKotlin Language = "kts"
	// LanguageYaml used for YAML
	LanguageYaml Language = "yaml"
	// LanguageKamelet used for Kamelets
	LanguageKamelet Language = "kamelet"
	// LanguageJavaShell used for Java Shell
	LanguageJavaShell Language = "jsh"
)

type MavenArtifact 

type MavenArtifact struct {
	// Maven Group
	GroupID string `json:"groupId" yaml:"groupId" xml:"groupId"`
	// Maven Artifact
	ArtifactID string `json:"artifactId" yaml:"artifactId" xml:"artifactId"`
	// Maven Version
	Version string `json:"version,omitempty" yaml:"version,omitempty" xml:"version,omitempty"`
}

MavenArtifact defines a GAV (Group:Artifact:Version) Maven artifact

func (*MavenArtifact) DeepCopy 

func (in *MavenArtifact) DeepCopy() *MavenArtifact

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

func (*MavenArtifact) DeepCopyInto 

func (in *MavenArtifact) DeepCopyInto(out *MavenArtifact)

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

func (*MavenArtifact) GetDependencyID 

func (in *MavenArtifact) GetDependencyID() string

type MavenBuildSpec 

type MavenBuildSpec struct {
	// base Maven specification
	MavenSpec `json:",inline"`
	// additional repositories
	Repositories []Repository `json:"repositories,omitempty"`
	// Servers (auth)
	Servers []Server `json:"servers,omitempty"`
}

MavenBuildSpec defines the Maven configuration plus additional repositories to use

func (*MavenBuildSpec) DeepCopy 

func (in *MavenBuildSpec) DeepCopy() *MavenBuildSpec

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

func (*MavenBuildSpec) DeepCopyInto 

func (in *MavenBuildSpec) DeepCopyInto(out *MavenBuildSpec)

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

type MavenSpec 

type MavenSpec struct {
	// The path of the local Maven repository.
	LocalRepository string `json:"localRepository,omitempty"`
	// The Maven properties.
	Properties map[string]string `json:"properties,omitempty"`
	// A reference to the ConfigMap or Secret key that contains
	// the Maven settings.
	Settings ValueSource `json:"settings,omitempty"`
	// A reference to the ConfigMap or Secret key that contains
	// the security of the Maven settings.
	SettingsSecurity ValueSource `json:"settingsSecurity,omitempty"`
	// The Secrets name and key, containing the CA certificate(s) used to connect
	// to remote Maven repositories.
	// It can contain X.509 certificates, and PKCS#7 formatted certificate chains.
	// A JKS formatted keystore is automatically created to store the CA certificate(s),
	// and configured to be used as a trusted certificate(s) by the Maven commands.
	// Note that the root CA certificates are also imported into the created keystore.
	CASecrets []corev1.SecretKeySelector `json:"caSecrets,omitempty"`
	// The Maven build extensions.
	// See https://maven.apache.org/guides/mini/guide-using-extensions.html.
	Extension []MavenArtifact `json:"extension,omitempty"`
	// The CLI options that are appended to the list of arguments for Maven commands,
	// e.g., `-V,--no-transfer-progress,-Dstyle.color=never`.
	// See https://maven.apache.org/ref/3.8.4/maven-embedder/cli.html.
	CLIOptions []string `json:"cliOptions,omitempty"`
}

MavenSpec --

func (*MavenSpec) DeepCopy 

func (in *MavenSpec) DeepCopy() *MavenSpec

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

func (*MavenSpec) DeepCopyInto 

func (in *MavenSpec) DeepCopyInto(out *MavenSpec)

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

type Pipe 

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

	// the specification of a Pipe
	Spec PipeSpec `json:"spec,omitempty"`
	// the status of a Pipe
	Status PipeStatus `json:"status,omitempty"`
}

Pipe is the Schema for the Pipe API

func NewPipe 

func NewPipe(namespace string, name string) Pipe

NewPipe --

func (*Pipe) DeepCopy 

func (in *Pipe) DeepCopy() *Pipe

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

func (*Pipe) DeepCopyInto 

func (in *Pipe) DeepCopyInto(out *Pipe)

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

func (*Pipe) DeepCopyObject 

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

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

func (*Pipe) SetOperatorID 

func (in *Pipe) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation

type PipeCondition 

type PipeCondition struct {
	// Type of pipe condition.
	Type PipeConditionType `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 []PodCondition `json:"pods,omitempty"`
}

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

func (*PipeCondition) DeepCopy 

func (in *PipeCondition) DeepCopy() *PipeCondition

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

func (*PipeCondition) DeepCopyInto 

func (in *PipeCondition) DeepCopyInto(out *PipeCondition)

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

func (PipeCondition) GetLastTransitionTime 

func (c PipeCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --

func (PipeCondition) GetLastUpdateTime 

func (c PipeCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --

func (PipeCondition) GetMessage 

func (c PipeCondition) GetMessage() string

GetMessage --

func (PipeCondition) GetReason 

func (c PipeCondition) GetReason() string

GetReason --

func (PipeCondition) GetStatus 

func (c PipeCondition) GetStatus() corev1.ConditionStatus

GetStatus --

func (PipeCondition) GetType 

func (c PipeCondition) GetType() string

GetType --

type PipeConditionType 

type PipeConditionType string

PipeConditionType -- 

const (
	// PipeConditionReady --
	PipeConditionReady PipeConditionType = "Ready"
	// PipeIntegrationConditionError is used to report the error on the generated Integration
	PipeIntegrationConditionError PipeConditionType = "IntegrationError"
)

type PipeList 

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

PipeList contains a list of Pipe

func NewPipeList 

func NewPipeList() PipeList

NewPipeList --

func (*PipeList) DeepCopy 

func (in *PipeList) DeepCopy() *PipeList

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

func (*PipeList) DeepCopyInto 

func (in *PipeList) DeepCopyInto(out *PipeList)

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

func (*PipeList) DeepCopyObject 

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

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

type PipePhase 

type PipePhase string

PipePhase --

type PipeSpec 

type PipeSpec struct {
	// Integration is an optional integration used to specify custom parameters
	Integration *IntegrationSpec `json:"integration,omitempty"`
	// Source is the starting point of the integration defined by this Pipe
	Source Endpoint `json:"source,omitempty"`
	// Sink is the destination of the integration defined by this Pipe
	Sink Endpoint `json:"sink,omitempty"`
	// ErrorHandler is an optional handler called upon an error occuring 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 Pipe
	Replicas *int32 `json:"replicas,omitempty"`
	// Custom SA to use for the Pipe
	ServiceAccountName string `json:"serviceAccountName,omitempty"`
}

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

func (*PipeSpec) DeepCopy 

func (in *PipeSpec) DeepCopy() *PipeSpec

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

func (*PipeSpec) DeepCopyInto 

func (in *PipeSpec) DeepCopyInto(out *PipeSpec)

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

type PipeStatus 

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

PipeStatus specify the status of a Pipe

func (*PipeStatus) DeepCopy 

func (in *PipeStatus) DeepCopy() *PipeStatus

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

func (*PipeStatus) DeepCopyInto 

func (in *PipeStatus) DeepCopyInto(out *PipeStatus)

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

func (*PipeStatus) GetCondition 

func (in *PipeStatus) GetCondition(condType PipeConditionType) *PipeCondition

GetCondition returns the condition with the provided type.

func (*PipeStatus) GetConditions 

func (in *PipeStatus) GetConditions() []ResourceCondition

GetConditions --

func (*PipeStatus) RemoveCondition 

func (in *PipeStatus) RemoveCondition(condType PipeConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*PipeStatus) SetCondition 

func (in *PipeStatus) SetCondition(condType PipeConditionType, status corev1.ConditionStatus, reason string, message string)

SetCondition --

func (*PipeStatus) SetConditions 

func (in *PipeStatus) SetConditions(conditions ...PipeCondition)

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 (*PipeStatus) SetErrorCondition 

func (in *PipeStatus) SetErrorCondition(condType PipeConditionType, reason string, err error)

SetErrorCondition --

type PluginProperties 

type PluginProperties map[string]StringOrProperties

func (PluginProperties) Add 

func (m PluginProperties) Add(key string, value string)

func (PluginProperties) AddAll 

func (m PluginProperties) AddAll(properties map[string]string)

func (PluginProperties) AddProperties 

func (m PluginProperties) AddProperties(key string, properties map[string]string)

func (PluginProperties) DeepCopy 

func (in PluginProperties) DeepCopy() PluginProperties

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

func (PluginProperties) DeepCopyInto 

func (in PluginProperties) DeepCopyInto(out *PluginProperties)

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

func (PluginProperties) MarshalXML 

func (m PluginProperties) MarshalXML(e *xml.Encoder, start xml.StartElement) error

type PodCondition 

type PodCondition struct {
	Name      string                `json:"name,omitempty" yaml:"name,omitempty"`
	Condition corev1.PodCondition   `json:"condition" yaml:"condition"`
	Health    []HealthCheckResponse `json:"health,omitempty" yaml:"health,omitempty"`
}

func (*PodCondition) DeepCopy 

func (in *PodCondition) DeepCopy() *PodCondition

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

func (*PodCondition) DeepCopyInto 

func (in *PodCondition) DeepCopyInto(out *PodCondition)

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

type PodSpec 

type PodSpec struct {
	// Volumes
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge,retainKeys" patchMergeKey:"name" protobuf:"bytes,1,rep,name=volumes"`
	// InitContainers
	InitContainers []corev1.Container `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,20,rep,name=initContainers"`
	// Containers
	Containers []corev1.Container `json:"containers" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=containers"`
	// EphemeralContainers
	EphemeralContainers []corev1.EphemeralContainer `` /* 128-byte string literal not displayed */
	// RestartPolicy
	RestartPolicy corev1.RestartPolicy `json:"restartPolicy,omitempty" protobuf:"bytes,3,opt,name=restartPolicy,casttype=RestartPolicy"`
	// TerminationGracePeriodSeconds
	TerminationGracePeriodSeconds *int64 `json:"terminationGracePeriodSeconds,omitempty" protobuf:"varint,4,opt,name=terminationGracePeriodSeconds"`
	// ActiveDeadlineSeconds
	ActiveDeadlineSeconds *int64 `json:"activeDeadlineSeconds,omitempty" protobuf:"varint,5,opt,name=activeDeadlineSeconds"`
	// DNSPolicy
	DNSPolicy corev1.DNSPolicy `json:"dnsPolicy,omitempty" protobuf:"bytes,6,opt,name=dnsPolicy,casttype=DNSPolicy"`
	// NodeSelector
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,rep,name=nodeSelector"`
	// TopologySpreadConstraints
	TopologySpreadConstraints []corev1.TopologySpreadConstraint `` /* 147-byte string literal not displayed */
	// PodSecurityContext
	SecurityContext corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,34,opt,name=securityContext"`
}

PodSpec defines a group of Kubernetes resources

func (*PodSpec) DeepCopy 

func (in *PodSpec) DeepCopy() *PodSpec

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

func (*PodSpec) DeepCopyInto 

func (in *PodSpec) DeepCopyInto(out *PodSpec)

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

type PodSpecTemplate 

type PodSpecTemplate struct {
	// the specification
	Spec PodSpec `json:"spec,omitempty"`
}

PodSpecTemplate represent a template used to deploy an Integration `Pod`

func (*PodSpecTemplate) DeepCopy 

func (in *PodSpecTemplate) DeepCopy() *PodSpecTemplate

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

func (*PodSpecTemplate) DeepCopyInto 

func (in *PodSpecTemplate) DeepCopyInto(out *PodSpecTemplate)

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

type Properties 

type Properties map[string]string

func (Properties) Add 

func (m Properties) Add(key string, value string)

func (Properties) AddAll 

func (m Properties) AddAll(properties map[string]string)

func (Properties) DeepCopy 

func (in Properties) DeepCopy() Properties

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

func (Properties) DeepCopyInto 

func (in Properties) DeepCopyInto(out *Properties)

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

func (Properties) MarshalXML 

func (m Properties) MarshalXML(e *xml.Encoder, start xml.StartElement) error

type PublishTask 

type PublishTask struct {
	// can be useful to share info with other tasks
	ContextDir string `json:"contextDir,omitempty"`
	// base image layer
	BaseImage string `json:"baseImage,omitempty"`
	// final image name
	Image string `json:"image,omitempty"`
	// where to publish the final image
	Registry RegistrySpec `json:"registry,omitempty"`
}

PublishTask image publish configuration

func (*PublishTask) DeepCopy 

func (in *PublishTask) DeepCopy() *PublishTask

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

func (*PublishTask) DeepCopyInto 

func (in *PublishTask) DeepCopyInto(out *PublishTask)

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

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 RegistrySpec 

type RegistrySpec struct {
	// if the container registry is insecure (ie, http only)
	Insecure bool `json:"insecure,omitempty"`
	// the URI to access
	Address string `json:"address,omitempty"`
	// the secret where credentials are stored
	Secret string `json:"secret,omitempty"`
	// the configmap which stores the Certificate Authority
	CA string `json:"ca,omitempty"`
	// the registry organization
	Organization string `json:"organization,omitempty"`
}

RegistrySpec provides the configuration for the container registry

func (*RegistrySpec) DeepCopy 

func (in *RegistrySpec) DeepCopy() *RegistrySpec

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

func (*RegistrySpec) DeepCopyInto 

func (in *RegistrySpec) DeepCopyInto(out *RegistrySpec)

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

type Repository 

type Repository struct {
	// identifies the repository
	ID string `xml:"id" json:"id"`
	// name of the repository
	Name string `xml:"name,omitempty" json:"name,omitempty"`
	// location of the repository
	URL string `xml:"url" json:"url"`
	// can use snapshot
	Snapshots RepositoryPolicy `xml:"snapshots,omitempty" json:"snapshots,omitempty"`
	// can use stable releases
	Releases RepositoryPolicy `xml:"releases,omitempty" json:"releases,omitempty"`
}

Repository defines a Maven repository

func (*Repository) DeepCopy 

func (in *Repository) DeepCopy() *Repository

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

func (*Repository) DeepCopyInto 

func (in *Repository) DeepCopyInto(out *Repository)

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

type RepositoryPolicy 

type RepositoryPolicy struct {
	// is the policy activated or not
	Enabled bool `xml:"enabled" json:"enabled"`
	// This element specifies how often updates should attempt to occur.
	// Maven will compare the local POM's timestamp (stored in a repository's maven-metadata file) to the remote.
	// The choices are: `always`, `daily` (default), `interval:X` (where X is an integer in minutes) or `never`
	UpdatePolicy string `xml:"updatePolicy,omitempty" json:"updatePolicy,omitempty"`
	// When Maven deploys files to the repository, it also deploys corresponding checksum files.
	// Your options are to `ignore`, `fail`, or `warn` on missing or incorrect checksums.
	ChecksumPolicy string `xml:"checksumPolicy,omitempty" json:"checksumPolicy,omitempty"`
}

RepositoryPolicy defines the policy associated to a Maven repository

func (*RepositoryPolicy) DeepCopy 

func (in *RepositoryPolicy) DeepCopy() *RepositoryPolicy

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

func (*RepositoryPolicy) DeepCopyInto 

func (in *RepositoryPolicy) DeepCopyInto(out *RepositoryPolicy)

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

type ResourceCondition 

type ResourceCondition interface {
	GetType() string
	GetStatus() corev1.ConditionStatus
	GetLastUpdateTime() metav1.Time
	GetLastTransitionTime() metav1.Time
	GetReason() string
	GetMessage() string
}

ResourceCondition is a common type for all conditions

type RuntimeProvider 

type RuntimeProvider string

RuntimeProvider is the provider chosen for the runtime 

const (
	// RuntimeProviderQuarkus Camel Quarkus runtime
	RuntimeProviderQuarkus RuntimeProvider = "quarkus"
)

type RuntimeSpec 

type RuntimeSpec struct {
	// Camel K Runtime version
	Version string `json:"version" yaml:"version"`
	// Camel main application provider, ie, Camel Quarkus
	Provider RuntimeProvider `json:"provider" yaml:"provider"`
	// application entry point (main) to be executed
	ApplicationClass string `json:"applicationClass" yaml:"applicationClass"`
	// list of dependencies needed to run the application
	Dependencies []MavenArtifact `json:"dependencies" yaml:"dependencies"`
	// set of metadata
	Metadata map[string]string `json:"metadata,omitempty" yaml:"metadata,omitempty"`
	// features offered by this runtime
	Capabilities map[string]Capability `json:"capabilities,omitempty" yaml:"capabilities,omitempty"`
}

RuntimeSpec represents the configuration for the Java runtime in charge to execute the Camel application

func (*RuntimeSpec) CapabilityDependencies 

func (in *RuntimeSpec) CapabilityDependencies(capability string) []MavenArtifact

func (*RuntimeSpec) DeepCopy 

func (in *RuntimeSpec) DeepCopy() *RuntimeSpec

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

func (*RuntimeSpec) DeepCopyInto 

func (in *RuntimeSpec) DeepCopyInto(out *RuntimeSpec)

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

type S2iTask 

type S2iTask struct {
	BaseTask `json:",inline"`
	// can be useful to share info with other tasks
	ContextDir string `json:"contextDir,omitempty"`
	// used by the ImageStream
	Tag string `json:"tag,omitempty"`
}

S2iTask is used to configure S2I

func (*S2iTask) DeepCopy 

func (in *S2iTask) DeepCopy() *S2iTask

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

func (*S2iTask) DeepCopyInto 

func (in *S2iTask) DeepCopyInto(out *S2iTask)

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

type Server 

type Server struct {
	XMLName       xml.Name   `xml:"server" json:"-"`
	ID            string     `xml:"id,omitempty" json:"id,omitempty"`
	Username      string     `xml:"username,omitempty" json:"username,omitempty"`
	Password      string     `xml:"password,omitempty" json:"password,omitempty"`
	Configuration Properties `xml:"configuration,omitempty" json:"configuration,omitempty"`
}

func (*Server) DeepCopy 

func (in *Server) DeepCopy() *Server

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

func (*Server) DeepCopyInto 

func (in *Server) DeepCopyInto(out *Server)

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

type SourceSpec 

type SourceSpec struct {
	// contains configuration related to the source code
	DataSpec `json:",inline"`
	// specify which is the language (Camel DSL) used to interpret this source code
	Language Language `json:"language,omitempty"`
	// Loader is an optional id of the org.apache.camel.k.RoutesLoader that will
	// interpret this source at runtime
	Loader string `json:"loader,omitempty"`
	// Interceptors are optional identifiers the org.apache.camel.k.RoutesLoader
	// uses to pre/post process sources
	Interceptors []string `json:"interceptors,omitempty"`
	// Type defines the kind of source described by this object
	Type SourceType `json:"type,omitempty"`
	// List of property names defined in the source (e.g. if type is "template")
	PropertyNames []string `json:"property-names,omitempty"`
}

SourceSpec defines the configuration for one or more routes to be executed in a certain Camel DSL language

func NewSourceSpec 

func NewSourceSpec(name string, content string, language Language) SourceSpec

func (*SourceSpec) DeepCopy 

func (in *SourceSpec) DeepCopy() *SourceSpec

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

func (*SourceSpec) DeepCopyInto 

func (in *SourceSpec) DeepCopyInto(out *SourceSpec)

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

func (*SourceSpec) InferLanguage 

func (in *SourceSpec) InferLanguage() Language

InferLanguage returns the language of the source or discovers it from file extension if not set

type SourceType 

type SourceType string

SourceType represents an available source type 

const (
	// SourceTypeDefault is used to represent a source code
	SourceTypeDefault SourceType = ""
	// SourceTypeTemplate is used to represent a template
	SourceTypeTemplate SourceType = "template"
	// SourceTypeErrorHandler is used to represent an error handler
	SourceTypeErrorHandler SourceType = "errorHandler"
)

type SpectrumTask 

type SpectrumTask struct {
	BaseTask    `json:",inline"`
	PublishTask `json:",inline"`
}

SpectrumTask is used to configure Spectrum

func (*SpectrumTask) DeepCopy 

func (in *SpectrumTask) DeepCopy() *SpectrumTask

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

func (*SpectrumTask) DeepCopyInto 

func (in *SpectrumTask) DeepCopyInto(out *SpectrumTask)

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

type StringOrProperties 

type StringOrProperties struct {
	Value      string     `xml:",chardata" json:"-"`
	Properties Properties `xml:"properties,omitempty" json:"properties,omitempty"`
}

func (*StringOrProperties) DeepCopy 

func (in *StringOrProperties) DeepCopy() *StringOrProperties

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

func (*StringOrProperties) DeepCopyInto 

func (in *StringOrProperties) DeepCopyInto(out *StringOrProperties)

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

type Task 

type Task struct {

	// a BuilderTask, used to generate and package the project
	Builder *BuilderTask `json:"builder,omitempty"`

	// a BuildahTask, for Buildah strategy
	Buildah *BuildahTask `json:"buildah,omitempty"`
	// a KanikoTask, for Kaniko strategy
	Kaniko *KanikoTask `json:"kaniko,omitempty"`
	// a SpectrumTask, for Spectrum strategy
	Spectrum *SpectrumTask `json:"spectrum,omitempty"`
	// a S2iTask, for S2I strategy
	S2i *S2iTask `json:"s2i,omitempty"`

	Custom *UserTask `json:"custom,omitempty"`
}

Task represents the abstract task. Only one of the task should be configured to represent the specific task chosen.

func (*Task) DeepCopy 

func (in *Task) DeepCopy() *Task

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

func (*Task) DeepCopyInto 

func (in *Task) DeepCopyInto(out *Task)

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

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 TraitConfiguration 

type TraitConfiguration struct {
	// generic raw message, typically a map containing the keys (trait parameters) and the values (either single text or array)
	RawMessage `json:",inline"`
}

TraitConfiguration represents the expected configuration for a given trait parameter Deprecated: superceded by each Trait type, left for backward compatibility.

func (*TraitConfiguration) DeepCopy 

func (in *TraitConfiguration) DeepCopy() *TraitConfiguration

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

func (*TraitConfiguration) DeepCopyInto 

func (in *TraitConfiguration) DeepCopyInto(out *TraitConfiguration)

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

type TraitProfile 

type TraitProfile string

TraitProfile represents lists of traits that are enabled for the specific installation/integration 

const (
	// TraitProfileOpenShift is used by default on OpenShift clusters
	TraitProfileOpenShift TraitProfile = "OpenShift"
	// TraitProfileKubernetes is used by default on Kubernetes clusters
	TraitProfileKubernetes TraitProfile = "Kubernetes"
	// TraitProfileKnative is used by default on OpenShift/Kubernetes clusters powered by Knative
	TraitProfileKnative TraitProfile = "Knative"
	// DefaultTraitProfile is the trait profile used as default when no other profile is set
	DefaultTraitProfile = TraitProfileKubernetes
)

func TraitProfileByName 

func TraitProfileByName(name string) TraitProfile

TraitProfileByName returns the trait profile corresponding to the given name (case insensitive).

func (TraitProfile) Equal 

func (p TraitProfile) Equal(other TraitProfile) bool

Equal checks if the profile is equal to the given profile (case insensitive).

type TraitSpec 

type TraitSpec struct {
	// TraitConfiguration parameters configuration
	Configuration TraitConfiguration `json:"configuration"`
}

A TraitSpec contains the configuration of a trait Deprecated: superceded by each Trait type, left for backward compatibility.

func (*TraitSpec) DeepCopy 

func (in *TraitSpec) DeepCopy() *TraitSpec

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

func (*TraitSpec) DeepCopyInto 

func (in *TraitSpec) DeepCopyInto(out *TraitSpec)

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

type Traits 

type Traits struct {
	// The configuration of Affinity trait
	Affinity *trait.AffinityTrait `property:"affinity" json:"affinity,omitempty"`
	// The configuration of Builder trait
	Builder *trait.BuilderTrait `property:"builder" json:"builder,omitempty"`
	// The configuration of Camel trait
	Camel *trait.CamelTrait `property:"camel" json:"camel,omitempty"`
	// The configuration of Container trait
	Container *trait.ContainerTrait `property:"container" json:"container,omitempty"`
	// The configuration of Cron trait
	Cron *trait.CronTrait `property:"cron" json:"cron,omitempty"`
	// The configuration of Dependencies trait
	Dependencies *trait.DependenciesTrait `property:"dependencies" json:"dependencies,omitempty"`
	// The configuration of Deployer trait
	Deployer *trait.DeployerTrait `property:"deployer" json:"deployer,omitempty"`
	// The configuration of Deployment trait
	Deployment *trait.DeploymentTrait `property:"deployment" json:"deployment,omitempty"`
	// The configuration of Environment trait
	Environment *trait.EnvironmentTrait `property:"environment" json:"environment,omitempty"`
	// The configuration of Error Handler trait
	ErrorHandler *trait.ErrorHandlerTrait `property:"error-handler" json:"error-handler,omitempty"`
	// The configuration of GC trait
	GC *trait.GCTrait `property:"gc" json:"gc,omitempty"`
	// The configuration of Health trait
	Health *trait.HealthTrait `property:"health" json:"health,omitempty"`
	// The configuration of Ingress trait
	Ingress *trait.IngressTrait `property:"ingress" json:"ingress,omitempty"`
	// The configuration of Istio trait
	Istio *trait.IstioTrait `property:"istio" json:"istio,omitempty"`
	// The configuration of Jolokia trait
	Jolokia *trait.JolokiaTrait `property:"jolokia" json:"jolokia,omitempty"`
	// The configuration of JVM trait
	JVM *trait.JVMTrait `property:"jvm" json:"jvm,omitempty"`
	// The configuration of Kamelets trait
	Kamelets *trait.KameletsTrait `property:"kamelets" json:"kamelets,omitempty"`
	// The configuration of Knative trait
	Knative *trait.KnativeTrait `property:"knative" json:"knative,omitempty"`
	// The configuration of Knative Service trait
	KnativeService *trait.KnativeServiceTrait `property:"knative-service" json:"knative-service,omitempty"`
	// The configuration of Logging trait
	Logging *trait.LoggingTrait `property:"logging" json:"logging,omitempty"`
	// The configuration of Mount trait
	Mount *trait.MountTrait `property:"mount" json:"mount,omitempty"`
	// The configuration of OpenAPI trait
	OpenAPI *trait.OpenAPITrait `property:"openapi" json:"openapi,omitempty"`
	// The configuration of Owner trait
	Owner *trait.OwnerTrait `property:"owner" json:"owner,omitempty"`
	// The configuration of PDB trait
	PDB *trait.PDBTrait `property:"pdb" json:"pdb,omitempty"`
	// The configuration of Platform trait
	Platform *trait.PlatformTrait `property:"platform" json:"platform,omitempty"`
	// The configuration of Pod trait
	Pod *trait.PodTrait `property:"pod" json:"pod,omitempty"`
	// The configuration of Prometheus trait
	Prometheus *trait.PrometheusTrait `property:"prometheus" json:"prometheus,omitempty"`
	// The configuration of Pull Secret trait
	PullSecret *trait.PullSecretTrait `property:"pull-secret" json:"pull-secret,omitempty"`
	// The configuration of Quarkus trait
	Quarkus *trait.QuarkusTrait `property:"quarkus" json:"quarkus,omitempty"`
	// The configuration of Registry trait
	Registry *trait.RegistryTrait `property:"registry" json:"registry,omitempty"`
	// The configuration of Route trait
	Route *trait.RouteTrait `property:"route" json:"route,omitempty"`
	// The configuration of Service trait
	Service *trait.ServiceTrait `property:"service" json:"service,omitempty"`
	// The configuration of Service Binding trait
	ServiceBinding *trait.ServiceBindingTrait `property:"service-binding" json:"service-binding,omitempty"`
	// The configuration of Toleration trait
	Toleration *trait.TolerationTrait `property:"toleration" json:"toleration,omitempty"`

	// The extension point with addon traits
	Addons map[string]AddonTrait `json:"addons,omitempty"`

	// Deprecated: for backward compatibility.
	Keda *TraitSpec `property:"keda" json:"keda,omitempty"`
	// Deprecated: for backward compatibility.
	Master *TraitSpec `property:"master" json:"master,omitempty"`
	// Deprecated: for backward compatibility.
	Strimzi *TraitSpec `property:"strimzi" json:"strimzi,omitempty"`
	// Deprecated: for backward compatibility.
	ThreeScale *TraitSpec `property:"3scale" json:"3scale,omitempty"`
	// Deprecated: for backward compatibility.
	Tracing *TraitSpec `property:"tracing" json:"tracing,omitempty"`
}

Traits represents the collection of trait configurations

func (*Traits) DeepCopy 

func (in *Traits) DeepCopy() *Traits

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

func (*Traits) DeepCopyInto 

func (in *Traits) DeepCopyInto(out *Traits)

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

func (*Traits) Merge 

func (t *Traits) Merge(other Traits) error

Merge merges the given Traits into the receiver.

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"
)

type UserTask 

type UserTask struct {
	BaseTask `json:",inline"`
	// the container image to use
	ContainerImage string `json:"image,omitempty"`
	// the command to execute
	ContainerCommand string `json:"command,omitempty"`
}

UserTask is used to execute any generic custom operation

func (*UserTask) DeepCopy 

func (in *UserTask) DeepCopy() *UserTask

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

func (*UserTask) DeepCopyInto 

func (in *UserTask) DeepCopyInto(out *UserTask)

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

type ValueSource 

type ValueSource struct {
	// Selects a key of a ConfigMap.
	ConfigMapKeyRef *corev1.ConfigMapKeySelector `json:"configMapKeyRef,omitempty"`
	// Selects a key of a secret.
	SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}

ValueSource --

func (*ValueSource) DeepCopy 

func (in *ValueSource) DeepCopy() *ValueSource

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

func (*ValueSource) DeepCopyInto 

func (in *ValueSource) DeepCopyInto(out *ValueSource)

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

Source Files

View all Source files

Directories

Path Synopsis
Package trait contains Trait API Schema definitions for the camel v1 API group +kubebuilder:object:generate=true +groupName=camel.apache.org
 Package trait contains Trait API Schema definitions for the camel v1 API group +kubebuilder:object:generate=true +groupName=camel.apache.org

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.