Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for newCodecFactory (0.2 sec)

  1. pkg/scheduler/apis/config/scheme/scheme.go

    )
    
    var (
    	// Scheme is the runtime.Scheme to which all kubescheduler api types are registered.
    	Scheme = runtime.NewScheme()
    
    	// Codecs provides access to encoding and decoding for the scheme.
    	Codecs = serializer.NewCodecFactory(Scheme, serializer.EnableStrict)
    )
    
    func init() {
    	AddToScheme(Scheme)
    }
    
    // AddToScheme builds the kubescheduler scheme using all known versions of the kubescheduler api.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 17 05:27:21 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/apis/apiserver/load/load.go

    	api "k8s.io/apiserver/pkg/apis/apiserver"
    	"k8s.io/apiserver/pkg/apis/apiserver/install"
    	externalapi "k8s.io/apiserver/pkg/apis/apiserver/v1alpha1"
    )
    
    var (
    	scheme = runtime.NewScheme()
    	codecs = serializer.NewCodecFactory(scheme, serializer.EnableStrict)
    )
    
    func init() {
    	install.Install(scheme)
    }
    
    func LoadFromFile(file string) (*api.AuthorizationConfiguration, error) {
    	data, err := os.ReadFile(file)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 06:28:47 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/apis/output/scheme/scheme.go

    )
    
    // Scheme is the runtime.Scheme to which all kubeadm api types are registered.
    var Scheme = runtime.NewScheme()
    
    // Codecs provides access to encoding and decoding for the scheme.
    var Codecs = serializer.NewCodecFactory(Scheme)
    
    func init() {
    	metav1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"})
    	AddToScheme(Scheme)
    }
    
    // AddToScheme builds the kubeadm scheme using all known versions of the kubeadm api.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:01:20 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/wrapper.go

    	scheme := runtime.NewScheme()
    	utilruntime.Must(apidiscoveryv2.AddToScheme(scheme))
    	utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme))
    	codecs := serializer.NewCodecFactory(scheme)
    	return &WrappedHandler{codecs, handler, aggHandler}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go

    	"k8s.io/apiserver/pkg/storage/etcd3/testing/testingcert"
    	"k8s.io/apiserver/pkg/storage/etcd3/testserver"
    	"k8s.io/apiserver/pkg/storage/storagebackend"
    )
    
    var scheme = runtime.NewScheme()
    var 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: Fri Jun 07 17:57:37 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go

    	//utilruntime.Must(core.AddToScheme(scheme))
    	utilruntime.Must(corev1.AddToScheme(scheme))
    	utilruntime.Must(scheme.SetVersionPriority(corev1.SchemeGroupVersion))
    	codecs := serializer.NewCodecFactory(scheme)
    	sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion)
    	config := *sc.ForResource(schema.GroupResource{Resource: "endpoints"})
    	baseKey := "/" + uuid.New().String() + "/peer-testleases/"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go

    	storagetesting "k8s.io/apiserver/pkg/storage/testing"
    	"k8s.io/apiserver/pkg/storage/value/encrypt/identity"
    )
    
    var (
    	scheme   = runtime.NewScheme()
    	codecs   = serializer.NewCodecFactory(scheme)
    	errDummy = fmt.Errorf("dummy error")
    )
    
    func init() {
    	metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion)
    	utilruntime.Must(example.AddToScheme(scheme))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 20:43:52 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/generate_test.go

    			whURL:          "",
    			whSVC:          "istiod-revision",
    			whCA:           "ca",
    			userManaged:    true,
    		},
    	}
    	scheme := runtime.NewScheme()
    	codecFactory := serializer.NewCodecFactory(scheme)
    	deserializer := codecFactory.UniversalDeserializer()
    
    	fail := admitv1.Fail
    	fakeClient := kube.NewFakeClient(&admitv1.ValidatingWebhookConfiguration{
    		TypeMeta: metav1.TypeMeta{},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 17:43:49 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top