MCPcopy Create free account

hub / github.com/apache/camel-k / functions

Functions5,125 in github.com/apache/camel-k

⨍ Functions 5,125◇ Types & classes 777
↓ 3 callersMethodgetDependencies
(schemeID string, scope func(CamelScheme) CamelSchemeScope)
pkg/apis/camel/v1/camelcatalog_types_support.go:280
↓ 3 callersFunctiongetEnvPlatform
getEnvPlatform is in charge to parse the environment variables of the operator and return the Platform object.
pkg/platform/env_platform.go:56
↓ 3 callersFunctiongetIntegration
(ctx context.Context, c client.Client, name, namespace string)
pkg/cmd/util.go:242
↓ 3 callersFunctiongetKedaScaledObject
(c *kubernetes.Collection)
pkg/trait/keda_test.go:201
↓ 3 callersFunctiongetOperatorImage
getOperatorImage returns the image currently used by the running operator if present (when running out of cluster, it may be absent).
pkg/cmd/operator/operator.go:273
↓ 3 callersFunctiongetOrFindAny
getOrFindAny returns the named platform or any other platform in the local namespace or the global one. nolint:staticcheck
pkg/platform/platform.go:99
↓ 3 callersMethodgetURIPrefix
(uri string)
pkg/util/source/inspector.go:440
↓ 3 callersFunctiongetUpdatedController
getUpdatedController retrieves the controller updated from the deployer trait execution.
pkg/controller/integration/monitor.go:421
↓ 3 callersFunctiongetWatchNamespace
getWatchNamespace returns the Namespace the operator should be watching for changes.
pkg/cmd/operator/operator.go:263
↓ 3 callersMethodhandleAndRestart
(ctx context.Context, err error, wait time.Duration, out *bufio.Writer, clientCloser func() error)
pkg/util/kubernetes/log/pod_scraper.go:124
↓ 3 callersMethodhasOnlyPassiveEndpoints
hasOnlyPassiveEndpoints returns true if the source has no endpoint that needs to remain always active.
pkg/util/source/inspector.go:413
↓ 3 callersFunctionimageContext
(ctx *builderContext, selector artifactsSelector)
pkg/builder/image.go:156
↓ 3 callersFunctioninitializeBuilderCmdOptions
(t *testing.T)
pkg/cmd/builder_test.go:30
↓ 3 callersFunctioninjectJibProfile
injectJibProfile is in charge to load the pom.xml and inject the profile required eventually for Jib publishing.
pkg/builder/jib.go:170
↓ 3 callersFunctionintegrationMatches
integrationMatches returns whether the v1.IntegrationKit meets the requirements of the v1.Integration.
pkg/controller/integration/kits.go:100
↓ 3 callersFunctioninvokeUserTestCode
(t *testing.T, ctx context.Context, ns string, doRun func(context.Context, *gomega.WithT, string))
e2e/support/test_support.go:1975
↓ 3 callersMethodisNativeKit
(e *Environment)
pkg/trait/quarkus.go:430
↓ 3 callersFunctionkitMaxBuildLimit
(t *testing.T, maxRunningBuilds int32, condition func(runningBuilds int) bool, buildOrderStrategy v1.BuildOrde
e2e/advanced/build_max_pipelines_test.go:43
↓ 3 callersFunctionloadContentHTTP
(ctx context.Context, u fmt.Stringer)
pkg/cmd/source/content.go:47
↓ 3 callersFunctionnewCmdRun
(rootCmdOptions *RootCmdOptions)
pkg/cmd/run.go:62
↓ 3 callersFunctionnewFromURI
(ctx context.Context, uri string)
pkg/kamelet/repository/repository.go:87
↓ 3 callersFunctionnewGitOpsTrait
()
pkg/trait/gitops.go:54
↓ 3 callersMethodnewIntegrationKit
(e *Environment, packageType quarkusPackageType)
pkg/trait/quarkus.go:272
↓ 3 callersFunctionnewMavenContext
newMavenContext returns a maven Context.
pkg/builder/common.go:31
↓ 3 callersFunctionnewProbe
( path string, scheme corev1.URIScheme, resolverPort *intstr.IntOrString, initialDelay, timeout, period, s
pkg/trait/health.go:279
↓ 3 callersFunctionnewSource
newSource creates a source using the content provider function.
pkg/cmd/source/source.go:48
↓ 3 callersFunctionparse
(item string, contentType ContentType)
pkg/util/resource/config.go:145
↓ 3 callersMethodparseAndConvertToTrait
(params []string, traitParam string)
pkg/cmd/kit_create.go:187
↓ 3 callersMethodparseStep
nolint:nestif
pkg/util/source/inspector_yaml.go:89
↓ 3 callersMethodparseTasksConf
(defaultBuildConf *v1.BuildConfiguration)
pkg/trait/builder.go:614
↓ 3 callersFunctionpdbCreatedCheck
(t *testing.T, pdbTrait *pdbTrait, environment *Environment)
pkg/trait/pdb_test.go:79
↓ 3 callersFunctionprocessDependencies
processDependencies walks a dir and return a list of all found jar artifacts. It can skip nested directories.
pkg/builder/common.go:77
↓ 3 callersFunctionpropagate
(traitSource string, traits v1.Traits, kitTraits *v1.IntegrationKitTraits)
pkg/trait/quarkus.go:340
↓ 3 callersMethodpropagateLabelAndAnnotations
(res metav1.Object, targetLabels map[string]string, targetAnnotations map[string]string)
pkg/trait/owner.go:118
↓ 3 callersFunctionraw2map
(t *testing.T, in camelv1.RawMessage)
pkg/controller/integration/health_test.go:93
↓ 3 callersFunctionrepeated
repeated wraps the regexp in a non-capturing group to get one or more matches.
e2e/support/regexp.go:102
↓ 3 callersFunctionsourcesRequiredAtBuildTime
Indicates whether the given source file is required at build time for native compilation.
pkg/trait/quarkus.go:502
↓ 3 callersFunctionteardown
We must ALWAYS clean the environment variables and viper library properties to avoid mess up with the rest of the tests.
pkg/cmd/root_test.go:114
↓ 3 callersFunctiontestApplyEmptyAffinityLabelsDoesSucceed
(t *testing.T, trait *affinityTrait, environment *Environment, affinity *corev1.Affinity)
pkg/trait/affinity_test.go:88
↓ 3 callersFunctiontestApplyNodeAffinityLabelsDoesSucceed
(t *testing.T, trait *affinityTrait, environment *Environment, podSpec *corev1.PodSpec)
pkg/trait/affinity_test.go:111
↓ 3 callersFunctiontestApplyPodAffinityLabelsDoesSucceed
(t *testing.T, trait *affinityTrait, environment *Environment, podSpec *corev1.PodSpec)
pkg/trait/affinity_test.go:176
↓ 3 callersFunctiontestApplyPodAntiAffinityLabelsDoesSucceed
(t *testing.T, trait *affinityTrait, environment *Environment, podSpec *corev1.PodSpec)
pkg/trait/affinity_test.go:141
↓ 3 callersFunctiontestApplyPodTolerationLabelsDefault
(t *testing.T, trait *tolerationTrait, environment *Environment, tolerations *[]corev1.Toleration)
pkg/trait/toleration_test.go:75
↓ 3 callersFunctiontestApplyPodTolerationLabelsTolerationSeconds
(t *testing.T, trait *tolerationTrait, environment *Environment, tolerations *[]corev1.Toleration)
pkg/trait/toleration_test.go:103
↓ 3 callersMethodtoggle
(it *v1.Integration, active bool)
pkg/cmd/debug.go:140
↓ 3 callersMethodupdate
(ctx context.Context, base *v1.IntegrationKit, target *v1.IntegrationKit)
pkg/controller/integrationkit/integrationkit_controller.go:326
↓ 3 callersFunctionvalueSource
valueSource expects any var to contain <configmap|secret>:<my-name>@<my-key>.
pkg/platform/env_platform.go:320
↓ 3 callersMethodwithServiceDo
( skipDuplicates bool, e *Environment, env *knativeapi.CamelEnvironment, serviceURIs []string, serviceTyp
pkg/trait/knative.go:548
↓ 2 callersMethodAddAll
AddAll adds all resources to the collection.
pkg/util/kubernetes/collection.go:100
↓ 2 callersMethodAddOrReplaceGeneratedSources
(sources ...SourceSpec)
pkg/apis/camel/v1/integration_types_support.go:223
↓ 2 callersFunctionApplyIntegrationProfile
ApplyIntegrationProfile resolves integration profile from given object.
pkg/platform/profile.go:31
↓ 2 callersFunctionAssignIntegrationToOperator
(t *testing.T, ctx context.Context, ns, name, operator string)
e2e/support/test_support.go:629
↓ 2 callersFunctionBuildConditions
(t *testing.T, ctx context.Context, ns, name string)
e2e/support/test_support.go:1582
↓ 2 callersFunctionBuildFailureRecoveryAttempt
(t *testing.T, ctx context.Context, ns, name string)
e2e/support/test_support.go:1602
↓ 2 callersMethodBuilderDependencies
BuilderDependencies returns the list of dependencies configured on by the builder task for this Build.
pkg/apis/camel/v1/build_types_support.go:52
↓ 2 callersFunctionBuilderPodPhase
(t *testing.T, ctx context.Context, ns string, name string)
e2e/support/test_support.go:1265
↓ 2 callersMethodCamelCatalogs
CamelCatalogs returns an object that can list and get CamelCatalogs.
pkg/client/camel/listers/camel/v1/camelcatalog.go:36
↓ 2 callersMethodCanHandle
(integration *v1.Integration)
pkg/controller/integration/monitor.go:63
↓ 2 callersMethodCanHandle
CanHandle tells whether this action can handle the integration.
pkg/controller/integration/build_complete.go:43
↓ 2 callersFunctionCheckConfigmapWithOwnerRef
(t *testing.T, hotreload bool)
e2e/common/config/config_reload_test.go:116
↓ 2 callersFunctionCheckSelfPermission
CheckSelfPermission can be used to check if the current user/service-account is allowed to execute a given operation in the cluster. E.g. checkPermiss
pkg/util/kubernetes/permission.go:32
↓ 2 callersFunctionCheckServiceAccountPermission
CheckServiceAccountPermission verify if a given Service Account can access a given resource. Service Account must be provided as "system:serviceaccoun
pkg/util/kubernetes/permission.go:59
↓ 2 callersFunctionClusterServiceVersion
(t *testing.T, ctx context.Context, conditions func(olm.ClusterServiceVersion) bool, ns string)
e2e/support/csv.go:36
↓ 2 callersMethodComponent
()
pkg/trait/keda/mapper.go:26
↓ 2 callersFunctionCompress
Compress --.
pkg/util/gzip/compress.go:30
↓ 2 callersFunctionConfigTreePropertySplit
ConfigTreePropertySplit Parses a property spec and returns its parts.
pkg/util/util.go:477
↓ 2 callersMethodConfigure
(e *Environment)
pkg/trait/git.go:43
↓ 2 callersMethodContentType
ContentType is the type of content used for the configuration.
pkg/util/resource/config.go:46
↓ 2 callersMethodControllerStrategySelectorOrder
ControllerStrategySelectorOrder returns the order (priority) of the controller strategy selector
pkg/trait/trait_types.go:202
↓ 2 callersFunctionCopyMap
CopyMap clones a map of strings.
pkg/util/util.go:326
↓ 2 callersFunctionCreateKameletWithID
(t *testing.T, operatorID string, ctx context.Context, ns string, name string, template map[string]interface{}
e2e/support/test_support.go:1872
↓ 2 callersFunctionCreatePlainTextSecretWithLabels
(t *testing.T, ctx context.Context, ns string, name string, data map[string]string, labels map[string]string)
e2e/support/test_support.go:1418
↓ 2 callersFunctionCreateTrigger
(brokerReference corev1.ObjectReference, subscriberRef duckv1.KReference, eventType string, path string, attri
pkg/util/knative/knative.go:103
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Build.
pkg/apis/camel/v1/zz_generated.deepcopy.go:111
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelCatalog.
pkg/apis/camel/v1/zz_generated.deepcopy.go:424
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntegrationKit.
pkg/apis/camel/v1/zz_generated.deepcopy.go:1230
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntegrationPlatform.
pkg/apis/camel/v1/zz_generated.deepcopy.go:1460
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Kamelet.
pkg/apis/camel/v1/zz_generated.deepcopy.go:2105
↓ 2 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipe.
pkg/apis/camel/v1/zz_generated.deepcopy.go:2481
↓ 2 callersMethodDeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/camel/v1/zz_generated.deepcopy.go:2491
↓ 2 callersFunctionDeploymentUID
(t *testing.T, ctx context.Context, ns string, name string)
e2e/support/test_support.go:1543
↓ 2 callersMethodDisableKnativeServing
()
pkg/internal/client.go:209
↓ 2 callersFunctionDumpNamespace
(t *testing.T, ctx context.Context, ns string)
e2e/support/test_support.go:2073
↓ 2 callersMethodEnableOpenshiftDiscovery
()
pkg/internal/client.go:205
↓ 2 callersFunctionEncodePropertyFile
EncodePropertyFile encodes a property map into a .properties file.
pkg/util/property/property.go:45
↓ 2 callersFunctionErrorBytes
(t *testing.T, path string, callable func(path string) ([]byte, error))
pkg/resources/resources_test.go:73
↓ 2 callersFunctionErrorString
(t *testing.T, path string, callable func(path string) (string, error))
pkg/resources/resources_test.go:79
↓ 2 callersFunctionExpectExecSucceedWithTimeout
(t *testing.T, g *WithT, command *exec.Cmd, timeout string)
e2e/support/test_util.go:140
↓ 2 callersFunctionExtractAndMaybeDeleteTraits
ExtractAndMaybeDeleteTraits will extract the annotation traits into v1.Traits struct, removing from the value from the input map.
pkg/trait/util.go:327
↓ 2 callersFunctionFile
File returns a channel that signals each time the content of the file changes.
pkg/util/sync/file.go:28
↓ 2 callersFunctionFindBuilderTask
FindBuilderTask returns the 1st builder task from the task list.
pkg/apis/camel/v1/build_types_support.go:69
↓ 2 callersFunctionForIntegration
ForIntegration --.
pkg/util/log/log.go:201
↓ 2 callersMethodForIntegrationKit
ForIntegrationKit --.
pkg/util/log/log.go:118
↓ 2 callersMethodForPipe
ForPipe --.
pkg/util/log/log.go:160
↓ 2 callersFunctionFromYamlDSL
FromYamlDSL creates a slice of flows from a Camel YAML DSL stream.
pkg/apis/camel/v1/integration_types_support.go:510
↓ 2 callersFunctionGateway
Gateway returns the gateway with the given name.
e2e/support/test_support.go:2255
↓ 2 callersMethodGetCondition
GetCondition returns the condition with the provided type.
pkg/apis/camel/v1/integration_types_support.go:385
↓ 2 callersFunctionGetConfigMap
(context context.Context, client ctrl.Reader, name string, namespace string)
pkg/util/kubernetes/client.go:109
↓ 2 callersMethodGetController
GetController returns the controller associated with the integration (e.g. Deployment, Knative Service or CronJob).
pkg/util/kubernetes/collection.go:462
↓ 2 callersFunctionGetDeploymentCondition
(deployment appsv1.Deployment, conditionType appsv1.DeploymentConditionType)
pkg/util/kubernetes/conditions.go:40
← previousnext →701–800 of 5,125, ranked by callers