66 "sync"
77
88 "github.com/pkg/errors"
9+ "github.com/replicatedhq/replicated-sdk/pkg/logger"
910 "github.com/replicatedhq/replicated-sdk/pkg/util"
1011 corev1 "k8s.io/api/core/v1"
1112 kuberneteserrors "k8s.io/apimachinery/pkg/api/errors"
@@ -90,8 +91,7 @@ func save(ctx context.Context, clientset kubernetes.Interface, namespace string,
9091}
9192
9293var (
93- ErrReplicatedMetadataSecretEmpty = errors .New ("replicated metadata secret is empty" )
94- ErrReplicatedMetadataSecretNotFound = errors .New ("replicated metadata secret not found" )
94+ ErrReplicatedMetadataNotFound = errors .New ("replicated metadata not found" )
9595)
9696
9797func get (ctx context.Context , clientset kubernetes.Interface , namespace string , key replicatedMetadataSecretKey , v interface {}) error {
@@ -101,20 +101,21 @@ func get(ctx context.Context, clientset kubernetes.Interface, namespace string,
101101 }
102102
103103 if kuberneteserrors .IsNotFound (err ) {
104- return ErrReplicatedMetadataSecretNotFound
104+ return ErrReplicatedMetadataNotFound
105105 }
106106
107107 if len (secret .Data ) == 0 {
108- return ErrReplicatedMetadataSecretEmpty
108+ return ErrReplicatedMetadataNotFound
109109 }
110110
111111 dataBytes , ok := secret .Data [string (key )]
112112 if ! ok || len (dataBytes ) == 0 {
113- return errors .Wrapf (ErrReplicatedMetadataSecretEmpty , "key (%s) not found in secret" , key )
113+ return errors .Wrapf (ErrReplicatedMetadataNotFound , "key (%s) not found in secret" , key )
114114 }
115115
116116 if err := json .Unmarshal (dataBytes , v ); err != nil {
117- return errors .Wrapf (err , "failed to unmarshal secret data for key %s" , key )
117+ logger .Infof ("failed to unmarshal secret data for key %s: %v" , key , err )
118+ return ErrReplicatedMetadataNotFound
118119 }
119120
120121 return nil
0 commit comments