Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 70 for newCodecFactory (0.29 sec)

  1. istioctl/pkg/tag/generate.go

    	})
    	if err != nil {
    		return "", fmt.Errorf("failed rendering istio-control manifest: %v", err)
    	}
    
    	scheme := runtime.NewScheme()
    	codecFactory := serializer.NewCodecFactory(scheme)
    	deserializer := codecFactory.UniversalDeserializer()
    	serializer := json.NewSerializerWithOptions(
    		json.DefaultMetaFactory, nil, nil, json.SerializerOptions{
    			Yaml:   true,
    			Pretty: true,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 17:43:49 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/config.go

    	data, err := os.ReadFile(configFilePath)
    	if err != nil {
    		return nil, fmt.Errorf("unable to read admission control configuration from %q [%v]", configFilePath, err)
    	}
    	codecs := serializer.NewCodecFactory(configScheme)
    	decoder := codecs.UniversalDecoder()
    	decodedObj, err := runtime.Decode(decoder, data)
    	// we were able to decode the file successfully
    	if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go

    			wantHealthzChecks:    nil,
    			wantReadyzChecks:     nil,
    			wantLivezChecks:      nil,
    			skipHealth:           true,
    		},
    	}
    
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			serverConfig := server.NewConfig(codecs)
    			etcdOptions := &EtcdOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/roundtrip_test.go

    	storagev1beta1.SchemeBuilder,
    	storagev1.SchemeBuilder,
    	svmv1alpha1.SchemeBuilder,
    }
    
    func TestRoundTripExternalTypes(t *testing.T) {
    	scheme := runtime.NewScheme()
    	codecs := serializer.NewCodecFactory(scheme)
    	for _, builder := range groups {
    		require.NoError(t, builder.AddToScheme(scheme))
    	}
    	seed := rand.Int63()
    	// I'm only using the generic fuzzer funcs, but at some point in time we might need to
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/util_test.go

    	"k8s.io/apiserver/pkg/storage/etcd3"
    	etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing"
    	"k8s.io/apiserver/pkg/storage/value/encrypt/identity"
    )
    
    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: Mon Mar 11 12:07:39 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory_test.go

    	"k8s.io/apiserver/pkg/storage/storagebackend"
    )
    
    var (
    	v1GroupVersion = schema.GroupVersion{Group: "", Version: "v1"}
    
    	scheme = runtime.NewScheme()
    	codecs = serializer.NewCodecFactory(scheme)
    )
    
    func init() {
    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	scheme.AddUnversionedTypes(v1GroupVersion,
    		&metav1.Status{},
    		&metav1.APIVersions{},
    		&metav1.APIGroupList{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 13:35:58 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/webhook/client.go

    			return ClientManager{}, err
    		}
    	}
    	return ClientManager{
    		cache: cache,
    		negotiatedSerializer: serializer.NegotiatedSerializerWrapper(runtime.SerializerInfo{
    			Serializer: serializer.NewCodecFactory(hookScheme).LegacyCodec(gvs...),
    		}),
    	}, nil
    }
    
    // SetAuthenticationInfoResolverWrapper sets the
    // AuthenticationInfoResolverWrapper.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 09:09:10 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/filters/metrics_test.go

    	// This also implies that we can't run this test in parallel with other auth tests.
    	authorizationAttemptsCounter.Reset()
    
    	scheme := runtime.NewScheme()
    	negotiatedSerializer := serializer.NewCodecFactory(scheme).WithoutConversion()
    
    	for _, tt := range testCases {
    		t.Run(tt.desc, func(t *testing.T) {
    			defer authorizationAttemptsCounter.Reset()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 20 13:35:55 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top