mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-12-02 03:00:23 +00:00
80 lines
2.5 KiB
Go
80 lines
2.5 KiB
Go
/*
|
|
Copyright 2018 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package resource
|
|
|
|
import (
|
|
"encoding/json"
|
|
"io"
|
|
"strings"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
"k8s.io/apimachinery/pkg/runtime/serializer"
|
|
"k8s.io/client-go/kubernetes/scheme"
|
|
"k8s.io/client-go/rest"
|
|
)
|
|
|
|
// dynamicCodec is a codec that wraps the standard unstructured codec
|
|
// with special handling for Status objects.
|
|
// Deprecated only used by test code and its wrong
|
|
type dynamicCodec struct{}
|
|
|
|
func (dynamicCodec) Decode(data []byte, gvk *schema.GroupVersionKind, obj runtime.Object) (runtime.Object, *schema.GroupVersionKind, error) {
|
|
obj, gvk, err := unstructured.UnstructuredJSONScheme.Decode(data, gvk, obj)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
if _, ok := obj.(*metav1.Status); !ok && strings.ToLower(gvk.Kind) == "status" {
|
|
obj = &metav1.Status{}
|
|
err := json.Unmarshal(data, obj)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
}
|
|
|
|
return obj, gvk, nil
|
|
}
|
|
|
|
func (dynamicCodec) Encode(obj runtime.Object, w io.Writer) error {
|
|
return unstructured.UnstructuredJSONScheme.Encode(obj, w)
|
|
}
|
|
|
|
// ContentConfig returns a rest.ContentConfig for dynamic types. It includes enough codecs to act as a "normal"
|
|
// serializer for the rest.client with options, status and the like.
|
|
func UnstructuredPlusDefaultContentConfig() rest.ContentConfig {
|
|
var jsonInfo runtime.SerializerInfo
|
|
// TODO: scheme.Codecs here should become "pkg/apis/server/scheme" which is the minimal core you need
|
|
// to talk to a kubernetes server
|
|
for _, info := range scheme.Codecs.SupportedMediaTypes() {
|
|
if info.MediaType == runtime.ContentTypeJSON {
|
|
jsonInfo = info
|
|
break
|
|
}
|
|
}
|
|
|
|
jsonInfo.Serializer = dynamicCodec{}
|
|
jsonInfo.PrettySerializer = nil
|
|
return rest.ContentConfig{
|
|
AcceptContentTypes: runtime.ContentTypeJSON,
|
|
ContentType: runtime.ContentTypeJSON,
|
|
NegotiatedSerializer: serializer.NegotiatedSerializerWrapper(jsonInfo),
|
|
}
|
|
}
|