Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 67 for newCodecFactory (0.33 sec)

  1. istioctl/pkg/kubeinject/kubeinject.go

    		r.AddKnownTypes(admissionv1beta1.SchemeGroupVersion, &admissionv1beta1.AdmissionReview{})
    		r.AddKnownTypes(admission.SchemeGroupVersion, &admission.AdmissionReview{})
    		return r
    	}()
    	codecs       = serializer.NewCodecFactory(runtimeScheme)
    	deserializer = codecs.UniversalDeserializer()
    )
    
    // GetFirstPod returns a pod matching the namespace and label selector
    // and the number of all pods that match the label selector.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 29 02:29:02 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  2. pkg/kube/util.go

    		// will not be round-tripped through internal versions. Defaulting does not happen
    		// on the client.
    		config.NegotiatedSerializer = serializer.NewCodecFactory(IstioScheme).WithoutConversion()
    	}
    	if len(config.UserAgent) == 0 {
    		config.UserAgent = IstioUserAgent()
    	}
    
    	return config
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/validation_test.go

    )
    
    // TestRoundTrip checks the conversion to go-openapi types.
    // internal -> go-openapi -> JSON -> external -> internal
    func TestRoundTrip(t *testing.T) {
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    
    	// add internal and external types to scheme
    	if err := apiextensions.AddToScheme(scheme); err != nil {
    		t.Fatal(err)
    	}
    	if err := apiextensionsv1.AddToScheme(scheme); err != nil {
    		t.Fatal(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 04:49:59 UTC 2023
    - 24.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top