v1

package
v2.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 15 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"

	// BuildConditionScheduled --.
	BuildConditionScheduled BuildConditionType = "Scheduled"

	// BuildConditionReadyReason --.
	BuildConditionReadyReason string = "Ready"
	// BuildConditionWaitingReason --.
	BuildConditionWaitingReason string = "Waiting"
)
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"
	// PlatformSelectorAnnotation platform id annotation label.
	PlatformSelectorAnnotation = "camel.apache.org/platform.id"
	// IntegrationProfileAnnotation integration profile id annotation label.
	IntegrationProfileAnnotation = "camel.apache.org/integration-profile.id"
	// IntegrationProfileNamespaceAnnotation integration profile id annotation label.
	IntegrationProfileNamespaceAnnotation = "camel.apache.org/integration-profile.namespace"
)
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"

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

	// IntegrationConditionReady --.
	IntegrationConditionReady IntegrationConditionType = "Ready"
	// 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"
	// IntegrationConditionTraitInfo --.
	IntegrationConditionTraitInfo IntegrationConditionType = "TraitInfo"

	// 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"
	// IntegrationConditionMonitoringPodsAvailableReason used to specify that the Pods generated are available for monitoring.
	IntegrationConditionMonitoringPodsAvailableReason string = "MonitoringPodsAvailable"
	// 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"
	// IntegrationConditionImportingKindAvailableReason used (as false) if we're trying to import an unsupported kind.
	IntegrationConditionImportingKindAvailableReason string = "ImportingKindAvailable"
)
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"
	// IntegrationKitTypeSynthetic identifies a synthetic Kit (generated for any container image for which the operator cannot make any assumption).
	IntegrationKitTypeSynthetic = "synthetic"

	// 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"
	// IntegrationKitLayoutNativeSources labels a kit using the Quarkus native-sources packaging.
	IntegrationKitLayoutNativeSources = "native-sources"

	// 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"
	// IntegrationKitConditionTraitInfo --.
	IntegrationKitConditionTraitInfo IntegrationKitConditionType = "TraitInfo"
)
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).
	// Deprecated no longer in use.
	IntegrationPlatformPhaseWarming IntegrationPlatformPhase = "Warming"
	// IntegrationPlatformPhaseReady when the IntegrationPlatform is ready.
	IntegrationPlatformPhaseReady IntegrationPlatformPhase = "Ready"
	// IntegrationPlatformPhaseError when the IntegrationPlatform had some error (see Conditions).
	IntegrationPlatformPhaseError IntegrationPlatformPhase = "Error"
	// IntegrationPlatformPhaseCreateCatalog when the IntegrationPlatform creates a new CamelCatalog.
	IntegrationPlatformPhaseCreateCatalog IntegrationPlatformPhase = "CreateCatalog"

	// IntegrationPlatformConditionReady is the condition if the IntegrationPlatform is ready.
	// Deprecated: use IntegrationPlatformConditionTypeCreated.
	IntegrationPlatformConditionReady = "Ready"
	// IntegrationPlatformConditionTypeCreated is the condition if the IntegrationPlatform has been created.
	IntegrationPlatformConditionTypeCreated IntegrationPlatformConditionType = "Created"

	// IntegrationPlatformConditionTypeRegistryAvailable is the condition for the availability of a container registry.
	IntegrationPlatformConditionTypeRegistryAvailable IntegrationPlatformConditionType = "RegistryAvailable"

	// IntegrationPlatformConditionCamelCatalogAvailable is the condition for the availability of a container registry.
	IntegrationPlatformConditionCamelCatalogAvailable IntegrationPlatformConditionType = "CamelCatalogAvailable"

	// IntegrationPlatformConditionCreatedReason represents the reason that the IntegrationPlatform is created.
	IntegrationPlatformConditionCreatedReason = "IntegrationPlatformCreated"
	// IntegrationPlatformConditionTypeRegistryAvailableReason represents the reason that the IntegrationPlatform Registry is available.
	IntegrationPlatformConditionTypeRegistryAvailableReason = "IntegrationPlatformRegistryAvailable"
	// IntegrationPlatformConditionCamelCatalogAvailableReason represents the reason that the IntegrationPlatform is created.
	IntegrationPlatformConditionCamelCatalogAvailableReason = "IntegrationPlatformCamelCatalogAvailable"
)
View Source 
const (
	// IntegrationProfileKind is the Kind name of the IntegrationProfile CR.
	IntegrationProfileKind string = "IntegrationProfile"

	// IntegrationProfilePhaseNone when the IntegrationProfile does not exist.
	IntegrationProfilePhaseNone IntegrationProfilePhase = ""
	// IntegrationProfilePhaseReady when the IntegrationProfile is ready.
	IntegrationProfilePhaseReady IntegrationProfilePhase = "Ready"
	// IntegrationProfilePhaseError when the IntegrationProfile had some error (see Conditions).
	IntegrationProfilePhaseError IntegrationProfilePhase = "Error"

	// IntegrationProfileConditionTypeCreated is the condition if the IntegrationProfile has been created.
	IntegrationProfileConditionTypeCreated IntegrationProfileConditionType = "Created"

	// IntegrationProfileConditionCreatedReason represents the reason that the IntegrationProfile is created.
	IntegrationProfileConditionCreatedReason = "IntegrationProfileCreated"
)
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"
	// KameletDataTypeLabel label used to override the default Kamelet action data type.
	KameletDataTypeLabel = "camel.apache.org/kamelet.data.type"

	// 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 IntegrationGenerationLabel = "camel.apache.org/generation"

IntegrationGenerationLabel is used to check on outdated integration resources that can be removed by garbage collection.

View Source 
const IntegrationImportedKindLabel = "camel.apache.org/imported-from-kind"

IntegrationImportedKindLabel specifies from what kind of resource an Integration was imported.

View Source 
const IntegrationImportedNameLabel = "camel.apache.org/imported-from-name"

IntegrationImportedNameLabel specifies from what resource an Integration was imported.

View Source 
const IntegrationKitLabel = "camel.apache.org/integrationkit"
View Source 
const IntegrationLabel = "camel.apache.org/integration"

IntegrationLabel is used to tag k8s object created by a given Integration.

View Source 
const IntegrationSyntheticLabel = "camel.apache.org/is-synthetic"

IntegrationSyntheticLabel is used to tag k8s synthetic Integrations.

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{
	IntegrationPlatformBuildPublishStrategyS2I,
	IntegrationPlatformBuildPublishStrategySpectrum,
	IntegrationPlatformBuildPublishStrategyJib,
}

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 GetAnnotation added in v2.3.0 

func GetAnnotation(name string, obj metav1.Object) string

GetAnnotation safely get the annotation value.

func GetIntegrationProfileAnnotation added in v2.3.0 

func GetIntegrationProfileAnnotation(obj metav1.Object) string

GetIntegrationProfileAnnotation to safely get the integration profile annotation value.

func GetIntegrationProfileNamespaceAnnotation added in v2.3.0 

func GetIntegrationProfileNamespaceAnnotation(obj metav1.Object) string

GetIntegrationProfileNamespaceAnnotation to safely get the integration profile namespace annotation value.

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 Args added in v2.1.0 

type Args struct {
	Arg string `xml:"arg" json:"arg"`
}

Args -- .

func (*Args) DeepCopy added in v2.1.0 

func (in *Args) DeepCopy() *Args

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

func (*Args) DeepCopyInto added in v2.1.0 

func (in *Args) DeepCopyInto(out *Args)

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"`
	// The configuration that should be used to perform the Build.
	Configuration BuildConfiguration `json:"configuration,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) TaskConfiguration added in v2.1.0 

func (build *Build) TaskConfiguration(name string) *BuildConfiguration

TaskConfiguration returns the task configuration of 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"`
	// The node selector for the builder pod. Only used for `pod` strategy
	NodeSelector map[string]string `property:"node-selector" json:"nodeSelector,omitempty"`
	// Annotation to use for the builder pod. Only used for `pod` strategy
	Annotations map[string]string `property:"annotations" json:"annotations,omitempty"`
	// The list of platforms used in order to build a container image.
	ImagePlatforms []string `property:"platforms" json:"platforms,omitempty"`
}

BuildConfiguration represent the configuration required to build the runtime.

func ConfigurationTasksByName added in v2.1.0 

func ConfigurationTasksByName(tasks []Task, name string) *BuildConfiguration

ConfigurationTasksByName returns the container 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. It returns the first matching build found regardless it may have any one more appropriate.

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 appropriate 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"`
	// root image (the first image from which the incremental image has started)
	RootImage string `json:"rootImage,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 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) GetJibLayerFilterExtensionMavenVersion added in v2.1.0 

func (c *CamelCatalogSpec) GetJibLayerFilterExtensionMavenVersion() string

GetJibLayerFilterExtensionMavenVersion returns the Jib layer filter plugin version required to publish an integration kit based on this catalog with jib strategy.

func (*CamelCatalogSpec) GetJibMavenPluginVersion added in v2.1.0 

func (c *CamelCatalogSpec) GetJibMavenPluginVersion() string

GetJibMavenPluginVersion returns the Jib plugin version required to publish an integration kit based on this catalog with jib strategy.

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.

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 CamelProperty added in v2.3.0 

type CamelProperty struct {
	Key   string `json:"key" yaml:"key"`
	Value string `json:"value,omitempty" yaml:"value,omitempty"`
}

CamelProperty represents a Camel property that may end up in an application.properties file.

func (*CamelProperty) DeepCopy added in v2.3.0 

func (in *CamelProperty) DeepCopy() *CamelProperty

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

func (*CamelProperty) DeepCopyInto added in v2.3.0 

func (in *CamelProperty) DeepCopyInto(out *CamelProperty)

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 {
	// List of required Maven dependencies
	Dependencies []MavenArtifact `json:"dependencies,omitempty" yaml:"dependencies,omitempty"`
	// Set of required Camel runtime properties
	RuntimeProperties []CamelProperty `json:"runtimeProperties,omitempty" yaml:"runtimeProperties,omitempty"`
	// Set of required Camel build time properties
	BuildTimeProperties []CamelProperty `json:"buildTimeProperties,omitempty" yaml:"buildTimeProperties,omitempty"`
	// Set of generic metadata
	Metadata map[string]string `json:"metadata,omitempty" yaml:"metadata,omitempty"`
}

Capability is a particular feature which requires a well known set of dependencies and other properties which are specified in the runtime catalog.

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 Container added in v2.1.0 

type Container struct {
	Entrypoint string `xml:"entrypoint" json:"entrypoint"`
	Args       Args   `xml:"args" json:"args"`
}

Container -- .

func (*Container) DeepCopy added in v2.1.0 

func (in *Container) DeepCopy() *Container

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

func (*Container) DeepCopyInto added in v2.1.0 

func (in *Container) DeepCopyInto(out *Container)

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

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 ExtraDirectories added in v2.1.0 

type ExtraDirectories struct {
	Paths       []Path       `xml:"paths>path" json:"paths>path"`
	Permissions []Permission `xml:"permissions>permission,omitempty" json:"permissions>permission,omitempty"`
}

ExtraDirectories -- .

func (*ExtraDirectories) DeepCopy added in v2.1.0 

func (in *ExtraDirectories) DeepCopy() *ExtraDirectories

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

func (*ExtraDirectories) DeepCopyInto added in v2.1.0 

func (in *ExtraDirectories) DeepCopyInto(out *ExtraDirectories)

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 Filter added in v2.1.0 

type Filter struct {
	Glob    string `xml:"glob" json:"glob"`
	ToLayer string `xml:"toLayer,omitempty" json:"toLayer,omitempty"`
}

Filter -- .

func (*Filter) DeepCopy added in v2.1.0 

func (in *Filter) DeepCopy() *Filter

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

func (*Filter) DeepCopyInto added in v2.1.0 

func (in *Filter) DeepCopyInto(out *Filter)

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) AllSources added in v2.2.0 

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

Sources return a new slice containing all the sources associated to the 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) IsSynthetic added in v2.3.0 

func (in *Integration) IsSynthetic() bool

IsSynthetic returns true for synthetic Integrations (non managed, likely imported from external deployments).

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) UserDefinedSources added in v2.2.0 

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

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) HasCapability added in v2.3.0 

func (in *IntegrationKit) HasCapability(capability string) bool

HasCapability returns true if the Kit is enabled with such a capability.

func (*IntegrationKit) HasHigherPriorityThan 

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

func (*IntegrationKit) IsExternal added in v2.3.0 

func (in *IntegrationKit) IsExternal() bool

IsExternal returns true for external IntegrationKits (integration kit not created by the operator).

func (*IntegrationKit) IsSynthetic added in v2.3.1 

func (in *IntegrationKit) IsSynthetic() bool

IsSynthetic returns true for synthetic IntegrationKits.

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"`
	// features offered by the IntegrationKit
	Capabilities []string `json:"capabilities,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"`
	// root image used by the kit (the first image from which the incremental image has started, typically a JDK/JRE base image)
	RootImage string `json:"rootImage,omitempty"`
	// base image used by the kit (could be another IntegrationKit)
	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, requires at least 4GiB of memory, so the Pod running the native build 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.
	// Deprecated: use jvm trait or read documentation.
	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.

func (*IntegrationKitTraits) Merge added in v2.3.0 

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

Merge merges the given IntegrationKitTraits into the receiver.

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 (
	// 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"
	// IntegrationPlatformBuildPublishStrategyJib uses Jib maven plugin (https://github.com/GoogleContainerTools/jib)
	// in order to push the incremental images to the image repository.
	IntegrationPlatformBuildPublishStrategyJib IntegrationPlatformBuildPublishStrategy = "Jib"
)

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 software
	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
	// Deprecated: no longer in use
	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) GetTimeout 

func (b IntegrationPlatformBuildSpec) GetTimeout() metav1.Duration

GetTimeout returns the specified duration or a default one.

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 IntegrationPlatformKameletSpec 

type IntegrationPlatformKameletSpec struct {
	// remote repository used to retrieve Kamelet catalog
	Repositories []KameletRepositorySpec `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 IntegrationProfile added in v2.3.0 

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

	Spec   IntegrationProfileSpec   `json:"spec,omitempty"`
	Status IntegrationProfileStatus `json:"status,omitempty"`
}

IntegrationProfile is the resource used to apply user defined settings to the Camel K operator behavior. It defines the behavior of all Custom Resources (`IntegrationKit`, `Integration`, `Kamelet`) in the given namespace.

func NewIntegrationProfile added in v2.3.0 

func NewIntegrationProfile(namespace string, name string) IntegrationProfile

NewIntegrationProfile --.

func (*IntegrationProfile) DeepCopy added in v2.3.0 

func (in *IntegrationProfile) DeepCopy() *IntegrationProfile

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

func (*IntegrationProfile) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfile) DeepCopyInto(out *IntegrationProfile)

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

func (*IntegrationProfile) DeepCopyObject added in v2.3.0 

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

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

func (*IntegrationProfile) GetActualValue added in v2.3.0 

func (in *IntegrationProfile) GetActualValue(extractor func(spec IntegrationProfileSpec) string) string

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

func (*IntegrationProfile) ResyncStatusFullConfig added in v2.3.0 

func (in *IntegrationProfile) ResyncStatusFullConfig()

ResyncStatusFullConfig copies the spec configuration into the status field.

func (*IntegrationProfile) SetOperatorID added in v2.3.0 

func (in *IntegrationProfile) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation.

type IntegrationProfileBuildSpec added in v2.3.0 

type IntegrationProfileBuildSpec struct {
	// 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 software
	BaseImage string `json:"baseImage,omitempty"`
	// the image registry used to push/pull Integration images
	Registry RegistrySpec `json:"registry,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"`
}

IntegrationProfileBuildSpec contains profile related build information. This configuration can be used to tune the behavior of the Integration/IntegrationKit image builds.

func (*IntegrationProfileBuildSpec) DeepCopy added in v2.3.0 

func (in *IntegrationProfileBuildSpec) DeepCopy() *IntegrationProfileBuildSpec

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

func (*IntegrationProfileBuildSpec) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileBuildSpec) DeepCopyInto(out *IntegrationProfileBuildSpec)

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

func (IntegrationProfileBuildSpec) GetTimeout added in v2.3.0 

func (b IntegrationProfileBuildSpec) GetTimeout() metav1.Duration

GetTimeout returns the specified duration or a default one.

type IntegrationProfileCondition added in v2.3.0 

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

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

func (*IntegrationProfileCondition) DeepCopy added in v2.3.0 

func (in *IntegrationProfileCondition) DeepCopy() *IntegrationProfileCondition

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

func (*IntegrationProfileCondition) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileCondition) DeepCopyInto(out *IntegrationProfileCondition)

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

func (IntegrationProfileCondition) GetLastTransitionTime added in v2.3.0 

func (c IntegrationProfileCondition) GetLastTransitionTime() metav1.Time

GetLastTransitionTime --.

func (IntegrationProfileCondition) GetLastUpdateTime added in v2.3.0 

func (c IntegrationProfileCondition) GetLastUpdateTime() metav1.Time

GetLastUpdateTime --.

func (IntegrationProfileCondition) GetMessage added in v2.3.0 

func (c IntegrationProfileCondition) GetMessage() string

GetMessage --.

func (IntegrationProfileCondition) GetReason added in v2.3.0 

func (c IntegrationProfileCondition) GetReason() string

GetReason --.

func (IntegrationProfileCondition) GetStatus added in v2.3.0 

func (c IntegrationProfileCondition) GetStatus() corev1.ConditionStatus

GetStatus --.

func (IntegrationProfileCondition) GetType added in v2.3.0 

func (c IntegrationProfileCondition) GetType() string

GetType --.

type IntegrationProfileConditionType added in v2.3.0 

type IntegrationProfileConditionType string

IntegrationProfileConditionType defines the type of condition.

type IntegrationProfileKameletSpec added in v2.3.0 

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

IntegrationProfileKameletSpec define the behavior for all the Kamelets controller by the IntegrationProfile.

func (*IntegrationProfileKameletSpec) DeepCopy added in v2.3.0 

func (in *IntegrationProfileKameletSpec) DeepCopy() *IntegrationProfileKameletSpec

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

func (*IntegrationProfileKameletSpec) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileKameletSpec) DeepCopyInto(out *IntegrationProfileKameletSpec)

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

type IntegrationProfileList added in v2.3.0 

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

IntegrationProfileList contains a list of IntegrationProfile.

func NewIntegrationProfileList added in v2.3.0 

func NewIntegrationProfileList() IntegrationProfileList

NewIntegrationProfileList --.

func (*IntegrationProfileList) DeepCopy added in v2.3.0 

func (in *IntegrationProfileList) DeepCopy() *IntegrationProfileList

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

func (*IntegrationProfileList) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileList) DeepCopyInto(out *IntegrationProfileList)

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

func (*IntegrationProfileList) DeepCopyObject added in v2.3.0 

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

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

type IntegrationProfilePhase added in v2.3.0 

type IntegrationProfilePhase string

IntegrationProfilePhase is the phase of an IntegrationProfile.

type IntegrationProfileSpec added in v2.3.0 

type IntegrationProfileSpec struct {
	// specify how to build the Integration/IntegrationKits
	Build IntegrationProfileBuildSpec `json:"build,omitempty"`
	// list of traits to be executed for all the Integration/IntegrationKits built from this IntegrationProfile
	Traits Traits `json:"traits,omitempty"`
	// configuration to be executed to all Kamelets controlled by this IntegrationProfile
	Kamelet IntegrationProfileKameletSpec `json:"kamelet,omitempty"`
}

IntegrationProfileSpec applies user defined settings to the IntegrationProfile.

func (*IntegrationProfileSpec) DeepCopy added in v2.3.0 

func (in *IntegrationProfileSpec) DeepCopy() *IntegrationProfileSpec

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

func (*IntegrationProfileSpec) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileSpec) DeepCopyInto(out *IntegrationProfileSpec)

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

type IntegrationProfileStatus added in v2.3.0 

type IntegrationProfileStatus struct {
	IntegrationProfileSpec `json:",inline"`
	// ObservedGeneration is the most recent generation observed for this IntegrationProfile.
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// defines in what phase the IntegrationProfile is found
	Phase IntegrationProfilePhase `json:"phase,omitempty"`
	// which are the conditions met (particularly useful when in ERROR phase)
	Conditions []IntegrationProfileCondition `json:"conditions,omitempty"`
}

IntegrationProfileStatus defines the observed state of IntegrationProfile.

func (*IntegrationProfileStatus) DeepCopy added in v2.3.0 

func (in *IntegrationProfileStatus) DeepCopy() *IntegrationProfileStatus

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

func (*IntegrationProfileStatus) DeepCopyInto added in v2.3.0 

func (in *IntegrationProfileStatus) DeepCopyInto(out *IntegrationProfileStatus)

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

func (*IntegrationProfileStatus) GetCondition added in v2.3.0 

func (in *IntegrationProfileStatus) GetCondition(condType IntegrationProfileConditionType) *IntegrationProfileCondition

GetCondition returns the condition with the provided type.

func (*IntegrationProfileStatus) GetConditions added in v2.3.0 

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

GetConditions --.

func (*IntegrationProfileStatus) RemoveCondition added in v2.3.0 

func (in *IntegrationProfileStatus) RemoveCondition(condType IntegrationProfileConditionType)

RemoveCondition removes the resource condition with the provided type.

func (*IntegrationProfileStatus) SetCondition added in v2.3.0 

func (in *IntegrationProfileStatus) SetCondition(condType IntegrationProfileConditionType, status corev1.ConditionStatus, reason string, message string)

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

func (*IntegrationProfileStatus) SetConditions added in v2.3.0 

func (in *IntegrationProfileStatus) SetConditions(conditions ...IntegrationProfileCondition)

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 (*IntegrationProfileStatus) SetErrorCondition added in v2.3.0 

func (in *IntegrationProfileStatus) SetErrorCondition(condType IntegrationProfileConditionType, 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) AddConfigurationProperty added in v2.3.0 

func (in *IntegrationSpec) AddConfigurationProperty(confValue string)

AddConfigurationProperty adds a new configuration property.

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) 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 JibTask added in v2.1.0 

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

JibTask is used to configure Jib.

func (*JibTask) DeepCopy added in v2.1.0 

func (in *JibTask) DeepCopy() *JibTask

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

func (*JibTask) DeepCopyInto added in v2.1.0 

func (in *JibTask) DeepCopyInto(out *JibTask)

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

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
	// +kubebuilder:default:={phase:"Ready"}
	// Deprecated no longer in use
	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) SetOperatorID added in v2.3.0 

func (k *Kamelet) SetOperatorID(operatorID string)

SetOperatorID sets the given operator id as an annotation.

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 KameletRepositorySpec added in v2.3.0 

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

KameletRepositorySpec defines the location of the Kamelet catalog to use.

func (*KameletRepositorySpec) DeepCopy added in v2.3.0 

func (in *KameletRepositorySpec) DeepCopy() *KameletRepositorySpec

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

func (*KameletRepositorySpec) DeepCopyInto added in v2.3.0 

func (in *KameletRepositorySpec) DeepCopyInto(out *KameletRepositorySpec)

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 Type
	Type string `json:"type,omitempty" yaml:"type,omitempty" xml:"type,omitempty"`
	// Maven Version
	Version string `json:"version,omitempty" yaml:"version,omitempty" xml:"version,omitempty"`
	// Maven Classifier
	Classifier string `json:"classifier,omitempty" yaml:"classifier,omitempty" xml:"classifier,omitempty"`
}

MavenArtifact defines a GAV (Group:Artifact:Type:Version:Classifier) 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 profile.
	Profiles []ValueSource `json:"profiles,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 Path added in v2.1.0 

type Path struct {
	From     string   `xml:"from" json:"from"`
	Into     string   `xml:"into" json:"into"`
	Excludes []string `xml:"excludes>exclude,omitempty" json:"excludes>exclude,omitempty"`
}

Path -- .

func (*Path) DeepCopy added in v2.1.0 

func (in *Path) DeepCopy() *Path

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

func (*Path) DeepCopyInto added in v2.1.0 

func (in *Path) DeepCopyInto(out *Path)

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

type Permission added in v2.1.0 

type Permission struct {
	File string `xml:"file" json:"file"`
	Mode string `xml:"mode" json:"mode"`
}

Permission -- .

func (*Permission) DeepCopy added in v2.1.0 

func (in *Permission) DeepCopy() *Permission

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

func (*Permission) DeepCopyInto added in v2.1.0 

func (in *Permission) DeepCopyInto(out *Permission)

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"
	// PipeIntegrationDeprecationNotice is used to report the usage of a deprecated resource.
	PipeIntegrationDeprecationNotice PipeConditionType = "DeprecationNotice"
)

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
	// Deprecated don't use this. Use trait annotations if you need to change any cluster configuration.
	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 occurring in the integration
	ErrorHandler *ErrorHandlerSpec `json:"errorHandler,omitempty"`
	// Steps contains an optional list of intermediate steps that are executed between the Source and the Sink
	Steps []Endpoint `json:"steps,omitempty"`
	// Replicas is the number of desired replicas for the 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 PluginConfiguration added in v2.1.0 

type PluginConfiguration struct {
	Container               Container        `xml:"container" json:"container"`
	AllowInsecureRegistries string           `xml:"allowInsecureRegistries" json:"allowInsecureRegistries"`
	ExtraDirectories        ExtraDirectories `xml:"extraDirectories" json:"extraDirectories"`
	PluginExtensions        PluginExtensions `xml:"pluginExtensions" json:"pluginExtensions"`
}

PluginConfiguration see link:https://maven.apache.org/settings.html[Maven settings].

func (*PluginConfiguration) DeepCopy added in v2.1.0 

func (in *PluginConfiguration) DeepCopy() *PluginConfiguration

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

func (*PluginConfiguration) DeepCopyInto added in v2.1.0 

func (in *PluginConfiguration) DeepCopyInto(out *PluginConfiguration)

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

type PluginExtension added in v2.1.0 

type PluginExtension struct {
	Implementation string                       `xml:"implementation" json:"implementation"`
	Configuration  PluginExtensionConfiguration `xml:"configuration" json:"configuration"`
}

PluginExtension -- .

func (*PluginExtension) DeepCopy added in v2.1.0 

func (in *PluginExtension) DeepCopy() *PluginExtension

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

func (*PluginExtension) DeepCopyInto added in v2.1.0 

func (in *PluginExtension) DeepCopyInto(out *PluginExtension)

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

type PluginExtensionConfiguration added in v2.1.0 

type PluginExtensionConfiguration struct {
	Filters        []Filter `xml:"filters>Filter" json:"filters>Filter"`
	Implementation string   `xml:"implementation,attr" json:"_implementation"`
}

PluginExtensionConfiguration -- .

func (*PluginExtensionConfiguration) DeepCopy added in v2.1.0 

func (in *PluginExtensionConfiguration) DeepCopy() *PluginExtensionConfiguration

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

func (*PluginExtensionConfiguration) DeepCopyInto added in v2.1.0 

func (in *PluginExtensionConfiguration) DeepCopyInto(out *PluginExtensionConfiguration)

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

type PluginExtensions added in v2.1.0 

type PluginExtensions struct {
	PluginExtension PluginExtension `xml:"pluginExtension" json:"pluginExtension"`
}

PluginExtensions -- .

func (*PluginExtensions) DeepCopy added in v2.1.0 

func (in *PluginExtensions) DeepCopy() *PluginExtensions

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

func (*PluginExtensions) DeepCopyInto added in v2.1.0 

func (in *PluginExtensions) DeepCopyInto(out *PluginExtensions)

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

type PluginProperties 

type PluginProperties map[string]StringOrProperties

PluginProperties -- .

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

Properties -- .

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"`
}

Server see link:https://maven.apache.org/settings.html[Maven settings].

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"`
	// True if the spec is generated from a Kamelet
	FromKamelet bool `json:"from-kamelet,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 (s *SourceSpec) InferLanguage() Language

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

func (*SourceSpec) IsGeneratedFromKamelet added in v2.1.0 

func (s *SourceSpec) IsGeneratedFromKamelet() bool

IsGeneratedFromKamelet determines is a source spec is derived from a Kamelet.

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"`
}

StringOrProperties -- .

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 build the project
	Builder *BuilderTask `json:"builder,omitempty"`

	// User customizable task execution. These are executed after the build and before the package task.
	Custom *UserTask `json:"custom,omitempty"`

	// Application pre publishing
	// a PackageTask, used to package the project
	Package *BuilderTask `json:"package,omitempty"`

	// a BuildahTask, for Buildah strategy
	// Deprecated: use spectrum, jib, s2i or a custom publishing strategy instead
	Buildah *BuildahTask `json:"buildah,omitempty"`
	// a KanikoTask, for Kaniko strategy
	// Deprecated: use spectrum, jib, s2i or a custom publishing strategy instead
	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"`
	// a JibTask, for Jib strategy
	Jib *JibTask `json:"jib,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
	// Deprecated: use jvm trait or read documentation.
	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 user id used to run the container
	ContainerUserID *int64 `json:"userId,omitempty"`
	// the command to execute
	// Deprecated: use ContainerCommands
	ContainerCommand string `json:"command,omitempty"`
	// the command to execute
	ContainerCommands []string `json:"commands,omitempty"`
	// the desired image build name
	PublishingImage string `json:"publishingImage,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 DecodeValueSource added in v2.1.0 

func DecodeValueSource(input string, defaultKey string, errorMessage string) (ValueSource, error)

DecodeValueSource returns a ValueSource object from an input that respects the format configmap|secret:resource-name[/path].

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.

func (*ValueSource) String added in v2.1.0 

func (o *ValueSource) String() string

String returns a string representation of ValueSource.

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.