Skip to content

Commit 6143cc6

Browse files
authored
Revert "Adding a new Minikube flag for helm chart install of Apache Camel K (#521)" (#553)
This reverts commit 136c4ab.
1 parent e50d13a commit 6143cc6

File tree

5 files changed

+3
-94
lines changed

5 files changed

+3
-94
lines changed

README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
## Getting Started
88

9-
Note: In order to use the `quickstart` plugin, you must install the [Kubernetes CLI `kubectl`](https://kubernetes.io/docs/tasks/tools/install-kubectl) and either [`kind`](https://kind.sigs.k8s.io/docs/user/quick-start) or [`minikube`](https://minikube.sigs.k8s.io/docs/start/). If you want to install the Apache Camel K option you also need the [`helm`](https://helm.sh/) CLI.
9+
Note: In order to use the `quickstart` plugin, you must install the [Kubernetes CLI `kubectl`](https://kubernetes.io/docs/tasks/tools/install-kubectl) and either [`kind`](https://kind.sigs.k8s.io/docs/user/quick-start) or [`minikube`](https://minikube.sigs.k8s.io/docs/start/).
1010

1111
### Installation
1212

internal/command/flags.go

-5
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ var name string
2424
var kubernetesVersion string
2525
var installServing bool
2626
var installEventing bool
27-
var installCamel bool
2827
var installKindRegistry bool
2928
var installKindExtraMountHostPath string
3029
var installKindExtraMountContainerPath string
@@ -56,10 +55,6 @@ func installEventingOption(targetCmd *cobra.Command) {
5655
targetCmd.Flags().BoolVar(&installEventing, "install-eventing", false, "install Eventing on quickstart cluster")
5756
}
5857

59-
func installCamelOption(targetCmd *cobra.Command) {
60-
targetCmd.Flags().BoolVar(&installCamel, "install-camel", false, "install Apache Camel K on quickstart cluster")
61-
}
62-
6358
func installKindRegistryOption(targetCmd *cobra.Command) {
6459
targetCmd.Flags().BoolVar(&installKindRegistry, "registry", false, "install registry for Kind quickstart cluster")
6560
}

internal/command/minikube.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -30,14 +30,13 @@ func NewMinikubeCommand() *cobra.Command {
3030
Short: "Quickstart with Minikube",
3131
RunE: func(cmd *cobra.Command, args []string) error {
3232
fmt.Println("Running Knative Quickstart using Minikube")
33-
return minikube.SetUp(name, kubernetesVersion, installServing, installEventing, installCamel)
33+
return minikube.SetUp(name, kubernetesVersion, installServing, installEventing)
3434
},
3535
}
3636
// Set minikubeCmd options
3737
clusterNameOption(minikubeCmd, "knative")
3838
kubernetesVersionOption(minikubeCmd, "", "kubernetes version to use (1.x.y)")
3939
installServingOption(minikubeCmd)
4040
installEventingOption(minikubeCmd)
41-
installCamelOption(minikubeCmd)
4241
return minikubeCmd
4342
}

pkg/install/install.go

-62
Original file line numberDiff line numberDiff line change
@@ -205,34 +205,6 @@ metadata:
205205
return nil
206206
}
207207

208-
func CamelK(registryAddress string) error {
209-
fmt.Println("🐪 Installing Apache Camel K ... ")
210-
211-
if err := addHelmRepo(); err != nil {
212-
fmt.Printf("Error adding Helm repo: %v\n", err)
213-
return err
214-
}
215-
fmt.Println("Helm repo added successfully")
216-
217-
// Run the Helm install command
218-
if err := runHelmInstall(registryAddress); err != nil {
219-
fmt.Printf("Error: %v\n", err)
220-
return err
221-
}
222-
223-
if err := waitForCRDsEstablished(); err != nil {
224-
return fmt.Errorf("crds: %w", err)
225-
}
226-
fmt.Println(" CRDs installed...")
227-
228-
if err := waitForPodsReady("default"); err != nil {
229-
return fmt.Errorf("core: %w", err)
230-
}
231-
fmt.Println(" Apache Camel K installed...")
232-
233-
return nil
234-
}
235-
236208
func runCommand(c *exec.Cmd) error {
237209
if out, err := c.CombinedOutput(); err != nil {
238210
fmt.Println(string(out))
@@ -265,37 +237,3 @@ func waitForCRDsEstablished() error {
265237
func waitForPodsReady(ns string) error {
266238
return runCommand(exec.Command("kubectl", "wait", "pod", "--timeout=10m", "--for=condition=Ready", "-l", "!job-name", "-n", ns))
267239
}
268-
269-
//nolint:gosec // avoid linter warnings
270-
func runHelmInstall(registryAddress string) error {
271-
272-
// Check if helm CLI is installed
273-
if _, err := exec.LookPath("helm"); err != nil {
274-
return fmt.Errorf("Please install helm CLI")
275-
}
276-
277-
cmd := exec.Command("helm", "install",
278-
"--generate-name",
279-
"--set", fmt.Sprintf("platform.build.registry.address=%s", registryAddress),
280-
"--set", "platform.build.registry.insecure=true",
281-
"camel-k/camel-k")
282-
283-
cmd.Stdout = cmd.Stderr
284-
285-
if out, err := cmd.CombinedOutput(); err != nil {
286-
fmt.Println(string(out))
287-
return fmt.Errorf("failed to run helm install: %w", err)
288-
}
289-
return nil
290-
}
291-
292-
func addHelmRepo() error {
293-
cmd := exec.Command("helm", "repo", "add", "camel-k", "https://apache.github.io/camel-k/charts/")
294-
cmd.Stdout = cmd.Stderr
295-
296-
if out, err := cmd.CombinedOutput(); err != nil {
297-
fmt.Println(string(out))
298-
return fmt.Errorf("failed to add helm repo: %w", err)
299-
}
300-
return nil
301-
}

pkg/minikube/minikube.go

+1-24
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ var memory = "3072"
3535
var installKnative = true
3636

3737
// SetUp creates a local Minikube cluster and installs all the relevant Knative components
38-
func SetUp(name, kVersion string, installServing, installEventing, installCamel bool) error {
38+
func SetUp(name, kVersion string, installServing, installEventing bool) error {
3939
start := time.Now()
4040

4141
// if neither the "install-serving" or "install-eventing" flags are set,
@@ -83,19 +83,6 @@ func SetUp(name, kVersion string, installServing, installEventing, installCamel
8383
if err := install.Eventing(); err != nil {
8484
return fmt.Errorf("install eventing: %w", err)
8585
}
86-
87-
if installCamel {
88-
89-
registryAddress, err := getMinikubeRegistryAddress()
90-
if err != nil {
91-
fmt.Printf("Error: %v\n", err)
92-
return err
93-
}
94-
95-
if err := install.CamelK(registryAddress); err != nil {
96-
return fmt.Errorf("install Apache Camel K: %w", err)
97-
}
98-
}
9986
}
10087
}
10188

@@ -284,13 +271,3 @@ func recreateCluster() error {
284271
}
285272
return nil
286273
}
287-
288-
func getMinikubeRegistryAddress() (string, error) {
289-
cmd := exec.Command("kubectl", "-n", "kube-system", "get", "service", "registry", "-o", "jsonpath={.spec.clusterIP}")
290-
out, err := cmd.CombinedOutput()
291-
if err != nil {
292-
return "", fmt.Errorf("failed to get registry address: %w", err)
293-
}
294-
address := strings.TrimSpace(string(out))
295-
return address, nil
296-
}

0 commit comments

Comments
 (0)