Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 67 for newCodecFactory (0.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    	}()
    
    	return t.SharedIndexInformer.RemoveEventHandler(registration)
    }
    
    var (
    	scheme  *runtime.Scheme             = runtime.NewScheme()
    	codecs  serializer.CodecFactory     = serializer.NewCodecFactory(scheme)
    	fakeGVR schema.GroupVersionResource = schema.GroupVersionResource{
    		Group:    "fake.example.com",
    		Version:  "v1",
    		Resource: "fakes",
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline_test.go

    func message(err error) string {
    	if err != nil {
    		return err.Error()
    	}
    
    	return ""
    }
    
    func newSerializer() runtime.NegotiatedSerializer {
    	scheme := runtime.NewScheme()
    	return serializer.NewCodecFactory(scheme).WithoutConversion()
    }
    
    type fakeRequestResolver struct{}
    
    func (r fakeRequestResolver) NewRequestInfo(req *http.Request) (*request.RequestInfo, error) {
    	return &request.RequestInfo{}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 14 23:04:34 UTC 2022
    - 16.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go

    	utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme))
    	// Register conversion for apidiscovery
    	utilruntime.Must(apidiscoveryv2conversion.RegisterConversions(scheme))
    
    	codecs := serializer.NewCodecFactory(scheme)
    	rdm := &resourceDiscoveryManager{
    		serializer:        codecs,
    		versionPriorities: make(map[groupVersionKey]priorityInfo),
    	}
    	rdm.serveHTTPFunc = metrics.InstrumentHandlerFunc("GET",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 02 00:29:39 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. pkg/credentialprovider/plugin/plugin.go

    	"k8s.io/utils/clock"
    )
    
    const (
    	globalCacheKey     = "global"
    	cachePurgeInterval = time.Minute * 15
    )
    
    var (
    	scheme = runtime.NewScheme()
    	codecs = serializer.NewCodecFactory(scheme)
    
    	apiVersions = map[string]schema.GroupVersion{
    		credentialproviderv1alpha1.SchemeGroupVersion.String(): credentialproviderv1alpha1.SchemeGroupVersion,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 05:07:28 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    	// Make an object tracker specifically for our policies and bindings
    	policiesAndBindingsTracker := clienttesting.NewObjectTracker(
    		policySourceTestScheme,
    		serializer.NewCodecFactory(policySourceTestScheme).UniversalDecoder())
    
    	// Make an informer for our policies and bindings
    
    	policyInformer := cache.NewSharedIndexInformer(
    		&cache.ListWatch{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. pilot/pkg/config/file/store.go

    			group:   groupVersionKind.Group,
    			version: groupVersionKind.Version,
    			kind:    groupVersionKind.Kind,
    		}
    	}
    
    	runtimeScheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(runtimeScheme)
    	deserializer := codecs.UniversalDeserializer()
    	obj, err := kube.IstioScheme.New(schema.GroupVersionKind().Kubernetes())
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
Back to top