Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 84 for newCodecFactory (0.33 sec)

  1. pkg/controlplane/reconcilers/lease_test.go

    	utilruntime.Must(core.AddToScheme(scheme))
    	utilruntime.Must(corev1.AddToScheme(scheme))
    	utilruntime.Must(scheme.SetVersionPriority(corev1.SchemeGroupVersion))
    
    	codecs = serializer.NewCodecFactory(scheme)
    }
    
    var codecs serializer.CodecFactory
    
    type fakeLeases struct {
    	storageLeases
    }
    
    var _ Leases = &fakeLeases{}
    
    func newFakeLeases(t *testing.T, s storage.Interface) *fakeLeases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 28.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go

    )
    
    const (
    	extensionsGroupName = "extensions"
    )
    
    var (
    	v1GroupVersion = schema.GroupVersion{Group: "", Version: "v1"}
    
    	scheme         = runtime.NewScheme()
    	codecs         = serializer.NewCodecFactory(scheme)
    	parameterCodec = runtime.NewParameterCodec(scheme)
    )
    
    func init() {
    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	scheme.AddUnversionedTypes(v1GroupVersion,
    		&metav1.Status{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	"k8s.io/apiserver/pkg/storage/etcd3/testserver"
    	storagetesting "k8s.io/apiserver/pkg/storage/testing"
    	"k8s.io/apiserver/pkg/storage/value"
    )
    
    var scheme = runtime.NewScheme()
    var codecs = serializer.NewCodecFactory(scheme)
    
    const defaultTestPrefix = "test!"
    
    func init() {
    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	utilruntime.Must(example.AddToScheme(scheme))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  4. pkg/kubeapiserver/options/authentication.go

    		allErrors = append(allErrors, fmt.Errorf("authentication-config file and oidc-* flags are mutually exclusive"))
    	}
    
    	return allErrors
    }
    
    var (
    	cfgScheme = runtime.NewScheme()
    	codecs    = serializer.NewCodecFactory(cfgScheme, serializer.EnableStrict)
    )
    
    func init() {
    	install.Install(cfgScheme)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
    	"k8s.io/component-base/metrics/legacyregistry"
    	"k8s.io/component-base/metrics/testutil"
    )
    
    var (
    	scheme = runtime.NewScheme()
    	codecs = serializer.NewCodecFactory(scheme)
    )
    
    func init() {
    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	utilruntime.Must(example.AddToScheme(scheme))
    	utilruntime.Must(examplev1.AddToScheme(scheme))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/cli-runtime/pkg/resource/builder.go

    	if b.mapper != nil {
    		b.errs = append(b.errs, fmt.Errorf("another mapper was already selected, cannot use internal types"))
    		return b
    	}
    	b.objectTyper = scheme
    	codecFactory := serializer.NewCodecFactory(scheme)
    	negotiatedSerializer := runtime.NegotiatedSerializer(codecFactory)
    	// if you specified versions, you're specifying a desire for external types, which you don't want to round-trip through
    	// internal types
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 10:17:56 UTC 2023
    - 37.2K bytes
    - Viewed (0)
  7. pkg/kube/client.go

    	}
    	return obj, dr, nil
    }
    
    // IstioScheme returns a scheme will all known Istio-related types added
    var (
    	IstioScheme = istioScheme()
    	IstioCodec  = serializer.NewCodecFactory(IstioScheme)
    )
    
    // FakeIstioScheme is an IstioScheme that has List type registered.
    var FakeIstioScheme = func() *runtime.Scheme {
    	s := istioScheme()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    }
    
    func init() {
    	configScheme := runtime.NewScheme()
    	utilruntime.Must(apiserver.AddToScheme(configScheme))
    	utilruntime.Must(apiserverv1.AddToScheme(configScheme))
    	codecs = serializer.NewCodecFactory(configScheme, serializer.EnableStrict)
    	envelopemetrics.RegisterMetrics()
    	storagevalue.RegisterMetrics()
    	metrics.RegisterMetrics()
    }
    
    type kmsPluginHealthzResponse struct {
    	err      error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  9. pkg/kube/inject/webhook.go

    	"istio.io/istio/pkg/util/sets"
    	iptablesconstants "istio.io/istio/tools/istio-iptables/pkg/constants"
    )
    
    var (
    	runtimeScheme     = runtime.NewScheme()
    	codecs            = serializer.NewCodecFactory(runtimeScheme)
    	deserializer      = codecs.UniversalDeserializer()
    	jsonSerializer    = kjson.NewSerializerWithOptions(kjson.DefaultMetaFactory, runtimeScheme, runtimeScheme, kjson.SerializerOptions{})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    		// override scale subresource values
    		// shallow copy
    		scaleScope := *requestScopes[v.Name]
    		scaleConverter := scale.NewScaleConverter()
    		scaleScope.Subresource = "scale"
    		scaleScope.Serializer = serializer.NewCodecFactory(scaleConverter.Scheme())
    		scaleScope.Kind = autoscalingv1.SchemeGroupVersion.WithKind("Scale")
    		scaleScope.Namer = handlers.ContextBasedNaming{
    			Namer:         meta.NewAccessor(),
    			ClusterScoped: clusterScoped,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
Back to top