Documentation
¶
Index ¶
- Variables
- func BindKnativeAddressableResolverClusterRole(ctx context.Context, c kubernetes.Interface, namespace string) error
- func BuilderServiceAccountRoles(ctx context.Context, c client.Client, namespace string, ...) error
- func ExampleOrCollect(ctx context.Context, c client.Client, namespace string, ...) error
- func KameletCatalog(ctx context.Context, c client.Client, namespace string) error
- func KameletViewerRole(ctx context.Context, c client.Client, namespace string) error
- func ObjectOrCollect(ctx context.Context, c client.Client, namespace string, ...) error
- func OpenShiftConsoleDownloadLink(ctx context.Context, c client.Client) error
- func OperatorOrCollect(ctx context.Context, cmd *cobra.Command, c client.Client, ...) error
- func OperatorStartupOptionalTools(ctx context.Context, c client.Client, namespace string, ...)
- func PlatformOrCollect(ctx context.Context, c client.Client, clusterType string, namespace string, ...) (*v1.IntegrationPlatform, error)
- func RegistrySecretFromFileOrCollect(ctx context.Context, c client.Client, namespace string, file string, ...) (string, error)
- func RegistrySecretOrCollect(ctx context.Context, c client.Client, namespace string, auth registry.Auth, ...) (string, error)
- func Resource(ctx context.Context, c client.Client, namespace string, force bool, ...) error
- func ResourceOrCollect(ctx context.Context, c client.Client, namespace string, ...) error
- func Resources(ctx context.Context, c client.Client, namespace string, force bool, ...) error
- func ResourcesOrCollect(ctx context.Context, c client.Client, namespace string, ...) error
- func SetupClusterWideResourcesOrCollect(ctx context.Context, clientProvider client.Provider, ...) error
- func WaitForAllCrdInstallation(ctx context.Context, clientProvider client.Provider, timeout time.Duration) error
- type OperatorConfiguration
- type OperatorHealthConfiguration
- type OperatorMonitoringConfiguration
- type ResourceCustomizer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // KamelCLIDownloadName --. KamelCLIDownloadName = "kamel-cli" // KamelCLIDownloadDisplayName is the name as seen in the download page. KamelCLIDownloadDisplayName = "kamel - Apache Camel K Command Line Interface" // KamelCLIDownloadDescription is the description as seen in the download page. KamelCLIDownloadDescription = "Apache Camel K is a lightweight integration platform, born on Kubernetes, with serverless superpowers.\n\n" + "The `kamel` binary can be used to both configure the cluster and run integrations. " + "Once you've downloaded the `kamel` binary, log into the cluster using the `oc` client tool and start using the `kamel` CLI.\n\n" + "You can run `kamel help` to list the available commands or go to the [Camel K Website](https://camel.apache.org/projects/camel-k/) for more information." // KamelCLIDownloadURLTemplate is the download template with 3 missing parameters (version, version, os). KamelCLIDownloadURLTemplate = "https://github.com/apache/camel-k/releases/download/v%s/camel-k-client-%s-%s-64bit.tar.gz" )
The following variables may be overridden at build time.
View Source
var IdentityResourceCustomizer = func(object ctrl.Object) ctrl.Object {
return object
}
IdentityResourceCustomizer is a ResourceCustomizer that does nothing.
View Source
var RemoveIngressRoleCustomizer = func(object ctrl.Object) ctrl.Object { if role, ok := object.(*rbacv1.Role); ok && role.Name == "camel-k-operator" { rules: for i, rule := range role.Rules { for _, group := range rule.APIGroups { if group == networking.GroupName { role.Rules = append(role.Rules[:i], role.Rules[i+1:]...) break rules } } } } return object }
Functions ¶
func BindKnativeAddressableResolverClusterRole ¶
func BindKnativeAddressableResolverClusterRole(ctx context.Context, c kubernetes.Interface, namespace string) error
BindKnativeAddressableResolverClusterRole binds the Knative Addressable resolver aggregated ClusterRole to the operator ServiceAccount.
func BuilderServiceAccountRoles ¶
func BuilderServiceAccountRoles(ctx context.Context, c client.Client, namespace string, cluster v1.IntegrationPlatformCluster) error
BuilderServiceAccountRoles installs the builder service account and related roles in the given namespace.
func ExampleOrCollect ¶
func ExampleOrCollect(ctx context.Context, c client.Client, namespace string, collection *kubernetes.Collection, force bool) error
func KameletCatalog ¶
KameletCatalog installs the bundled Kamelets into the specified namespace.
func KameletViewerRole ¶
KameletViewerRole installs the role that allows any user ro access kamelets in the global namespace.
func ObjectOrCollect ¶
func OpenShiftConsoleDownloadLink ¶
OpenShiftConsoleDownloadLink installs the download link for the OpenShift console.
func OperatorOrCollect ¶
func OperatorOrCollect(ctx context.Context, cmd *cobra.Command, c client.Client, cfg OperatorConfiguration, collection *kubernetes.Collection, force bool) error
OperatorOrCollect installs the operator resources or adds them to the collector if present.
func OperatorStartupOptionalTools ¶
func OperatorStartupOptionalTools(ctx context.Context, c client.Client, namespace string, operatorNamespace string, log logr.Logger)
OperatorStartupOptionalTools tries to install optional tools at operator startup and warns if something goes wrong.
func PlatformOrCollect ¶
func PlatformOrCollect(ctx context.Context, c client.Client, clusterType string, namespace string, skipRegistrySetup bool, registry v1.RegistrySpec, collection *kubernetes.Collection, operatorID string) (*v1.IntegrationPlatform, error)
PlatformOrCollect -- nolint: lll
func RegistrySecretFromFileOrCollect ¶
func RegistrySecretFromFileOrCollect(ctx context.Context, c client.Client, namespace string, file string, collection *kubernetes.Collection, force bool) (string, error)
RegistrySecretFromFileOrCollect generates a secret from a docker-config.json file and creates it on the cluster (or appends it to the collection).
func RegistrySecretOrCollect ¶
func RegistrySecretOrCollect(ctx context.Context, c client.Client, namespace string, auth registry.Auth, collection *kubernetes.Collection, force bool) (string, error)
RegistrySecretOrCollect generates a secret from auth settings and creates it on the cluster (or appends it to the collection).
func Resource ¶
func Resource(ctx context.Context, c client.Client, namespace string, force bool, customizer ResourceCustomizer, name string) error
Resource installs a single named resource from the project resource directory.
func ResourceOrCollect ¶
func ResourceOrCollect(ctx context.Context, c client.Client, namespace string, collection *kubernetes.Collection, force bool, customizer ResourceCustomizer, name string) error
func Resources ¶
func Resources(ctx context.Context, c client.Client, namespace string, force bool, customizer ResourceCustomizer, names ...string) error
Resources installs named resources from the project resource directory.
func ResourcesOrCollect ¶
func ResourcesOrCollect(ctx context.Context, c client.Client, namespace string, collection *kubernetes.Collection, force bool, customizer ResourceCustomizer, names ...string) error
func SetupClusterWideResourcesOrCollect ¶
func SetupClusterWideResourcesOrCollect(ctx context.Context, clientProvider client.Provider, collection *kubernetes.Collection, clusterType string, force bool) error
Types ¶
type OperatorConfiguration ¶
type OperatorConfiguration struct {
CustomImage string
CustomImagePullPolicy string
Namespace string
Global bool
ClusterType string
Health OperatorHealthConfiguration
Monitoring OperatorMonitoringConfiguration
Tolerations []string
NodeSelectors []string
ResourcesRequirements []string
EnvVars []string
}
type OperatorHealthConfiguration ¶
type OperatorHealthConfiguration struct {
Port int32
}
Source Files
Click to show internal directories.
Click to hide internal directories.