Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for reserialize (0.26 sec)

  1. istioctl/pkg/tag/generate.go

    	scheme := runtime.NewScheme()
    	codecFactory := serializer.NewCodecFactory(scheme)
    	deserializer := codecFactory.UniversalDeserializer()
    	serializer := json.NewSerializerWithOptions(
    		json.DefaultMetaFactory, nil, nil, json.SerializerOptions{
    			Yaml:   true,
    			Pretty: true,
    			Strict: true,
    		})
    
    	whObject, _, err := deserializer.Decode([]byte(validatingWebhookYAML), nil, &admitv1.ValidatingWebhookConfiguration{})
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Jan 16 17:43:49 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher_test.go

    		types.MergePatchType, labelsPatch, metav1.PatchOptions{})
    	assert.NoError(t, err)
    
    	client.RunAndWait(ctx.Done())
    
    	payload, _ := json.Marshal(valid)
    
    	// serialize our fake plugin event
    	addEvent, err := processAddEvent(payload)
    	assert.Equal(t, err, nil)
    
    	// Push it thru the handler
    	pluginServer.ReconcileCNIAddEvent(ctx, addEvent)
    
    	waitForMockCalls()
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Feb 02 08:18:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/cni-watcher.go

    	var msg CNIPluginAddEvent
    	err := json.Unmarshal(body, &msg)
    	if err != nil {
    		log.Errorf("Failed to unmarshal CNI plugin event: %v", err)
    		return msg, err
    	}
    
    	log.Debugf("Deserialized CNI plugin event: %+v", msg)
    	return msg, nil
    }
    
    func (s *CniPluginServer) ReconcileCNIAddEvent(ctx context.Context, addCmd CNIPluginAddEvent) error {
    	log := log.WithLabels("cni-event", addCmd)
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  4. 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{},
    		ObjectMeta: metav1.ObjectMeta{
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Jan 16 17:43:49 GMT 2024
    - 12.1K bytes
    - Viewed (0)
  5. istioctl/pkg/admin/istiodconfig.go

    	if err != nil {
    		return nil, fmt.Errorf("cannot deserialize response %s", err)
    	}
    	return scopeInfos, nil
    }
    
    func (c *ControlzClient) PutScope(scope *ScopeInfo) error {
    	var jsonScopeInfo bytes.Buffer
    	err := json.NewEncoder(&jsonScopeInfo).Encode(scope)
    	if err != nil {
    		return fmt.Errorf("cannot serialize scope %+v", *scope)
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  6. istioctl/pkg/kubeinject/kubeinject.go

    		return nil, err
    	}
    	defer resp.Body.Close()
    	body, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return nil, err
    	}
    	var obj runtime.Object
    	var ar *kube.AdmissionReview
    	out, _, err := deserializer.Decode(body, nil, obj)
    	if err != nil {
    		return nil, fmt.Errorf("could not decode body: %v", err)
    	}
    	ar, err = kube.AdmissionReviewKubeToAdapter(out)
    	if err != nil {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  7. common-protos/k8s.io/apimachinery/pkg/runtime/generated.proto

      optional bytes raw = 2;
    
      // ContentEncoding is encoding used to encode 'Raw' data.
      // Unspecified means no encoding.
      optional string contentEncoding = 3;
    
      // ContentType  is serialization method used to serialize 'Raw'.
      // Unspecified means ContentTypeJSON.
      optional string contentType = 4;
    Plain Text
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  8. cni/pkg/plugin/plugin.go

    	// Parse previous result. Remove this if your plugin is not chained.
    	if conf.RawPrevResult != nil {
    		resultBytes, err := json.Marshal(conf.RawPrevResult)
    		if err != nil {
    			return nil, fmt.Errorf("could not serialize prevResult: %v", err)
    		}
    		res, err := version.NewResult(conf.CNIVersion, resultBytes)
    		if err != nil {
    			return nil, fmt.Errorf("could not parse prevResult: %v", err)
    		}
    		conf.RawPrevResult = nil
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
Back to top