Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 76 of 76 for newEncoder (0.04 seconds)

  1. internal/s3select/select.go

    	}
    	return s3Select.recordReader.Close()
    }
    
    // NewS3Select - creates new S3Select by given request XML reader.
    func NewS3Select(r io.Reader) (*S3Select, error) {
    	s3Select := &S3Select{}
    	if err := xml.NewDecoder(r).Decode(s3Select); err != nil {
    		return nil, err
    	}
    
    	return s3Select, nil
    }
    
    //////////////////
    // Helpers
    /////////////////
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  2. cmd/bucket-lifecycle.go

    // parseRestoreRequest parses RestoreObjectRequest from xml
    func parseRestoreRequest(reader io.Reader) (*RestoreObjectRequest, error) {
    	req := RestoreObjectRequest{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxRestoreObjectRequestSize)).Decode(&req); err != nil {
    		return nil, err
    	}
    	return &req, nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  3. src/cmd/api/main_test.go

    		if err != nil {
    			log.Fatalf("loading imports: %v\n%s", err, out)
    		}
    
    		var stdPackages []string
    		importMap := make(map[string]map[string]string)
    		importDir := make(map[string]string)
    		dec := json.NewDecoder(bytes.NewReader(out))
    		for {
    			var pkg struct {
    				ImportPath, Dir string
    				ImportMap       map[string]string
    				Standard        bool
    			}
    			err := dec.Decode(&pkg)
    			if err == io.EOF {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 31.4K bytes
    - Click Count (0)
  4. cmd/object-handlers_test.go

    	}
    	apiRouter.ServeHTTP(rec, req)
    	if rec.Code != http.StatusOK {
    		t.Fatalf("%s:  Expected the response status to be `%d`, but instead found `%d`", instanceType, http.StatusOK, rec.Code)
    	}
    	decoder := xml.NewDecoder(rec.Body)
    	multipartResponse := &InitiateMultipartUploadResponse{}
    	err = decoder.Decode(multipartResponse)
    	if err != nil {
    		t.Fatalf("Error decoding the recorded response Body")
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  5. internal/bucket/lifecycle/lifecycle_test.go

    				NoncurrentDays:          2,
    				NewerNoncurrentVersions: 4,
    				set:                     true,
    			},
    		},
    	}
    	for i, tc := range testCases {
    		var got NoncurrentVersionExpiration
    		dec := xml.NewDecoder(strings.NewReader(tc.xml))
    		if err := dec.Decode(&got); err != nil || got != tc.expected {
    			if err != nil {
    				t.Fatalf("%d: Failed to unmarshal xml %v", i+1, err)
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 55.5K bytes
    - Click Count (0)
  6. cmd/test-utils_test.go

    		if err != nil {
    			t.Fatalf("Unexpected err: %#v", err)
    		}
    		rec := httptest.NewRecorder()
    		apiRouter.ServeHTTP(rec, reqI)
    		checkRespErr(rec, http.StatusOK)
    		decoder := xml.NewDecoder(rec.Body)
    		multipartResponse := &InitiateMultipartUploadResponse{}
    		err = decoder.Decode(multipartResponse)
    		if err != nil {
    			t.Fatalf("Error decoding the recorded response Body")
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
Back to Top