Skip to content

Commit

Permalink
registry delete command
Browse files Browse the repository at this point in the history
  • Loading branch information
evghen1 committed Mar 1, 2024
1 parent a133ee3 commit e80dfd2
Show file tree
Hide file tree
Showing 3 changed files with 30 additions and 0 deletions.
24 changes: 24 additions & 0 deletions cmd/kndp/registry/delete.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
package registry

import (
"context"

"github.com/charmbracelet/log"
"github.com/kndpio/kndp/internal/registry"
"k8s.io/client-go/kubernetes"
)

type deleteCmd struct {
Name string `required:"" help:"Registry name."`
}

func (c deleteCmd) Run(ctx context.Context, client *kubernetes.Clientset, logger *log.Logger) error {
reg := registry.Registry{Name: c.Name}
err := reg.Delete(ctx, client)
if err != nil {
logger.Error(err)
} else {
logger.Info("Registry was removed successfully.")
}
return nil
}
1 change: 1 addition & 0 deletions cmd/kndp/registry/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,4 +3,5 @@ package registry
type Cmd struct {
Create createCmd `cmd:"" help:"Create registry"`
List listCmd `cmd:"" help:"List registries"`
Delete deleteCmd `cmd:"" help:"Delete registry"`
}
5 changes: 5 additions & 0 deletions internal/registry/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ type RegistryConfig struct {
}

type Registry struct {
Name string
Config RegistryConfig
}

Expand Down Expand Up @@ -107,6 +108,10 @@ func (r *Registry) Create(ctx context.Context, client *kubernetes.Clientset, con
return installer.Upgrade("", release.Config)
}

func (r *Registry) Delete(ctx context.Context, client *kubernetes.Clientset) error {
return secretClient(client).Delete(ctx, r.Name, v1.DeleteOptions{})
}

func secretClient(client *kubernetes.Clientset) kv1.SecretInterface {
return client.CoreV1().Secrets("default")
}

0 comments on commit e80dfd2

Please sign in to comment.