Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 84 for newCodecFactory (0.37 sec)

  1. staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/roundtrip.go

    func RoundTripTestForScheme(t *testing.T, scheme *runtime.Scheme, fuzzingFuncs fuzzer.FuzzerFuncs) {
    	codecFactory := runtimeserializer.NewCodecFactory(scheme)
    	f := fuzzer.FuzzerFor(
    		fuzzer.MergeFuzzerFuncs(metafuzzer.Funcs, fuzzingFuncs),
    		rand.NewSource(rand.Int63()),
    		codecFactory,
    	)
    	RoundTripTypesWithoutProtobuf(t, scheme, codecFactory, f, nil)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 16.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go

    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	utilruntime.Must(corev1.AddToScheme(scheme))
    	utilruntime.Must(scheme.SetVersionPriority(corev1.SchemeGroupVersion))
    
    	codecs = serializer.NewCodecFactory(scheme)
    }
    
    var codecs serializer.CodecFactory
    
    type serverInfo struct {
    	existingIP     string
    	id             string
    	ports          []corev1.EndpointPort
    	newIP          string
    	removeLease    bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. pkg/webhooks/validation/server/server.go

    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/log"
    )
    
    var scope = log.RegisterScope("validationServer", "validation webhook server")
    
    var (
    	runtimeScheme = runtime.NewScheme()
    	codecs        = serializer.NewCodecFactory(runtimeScheme)
    	deserializer  = codecs.UniversalDeserializer()
    
    	// Expect AdmissionRequest to only include these top-level field names
    	validFields = map[string]bool{
    		"apiVersion": true,
    		"kind":       true,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 04 06:13:56 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go

    	genericapiserver "k8s.io/apiserver/pkg/server"
    	serverstorage "k8s.io/apiserver/pkg/server/storage"
    	"k8s.io/apiserver/pkg/util/webhook"
    )
    
    var (
    	Scheme = runtime.NewScheme()
    	Codecs = serializer.NewCodecFactory(Scheme)
    
    	// if you modify this, make sure you update the crEncoder
    	unversionedVersion = schema.GroupVersion{Group: "", Version: "v1"}
    	unversionedTypes   = []runtime.Object{
    		&metav1.Status{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 14:31:43 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/test/api_meta_help_test.go

    			t.Fatalf("%d: unmatched: %s", i, cmp.Diff(e, a))
    		}
    	}
    }
    
    func TestSetExtractListRoundTrip(t *testing.T) {
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    	fuzzer := fuzz.New().NilChance(0).NumElements(1, 5).Funcs(metafuzzer.Funcs(codecs)...).MaxDepth(10)
    	for i := 0; i < 5; i++ {
    		start := &testapigroup.CarpList{}
    		fuzzer.Fuzz(&start.Items)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go

    	cliflag "k8s.io/component-base/cli/flag"
    	"k8s.io/klog/v2/ktesting"
    	netutils "k8s.io/utils/net"
    )
    
    func setUp(t *testing.T) server.Config {
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    
    	config := server.NewConfig(codecs)
    
    	return *config
    }
    
    type TestCertSpec struct {
    	host       string
    	names, ips []string // in certificate
    }
    
    type NamedTestCertSpec struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 15:52:39 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    var statusScheme = runtime.NewScheme()
    
    // ParameterCodec knows about query parameters used with the meta v1 API spec.
    var statusCodecs = serializer.NewCodecFactory(statusScheme)
    
    func init() {
    	statusScheme.AddUnversionedTypes(metav1.SchemeGroupVersion,
    		&metav1.Status{},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go

    var codecs = runtimeserializer.NewCodecFactory(scheme)
    
    const discoveryPath = "/apis"
    
    func init() {
    	utilruntime.Must(apidiscoveryv2.AddToScheme(scheme))
    	utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme))
    	// Register conversion for apidiscovery
    	utilruntime.Must(apidiscoveryv2conversion.RegisterConversions(scheme))
    	codecs = runtimeserializer.NewCodecFactory(scheme)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 02 00:29:39 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/test/api_meta_meta_test.go

    	metav1.TypeMeta
    	metav1.ObjectMeta
    }
    
    func getObjectMetaAndOwnerReferences() (myAPIObject2 MyAPIObject2, metaOwnerReferences []metav1.OwnerReference) {
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    	fuzz.New().NilChance(.5).NumElements(1, 5).Funcs(metafuzzer.Funcs(codecs)...).MaxDepth(10).Fuzz(&myAPIObject2)
    	references := myAPIObject2.ObjectMeta.OwnerReferences
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 14 10:11:56 UTC 2022
    - 12.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/filters/impersonation_test.go

    				actualUser = nil
    				return
    			} else {
    				actualUser = user
    			}
    
    			delegate.ServeHTTP(w, req)
    		})
    	}(WithImpersonation(doNothingHandler, impersonateAuthorizer{}, serializer.NewCodecFactory(runtime.NewScheme())))
    
    	server := httptest.NewServer(handler)
    	defer server.Close()
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			func() {
    				lock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 06 17:13:16 UTC 2021
    - 17.2K bytes
    - Viewed (0)
Back to top