- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for newCodecFactory (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)