camel

package
v1.12.1 Latest Latest
Warning

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

Go to latest
Published: May 29, 2023 License: Apache-2.0 Imports: 20 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BasePath                  = "/etc/camel"
	ConfDPath                 = filepath.Join(BasePath, "conf.d")
	SourcesMountPath          = filepath.Join(BasePath, "sources")
	ResourcesDefaultMountPath = filepath.Join(BasePath, "resources")
	ConfigResourcesMountPath  = filepath.Join(ConfDPath, "_resources")
	ConfigConfigmapsMountPath = filepath.Join(ConfDPath, "_configmaps")
	ConfigSecretsMountPath    = filepath.Join(ConfDPath, "_secrets")
	ServiceBindingsMountPath  = filepath.Join(ConfDPath, "_servicebindings")
)

Functions

func ManageIntegrationDependencies added in v1.3.0

func ManageIntegrationDependencies(project *maven.Project, dependencies []string, catalog *RuntimeCatalog) error

ManageIntegrationDependencies sets up all the required dependencies for the given Maven project.

func NormalizeDependency added in v1.11.0

func NormalizeDependency(dependency string) string

NormalizeDependency converts different forms of camel dependencies -- `camel-xxx`, `camel-quarkus-xxx`, and `camel-quarkus:xxx` -- into the unified form `camel:xxx`.

func SanitizeIntegrationDependencies added in v1.3.0

func SanitizeIntegrationDependencies(dependencies []maven.Dependency) error

SanitizeIntegrationDependencies --.

func ValidateDependencies added in v1.11.0

func ValidateDependencies(catalog *RuntimeCatalog, dependencies []string, out io.Writer)

ValidateDependencies validates dependencies against Camel catalog. It only shows warning and does not throw error in case the Catalog is just not complete and we don't want to let it stop the process.

func ValidateDependenciesE added in v1.11.0

func ValidateDependenciesE(catalog *RuntimeCatalog, dependencies []string) error

ValidateDependenciesE validates dependencies against Camel catalog and throws error in case it does not exist in the catalog.

func ValidateDependency added in v1.11.0

func ValidateDependency(catalog *RuntimeCatalog, dependency string, out io.Writer)

ValidateDependency validates a dependency against Camel catalog. It only shows warning and does not throw error in case the Catalog is just not complete, and we don't want to let it stop the process.

func ValidateDependencyE added in v1.12.1

func ValidateDependencyE(catalog *RuntimeCatalog, dependency string) error

ValidateDependencyE validates a dependency against Camel catalog and throws error in case it does not exist in the catalog.

Types

type CatalogVersion

type CatalogVersion struct {
	RuntimeVersion *semver.Version
	Catalog        *v1.CamelCatalog
}

CatalogVersion --.

type CatalogVersionCollection

type CatalogVersionCollection []CatalogVersion

CatalogVersionCollection --.

func (CatalogVersionCollection) Len

func (c CatalogVersionCollection) Len() int

Len returns the length of a collection. The number of CatalogVersion instances on the slice.

func (CatalogVersionCollection) Less

func (c CatalogVersionCollection) Less(i, j int) bool

Less is needed for the sort interface to compare two CatalogVersion objects on the slice. If checks if one is less than the other.

func (CatalogVersionCollection) Swap

func (c CatalogVersionCollection) Swap(i, j int)

Swap is needed for the sort interface to replace the CatalogVersion objects at two different positions in the slice.

type RuntimeCatalog

type RuntimeCatalog struct {
	v1.CamelCatalogSpec
	// contains filtered or unexported fields
}

RuntimeCatalog represents the data structure for a runtime catalog.

func DefaultCatalog

func DefaultCatalog() (*RuntimeCatalog, error)

func GenerateCatalog

func GenerateCatalog(
	ctx context.Context,
	client ctrl.Reader,
	namespace string,
	mvn v1.MavenSpec,
	runtime v1.RuntimeSpec,
	providerDependencies []maven.Dependency) (*RuntimeCatalog, error)

func GenerateCatalogCommon added in v1.3.0

func GenerateCatalogCommon(
	ctx context.Context,
	globalSettings []byte,
	userSettings []byte,
	caCert [][]byte,
	mvn v1.MavenSpec,
	runtime v1.RuntimeSpec,
	providerDependencies []maven.Dependency) (*RuntimeCatalog, error)

func LoadCatalog

func LoadCatalog(ctx context.Context, client client.Client, namespace string, runtime v1.RuntimeSpec) (*RuntimeCatalog, error)

LoadCatalog --.

func NewRuntimeCatalog

func NewRuntimeCatalog(spec v1.CamelCatalogSpec) *RuntimeCatalog

NewRuntimeCatalog creates a runtime catalog with the given catalog spec.

func QuarkusCatalog

func QuarkusCatalog() (*RuntimeCatalog, error)

func (*RuntimeCatalog) DecodeComponent added in v1.6.0

func (c *RuntimeCatalog) DecodeComponent(uri string) (*v1.CamelArtifact, *v1.CamelScheme)

DecodeComponent parses the given URI and return a camel artifact and a scheme.

func (*RuntimeCatalog) GetArtifactByDataFormat added in v1.3.0

func (c *RuntimeCatalog) GetArtifactByDataFormat(dataFormat string) *v1.CamelArtifact

GetArtifactByDataFormat returns the artifact corresponding to the given data format.

func (*RuntimeCatalog) GetArtifactByScheme

func (c *RuntimeCatalog) GetArtifactByScheme(scheme string) *v1.CamelArtifact

GetArtifactByScheme returns the artifact corresponding to the given component scheme.

func (*RuntimeCatalog) GetJavaTypeDependency

func (c *RuntimeCatalog) GetJavaTypeDependency(camelType string) (string, bool)

GetJavaTypeDependency returns the maven dependency for the given type name.

func (*RuntimeCatalog) GetLanguageDependency

func (c *RuntimeCatalog) GetLanguageDependency(language string) (string, bool)

GetLanguageDependency returns the maven dependency for the given language name.

func (*RuntimeCatalog) GetScheme

func (c *RuntimeCatalog) GetScheme(id string) (v1.CamelScheme, bool)

GetScheme returns the scheme definition for the given scheme id.

func (*RuntimeCatalog) HasArtifact

func (c *RuntimeCatalog) HasArtifact(artifact string) bool

HasArtifact checks if the given artifact is present in the catalog.

func (*RuntimeCatalog) HasLoaderByArtifact added in v1.11.0

func (c *RuntimeCatalog) HasLoaderByArtifact(artifact string) bool

HasLoaderByArtifact checks if the given artifact is a loader in the catalog.

func (*RuntimeCatalog) IsResolvable added in v1.12.0

func (c *RuntimeCatalog) IsResolvable(uri string) bool

IsResolvable checks given URI for proper Camel format (e.g. resolvable scheme).

func (*RuntimeCatalog) IsValidArtifact added in v1.11.0

func (c *RuntimeCatalog) IsValidArtifact(artifact string) bool

IsValidArtifact returns true if the given artifact is an artifact or loader in the catalog.

func (*RuntimeCatalog) VisitArtifacts

func (c *RuntimeCatalog) VisitArtifacts(visitor func(string, v1.CamelArtifact) bool)

VisitArtifacts --.

func (*RuntimeCatalog) VisitSchemes

func (c *RuntimeCatalog) VisitSchemes(visitor func(string, v1.CamelScheme) bool)

VisitSchemes --.

Jump to

Keyboard shortcuts

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