add CodecFactoryOptions for codecfactory

Author: Chaunceyctx

pkg/cache/cache.go

@@ -32,6 +32,7 @@ import (
 	"k8s.io/apimachinery/pkg/labels"
 	"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"
 	toolscache "k8s.io/client-go/tools/cache"
@@ -140,6 +141,9 @@ type Options struct {
 	// Scheme is the scheme to use for mapping objects to GroupVersionKinds
 	Scheme *runtime.Scheme
 
+	// CodecFactoryOptions is used to indicate whether enable Strict/Pretty mode of CodecFactory
+	CodecFactoryOptions serializer.CodecFactoryOptions
+
 	// Mapper is the RESTMapper to use for mapping GroupVersionKinds to Resources
 	Mapper meta.RESTMapper
 
@@ -419,11 +423,12 @@ func newCache(restConfig *rest.Config, opts Options) newCacheFunc {
 		return &informerCache{
 			scheme: opts.Scheme,
 			Informers: internal.NewInformers(restConfig, &internal.InformersOpts{
-				HTTPClient:   opts.HTTPClient,
-				Scheme:       opts.Scheme,
-				Mapper:       opts.Mapper,
-				ResyncPeriod: *opts.SyncPeriod,
-				Namespace:    namespace,
+				HTTPClient:          opts.HTTPClient,
+				Scheme:              opts.Scheme,
+				CodecFactoryOptions: opts.CodecFactoryOptions,
+				Mapper:              opts.Mapper,
+				ResyncPeriod:        *opts.SyncPeriod,
+				Namespace:           namespace,
 				Selector: internal.Selector{
 					Label: config.LabelSelector,
 					Field: config.FieldSelector,

pkg/cache/internal/informers.go

@@ -44,6 +44,7 @@ import (
 type InformersOpts struct {
 	HTTPClient            *http.Client
 	Scheme                *runtime.Scheme
+	CodecFactoryOptions   serializer.CodecFactoryOptions
 	Mapper                meta.RESTMapper
 	ResyncPeriod          time.Duration
 	Namespace             string
@@ -61,6 +62,13 @@ func NewInformers(config *rest.Config, options *InformersOpts) *Informers {
 	if options.NewInformer != nil {
 		newInformer = *options.NewInformer
 	}
+	var mutators []serializer.CodecFactoryOptionsMutator
+	if options.CodecFactoryOptions.Strict {
+		mutators = append(mutators, serializer.EnableStrict)
+	}
+	if options.CodecFactoryOptions.Pretty {
+		mutators = append(mutators, serializer.EnablePretty)
+	}
 	return &Informers{
 		config:     config,
 		httpClient: options.HTTPClient,
@@ -71,7 +79,7 @@ func NewInformers(config *rest.Config, options *InformersOpts) *Informers {
 			Unstructured: make(map[schema.GroupVersionKind]*Cache),
 			Metadata:     make(map[schema.GroupVersionKind]*Cache),
 		},
-		codecs:                serializer.NewCodecFactory(options.Scheme),
+		codecs:                serializer.NewCodecFactory(options.Scheme, mutators...),
 		paramCodec:            runtime.NewParameterCodec(options.Scheme),
 		resync:                options.ResyncPeriod,
 		startWait:             make(chan struct{}),

pkg/client/client.go

@@ -44,6 +44,9 @@ type Options struct {
 	// Scheme, if provided, will be used to map go structs to GroupVersionKinds
 	Scheme *runtime.Scheme
 
+	// CodecFactoryOptions, if provided, will be used to indicate whether enable Strict/Pretty mode of CodecFactory
+	CodecFactoryOptions serializer.CodecFactoryOptions
+
 	// Mapper, if provided, will be used to map GroupVersionKinds to Resources
 	Mapper meta.RESTMapper
 
@@ -145,12 +148,20 @@ func newClient(config *rest.Config, options Options) (*client, error) {
 		}
 	}
 
+	var mutators []serializer.CodecFactoryOptionsMutator
+	if options.CodecFactoryOptions.Strict {
+		mutators = append(mutators, serializer.EnableStrict)
+	}
+	if options.CodecFactoryOptions.Pretty {
+		mutators = append(mutators, serializer.EnablePretty)
+	}
+
 	resources := &clientRestResources{
 		httpClient: options.HTTPClient,
 		config:     config,
 		scheme:     options.Scheme,
 		mapper:     options.Mapper,
-		codecs:     serializer.NewCodecFactory(options.Scheme),
+		codecs:     serializer.NewCodecFactory(options.Scheme, mutators...),
 
 		structuredResourceByType:   make(map[schema.GroupVersionKind]*resourceMeta),
 		unstructuredResourceByType: make(map[schema.GroupVersionKind]*resourceMeta),