Merge pull request #198 from kndpio/191-registry-creation-context

added --context parameter for registry creation

Author: evghen1

cmd/kndp/registry/create.go

@@ -21,12 +21,14 @@ type createCmd struct {
 	Email          string `help:"is your Email."`
 	Default        bool   `help:"Set registry as default."`
 	Local          bool   `help:"Create local registry."`
+	Context        string `short:"c" help:"Kubernetes context where registry will be created."`
 }
 
 func (c *createCmd) Run(ctx context.Context, client *kubernetes.Clientset, config *rest.Config, logger *zap.SugaredLogger) error {
 	reg := registry.New(c.RegistryServer, c.Username, c.Password, c.Email)
 	reg.SetDefault(c.Default)
 	reg.SetLocal(c.Local)
+	reg.WithContext(c.Context)
 	err := reg.Validate(ctx, client, logger)
 	if err != nil {
 		return err

internal/registry/registry.go

@@ -18,6 +18,7 @@ import (
 	"k8s.io/client-go/kubernetes"
 	kv1 "k8s.io/client-go/kubernetes/typed/core/v1"
 	"k8s.io/client-go/rest"
+	cfg "sigs.k8s.io/controller-runtime/pkg/client/config"
 )
 
 const (
@@ -44,6 +45,7 @@ type Registry struct {
 	Config  RegistryConfig
 	Default bool
 	Local   bool
+	Context string
 	corev1.Secret
 }
 
@@ -138,6 +140,13 @@ func (r *Registry) SecretSpec() corev1.Secret {
 
 // Creates registry in requested context and assign it to engine
 func (r *Registry) Create(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error {
+	var err error
+	if r.Context != "" {
+		config, err = cfg.GetConfigWithContext(r.Context)
+		if err != nil {
+			return err
+		}
+	}
 
 	client, err := kube.Client(config)
 	if err != nil {
@@ -350,6 +359,11 @@ func (r *Registry) SetLocal(l bool) {
 	r.Local = l
 }
 
+// Kubernetes context where registry will be created
+func (r *Registry) WithContext(c string) {
+	r.Context = c
+}
+
 // Domain of primary registry
 func (r *Registry) Domain() string {
 	if r.Local {