test/extended/etcd/etcd_storage_path.go: decode CBOR data

Author: bertinatto

test/extended/etcd/etcd_storage_path.go

@@ -28,6 +28,7 @@ import (
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
+	cbor "k8s.io/apimachinery/pkg/runtime/serializer/cbor/direct"
 	"k8s.io/apimachinery/pkg/util/diff"
 	"k8s.io/apimachinery/pkg/util/errors"
 	"k8s.io/apimachinery/pkg/util/sets"
@@ -678,7 +679,10 @@ func JSONToUnstructured(stub, namespace string, mapping *meta.RESTMapping, dynam
 	return dynamicClient.Resource(mapping.Resource).Namespace(namespace), &unstructured.Unstructured{Object: typeMetaAdder}, nil
 }
 
-var protoEncodingPrefix = []byte{0x6b, 0x38, 0x73, 0x00}
+var (
+	protoEncodingPrefix = []byte{0x6b, 0x38, 0x73, 0x00}
+	cborPrefix          = []byte{0xd9, 0xd9, 0xf7}
+)
 
 func getFromEtcd(kv etcdv3.KV, path string) (*metaObject, error) {
 	response, err := kv.Get(context.Background(), "/"+path)
@@ -712,6 +716,10 @@ func getFromEtcd(kv etcdv3.KV, path string) (*metaObject, error) {
 		if err := json.Unmarshal(value, metaObj); err != nil {
 			return nil, err
 		}
+	case bytes.HasPrefix(value, cborPrefix):
+		if err := cbor.Unmarshal(value, metaObj); err != nil {
+			return nil, err
+		}
 	default:
 		// TODO handle encrypted data
 		return nil, fmt.Errorf("unknown data format at path /%s: %s", path, string(value))