- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 67 for newCodecFactory (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubeapiserver/options/authentication.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0) -
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) -
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) -
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)