You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by as...@apache.org on 2020/02/26 18:34:44 UTC
[camel-k] 01/15: chore: Rename Minikube registry discovery package
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 1b4a32fcafd9dc8c5c3d97361c69d7fe18239a0f
Author: Antonin Stefanutti <an...@stefanutti.fr>
AuthorDate: Thu Feb 20 16:00:17 2020 +0100
chore: Rename Minikube registry discovery package
---
pkg/install/operator.go | 25 +++++++++-------------
.../minishift.go => minikube/registry.go} | 4 ++--
2 files changed, 12 insertions(+), 17 deletions(-)
diff --git a/pkg/install/operator.go b/pkg/install/operator.go
index fb7cb17..df44050 100644
--- a/pkg/install/operator.go
+++ b/pkg/install/operator.go
@@ -35,7 +35,7 @@ import (
"github.com/apache/camel-k/pkg/util/envvar"
"github.com/apache/camel-k/pkg/util/knative"
"github.com/apache/camel-k/pkg/util/kubernetes"
- "github.com/apache/camel-k/pkg/util/minishift"
+ "github.com/apache/camel-k/pkg/util/minikube"
)
// OperatorConfiguration --
@@ -105,12 +105,12 @@ func OperatorOrCollect(ctx context.Context, c client.Client, cfg OperatorConfigu
return o
}
- isOpenshift, err := isOpenShift(c, cfg.ClusterType)
+ isOpenShift, err := isOpenShift(c, cfg.ClusterType)
if err != nil {
return err
}
- if isOpenshift {
- if err := installOpenshift(ctx, c, cfg.Namespace, customizer, collection, force); err != nil {
+ if isOpenShift {
+ if err := installOpenShift(ctx, c, cfg.Namespace, customizer, collection, force); err != nil {
return err
}
} else {
@@ -139,7 +139,7 @@ func OperatorOrCollect(ctx context.Context, c client.Client, cfg OperatorConfigu
return nil
}
-func installOpenshift(ctx context.Context, c client.Client, namespace string, customizer ResourceCustomizer, collection *kubernetes.Collection, force bool) error {
+func installOpenShift(ctx context.Context, c client.Client, namespace string, customizer ResourceCustomizer, collection *kubernetes.Collection, force bool) error {
return ResourcesOrCollect(ctx, c, namespace, collection, force, customizer,
"operator-service-account.yaml",
"operator-role-openshift.yaml",
@@ -180,7 +180,7 @@ func Platform(ctx context.Context, c client.Client, clusterType string, namespac
// PlatformOrCollect --
// nolint: lll
func PlatformOrCollect(ctx context.Context, c client.Client, clusterType string, namespace string, registry v1.IntegrationPlatformRegistrySpec, collection *kubernetes.Collection) (*v1.IntegrationPlatform, error) {
- isOpenshift, err := isOpenShift(c, clusterType)
+ isOpenShift, err := isOpenShift(c, clusterType)
if err != nil {
return nil, err
}
@@ -190,22 +190,22 @@ func PlatformOrCollect(ctx context.Context, c client.Client, clusterType string,
}
pl := platformObject.(*v1.IntegrationPlatform)
- if !isOpenshift {
+ if !isOpenShift {
pl.Spec.Build.Registry = registry
// Kubernetes only (Minikube)
if registry.Address == "" {
// This operation should be done here in the installer
// because the operator is not allowed to look into the "kube-system" namespace
- minikubeRegistry, err := minishift.FindRegistry(ctx, c)
+ address, err := minikube.FindRegistry(ctx, c)
if err != nil {
return nil, err
}
- if minikubeRegistry == nil {
+ if address == nil {
return nil, errors.New("cannot find automatically a registry where to push images")
}
- pl.Spec.Build.Registry.Address = *minikubeRegistry
+ pl.Spec.Build.Registry.Address = *address
pl.Spec.Build.Registry.Insecure = true
}
}
@@ -213,11 +213,6 @@ func PlatformOrCollect(ctx context.Context, c client.Client, clusterType string,
return pl, nil
}
-// Example --
-func Example(ctx context.Context, c client.Client, namespace string, force bool) error {
- return ExampleOrCollect(ctx, c, namespace, nil, force)
-}
-
// ExampleOrCollect --
func ExampleOrCollect(ctx context.Context, c client.Client, namespace string, collection *kubernetes.Collection, force bool) error {
return ResourcesOrCollect(ctx, c, namespace, collection, force, IdentityResourceCustomizer,
diff --git a/pkg/util/minishift/minishift.go b/pkg/util/minikube/registry.go
similarity index 95%
rename from pkg/util/minishift/minishift.go
rename to pkg/util/minikube/registry.go
index ae7b284..6ad5faa 100644
--- a/pkg/util/minishift/minishift.go
+++ b/pkg/util/minikube/registry.go
@@ -16,7 +16,7 @@ limitations under the License.
*/
// Package minishift contains utilities for Minishift deployments
-package minishift
+package minikube
import (
"context"
@@ -33,7 +33,7 @@ const (
registryNamespace = "kube-system"
)
-// FindRegistry returns the Minishift registry location if any
+// FindRegistry returns the Minikube addon registry location if any
func FindRegistry(ctx context.Context, c client.Client) (*string, error) {
svcs := corev1.ServiceList{
TypeMeta: metav1.TypeMeta{