🌱 Support disconnected hub.

Signed-off-by: Jeff Ortel <jortel@redhat.com>

cmd/main.go

@@ -102,25 +102,27 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	//
-	// k8s scheme.
-	err = buildScheme()
-	if err != nil {
-		return
-	}
-	//
-	// Add controller.
-	addonManager, err := addonManager(db)
-	if err != nil {
-		return
-	}
-	go func() {
-		err = addonManager.Start(make(<-chan struct{}))
+	if !Settings.Disconnected {
+		//
+		// k8s scheme.
+		err = buildScheme()
 		if err != nil {
-			err = liberr.Wrap(err)
 			return
 		}
-	}()
+		//
+		// Add controller.
+		addonManager, err := addonManager(db)
+		if err != nil {
+			return
+		}
+		go func() {
+			err = addonManager.Start(make(<-chan struct{}))
+			if err != nil {
+				err = liberr.Wrap(err)
+				return
+			}
+		}()
+	}
 	//
 	// k8s client.
 	client, err := k8s.NewClient()

k8s/client.go

@@ -1,15 +1,24 @@
 package k8s
 
 import (
+	"context"
 	liberr "github.com/konveyor/controller/pkg/error"
+	"github.com/konveyor/tackle2-hub/settings"
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/client-go/kubernetes/scheme"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/client/config"
 )
 
+var Settings = &settings.Settings
+
 //
 // NewClient builds new k8s client.
 func NewClient() (newClient client.Client, err error) {
+	if Settings.Disconnected {
+		newClient = &FakeClient{}
+		return
+	}
 	cfg, _ := config.GetConfig()
 	newClient, err = client.New(
 		cfg,
@@ -21,3 +30,30 @@ func NewClient() (newClient client.Client, err error) {
 	}
 	return
 }
+
+type FakeClient struct {
+}
+
+func (r *FakeClient) Get(_ context.Context, _ client.ObjectKey, _ runtime.Object) (err error) {
+	return
+}
+
+func (r *FakeClient) List(_ context.Context, _ *client.ListOptions, _ runtime.Object) (err error) {
+	return
+}
+
+func (r *FakeClient) Create(_ context.Context, _ runtime.Object) (err error) {
+	return
+}
+
+func (r *FakeClient) Delete(_ context.Context, _ runtime.Object, _ ...client.DeleteOptionFunc) (err error) {
+	return
+}
+
+func (r *FakeClient) Update(_ context.Context, _ runtime.Object) (err error) {
+	return
+}
+
+func (r *FakeClient) Status() (w client.StatusWriter) {
+	return
+}

settings/hub.go

@@ -24,6 +24,7 @@ const (
 	EnvDevelopment       = "DEVELOPMENT"
 	EnvFileTTL           = "FILE_TTL"
 	EnvAppName           = "APP_NAME"
+	EnvDisconnected      = "DISCONNECTED"
 )
 
 type Hub struct {
@@ -72,6 +73,8 @@ type Hub struct {
 	Development bool
 	// Product - deployed as product.
 	Product bool
+	// Disconnected indicates no cluster.
+	Disconnected bool
 }
 
 func (r *Hub) Load() (err error) {
@@ -161,8 +164,6 @@ func (r *Hub) Load() (err error) {
 	if found {
 		b, _ := strconv.ParseBool(s)
 		r.Development = b
-	} else {
-		r.Development = false
 	}
 	s, found = os.LookupEnv(EnvFileTTL)
 	if found {
@@ -174,8 +175,11 @@ func (r *Hub) Load() (err error) {
 	s, found = os.LookupEnv(EnvAppName)
 	if found {
 		r.Product = !(s == "" || s == "tackle")
-	} else {
-		r.Product = false
+	}
+	s, found = os.LookupEnv(EnvDisconnected)
+	if found {
+		b, _ := strconv.ParseBool(s)
+		r.Disconnected = b
 	}
 
 	return