Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 276 for marshaled (0.7 sec)

  1. pkg/kube/inject/webhook.go

    	}
    
    	return pod, nil
    }
    
    func createPatch(pod *corev1.Pod, original []byte) ([]byte, error) {
    	reinjected, err := json.Marshal(pod)
    	if err != nil {
    		return nil, err
    	}
    	p, err := jsonpatch.CreatePatch(original, reinjected)
    	if err != nil {
    		return nil, err
    	}
    	return json.Marshal(p)
    }
    
    // postProcessPod applies additionally transformations to the pod after merging with the injected template
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers-idp-ldap.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Encode result and send response.
    
    	data, err := json.Marshal(res)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	password := cred.SecretKey
    	econfigData, err := madmin.EncryptData(password, data)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 03 19:58:48 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. pkg/bootstrap/config_test.go

    		if err != nil {
    			t.Fatalf("failed to marshal: %v", err)
    		}
    		// nolint: lll
    		want := `{"id":"test","cluster":"cluster","metadata":{"A":1,"B":{"b":1},"OWNER":"real-owner","PROXY_CONFIG":{"serviceCluster":"cluster"},"UNKNOWN":"new-field"}}`
    		test.JSONEquals(t, want, string(b))
    	}
    
    	node2 := ConvertXDSNodeToNode(out)
    	{
    		got, err := json.Marshal(node2)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. src/internal/coverage/cfile/ts_test.go

    	mfc := coverage.MetaFileCollection{
    		ImportPaths:       []string{"command-line-arguments"},
    		MetaFileFragments: []string{mfile},
    	}
    	jdata, err := json.Marshal(mfc)
    	if err != nil {
    		t.Fatalf("marshal MetaFileCollection: %v", err)
    	}
    	if err := os.WriteFile(metafiles, jdata, 0666); err != nil {
    		t.Fatalf("write failed: %v", err)
    	}
    
    	// Kick off guts of test.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 09:58:07 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. cmd/bucket-encryption-handlers.go

    				writeErrorResponse(ctx, w, toAPIError(ctx, errKMSKeyNotFound), r.URL)
    				return
    			}
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(encConfig)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Store the bucket encryption configuration in the object layer
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. cmd/bucket-notification-handlers.go

    				// never reach a stage where we will have stale
    				// notification configs.
    			}
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(config)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseXML(w, configData)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  7. internal/store/queuestore.go

    	store.entries[key] = time.Now().UnixNano()
    
    	return nil
    }
    
    // write - writes an item to the directory.
    func (store *QueueStore[I]) write(key string, item I) error {
    	// Marshalls the item.
    	eventData, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    
    	path := filepath.Join(store.directory, key+store.fileExt)
    	if err := os.WriteFile(path, eventData, os.FileMode(0o770)); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 25 16:44:20 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. cmd/bucket-replication-handlers.go

    	}
    	// Validate the received bucket replication config
    	if err = replicationConfig.Validate(bucket, sameTarget); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	configData, err := xml.Marshal(replicationConfig)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketReplicationConfig, configData); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  9. pkg/wasm/convert.go

    		status = marshalFailure
    		return nil, fmt.Errorf("failed to marshal new wasm HTTP filter %+v to protobuf Any: %w", wasmHTTPFilterConfig, err)
    	}
    	ec.TypedConfig = wasmTypedConfig
    	wasmLog.Debugf("new extension config resource %+v", ec)
    
    	nec, err := anypb.New(ec)
    	if err != nil {
    		status = marshalFailure
    		return nil, fmt.Errorf("failed to marshal new extension config resource: %w", err)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/scheduling/v1alpha1/generated.pb.go

    }
    
    func (m *PriorityClass) Marshal() (dAtA []byte, err error) {
    	size := m.Size()
    	dAtA = make([]byte, size)
    	n, err := m.MarshalToSizedBuffer(dAtA[:size])
    	if err != nil {
    		return nil, err
    	}
    	return dAtA[:n], nil
    }
    
    func (m *PriorityClass) MarshalTo(dAtA []byte) (int, error) {
    	size := m.Size()
    	return m.MarshalToSizedBuffer(dAtA[:size])
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 18.9K bytes
    - Viewed (0)
Back to top