Skip to content

Commit

Permalink
Merge pull request #245 from web-seven/244-bugregistry-not-possible-t…
Browse files Browse the repository at this point in the history
…o-delete-local-registry

added local registy to list of registries
  • Loading branch information
evghen1 authored Nov 25, 2024
2 parents 657027f + 75c37bb commit 768b849
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 12 deletions.
5 changes: 2 additions & 3 deletions cmd/overlock/registry/delete.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,17 +11,16 @@ import (
type deleteCmd struct {
Name string `required:"" help:"Registry name."`
Default bool `help:"Remove from default."`
Local bool `help:"Remove associated local registry."`
}

func (c deleteCmd) Run(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error {
reg := registry.Registry{}
reg.Name = c.Name
reg.SetDefault(c.Default)
reg.SetLocal(c.Local)
reg.SetLocal(c.Name == registry.LocalRegistryName)
err := reg.Delete(ctx, config, logger)
if err != nil {
logger.Error(err)
logger.Info(err)
} else {
logger.Info("Registry was removed successfully.")
}
Expand Down
18 changes: 9 additions & 9 deletions internal/registry/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ var (
RegistryServerLabel = "overlock-registry-server-url"
DefaultRemoteDomain = "xpkg.upbound.io"
LocalServiceName = "registry"
LocalRegistryName = "registry.local"
defaultLocalDomain = LocalServiceName + ".%s.svc.cluster.local"
AuthConfigLabel = "overlock-registry-auth-config"
)
Expand Down Expand Up @@ -98,7 +99,7 @@ func NewLocal() Registry {
registry := Registry{
Default: false,
Local: true,
Name: "registry.local",
Name: LocalRegistryName,
}
registry.Server = registry.LocalDomain()
return registry
Expand Down Expand Up @@ -153,6 +154,12 @@ func (r *Registry) Create(ctx context.Context, config *rest.Config, logger *zap.
return err
}

secretSpec := r.SecretSpec()
_, err = secretClient(client).Create(ctx, &secretSpec, metav1.CreateOptions{})
if err != nil {
return err
}

if r.Local {
logger.Debug("Creating local registry")
err := r.CreateLocal(ctx, client, logger)
Expand All @@ -162,11 +169,6 @@ func (r *Registry) Create(ctx context.Context, config *rest.Config, logger *zap.
logger.Debug("Local registry created.")
} else {
logger.Debug("Creating remote registry")
secretSpec := r.SecretSpec()
_, err := secretClient(client).Create(ctx, &secretSpec, metav1.CreateOptions{})
if err != nil {
return err
}
err = r.SetRegistyPullSecret(ctx, config)
if err != nil {
return err
Expand Down Expand Up @@ -274,9 +276,7 @@ func (r *Registry) Delete(ctx context.Context, config *rest.Config, logger *zap.

release, _ := installer.GetRelease()

if release.Config == nil || release.Config["imagePullSecrets"] == nil {
logger.Warn("Not found any registry in context.")
} else {
if release != nil && release.Config != nil && release.Config["imagePullSecrets"] != nil {
oldRegistries := release.Config["imagePullSecrets"].([]interface{})

newRegistries := []interface{}{}
Expand Down

0 comments on commit 768b849

Please sign in to comment.