elias/caddy-ingess
1
0
Fork 0
mirror of https://github.com/eliasstepanik/caddy-ingess.git synced 2026-01-11 12:38:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

If secret doesn't exist, return fs.ErrNotExist (#100)

Browse Source
This commit is contained in:
Nila 2022-08-22 12:00:33 +02:00 committed by GitHub
parent f7739a6837
commit 769911d4f8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/storage/storage.go
View File

@ -3,6 +3,11 @@ package storage
import ( import (
"context" "context"
"fmt" "fmt"
"io/fs"
"regexp"
"strings"
"time"
"github.com/caddyserver/caddy/v2" "github.com/caddyserver/caddy/v2"
"github.com/caddyserver/certmagic" "github.com/caddyserver/certmagic"
"github.com/google/uuid" "github.com/google/uuid"
@ -14,9 +19,6 @@ import (
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/tools/leaderelection/resourcelock" "k8s.io/client-go/tools/leaderelection/resourcelock"
"regexp"
"strings"
"time"
) )
const ( const (
@ -130,6 +132,9 @@ func (s *SecretStorage) Store(ctx context.Context, key string, value []byte) err
func (s *SecretStorage) Load(ctx context.Context, key string) ([]byte, error) { func (s *SecretStorage) Load(ctx context.Context, key string) ([]byte, error) {
secret, err := s.KubeClient.CoreV1().Secrets(s.Namespace).Get(context.TODO(), cleanKey(key, keyPrefix), metav1.GetOptions{}) secret, err := s.KubeClient.CoreV1().Secrets(s.Namespace).Get(context.TODO(), cleanKey(key, keyPrefix), metav1.GetOptions{})
if err != nil { if err != nil {
if errors.IsNotFound(err) {
return nil, fs.ErrNotExist
}
return nil, err return nil, err
} }