Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 46 of 46 for NewDecoder (0.11 sec)

  1. docs/debugging/xl-meta/main.go

    					}
    				})
    				if err != nil {
    					return nil, err
    				}
    			}
    			if ndjson {
    				return buf.Bytes(), nil
    			}
    			var msi map[string]interface{}
    			dec := json.NewDecoder(buf)
    			// Use number to preserve integers.
    			dec.UseNumber()
    			err = dec.Decode(&msi)
    			if err != nil {
    				return nil, err
    			}
    			b, err = json.MarshalIndent(msi, "", "  ")
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  2. 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)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    		return
    	}
    
    	var rulesMap event.RulesMap
    	if r.ContentLength < 0 {
    		s.writeErrorResponse(w, errInvalidArgument)
    		return
    	}
    
    	err := gob.NewDecoder(r.Body).Decode(&rulesMap)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	globalEventNotifier.AddRulesMap(bucketName, rulesMap)
    }
    
    // HealthHandler - returns true of health
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    			return
    		}
    
    		headerLen += int64(len(name)) + int64(len(fileName))
    		if name != "file" {
    			if http.CanonicalHeaderKey(name) == http.CanonicalHeaderKey("x-minio-fanout-list") {
    				dec := json.NewDecoder(part)
    
    				// while the array contains values
    				for dec.More() {
    					var m minio.PutObjectFanOutEntry
    					if err := dec.Decode(&m); err != nil {
    						part.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. 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")
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  6. api/go1.txt

    pkg encoding/ascii85, func Decode([]uint8, []uint8, bool) (int, int, error)
    pkg encoding/ascii85, func Encode([]uint8, []uint8) int
    pkg encoding/ascii85, func MaxEncodedLen(int) int
    pkg encoding/ascii85, func NewDecoder(io.Reader) io.Reader
    pkg encoding/ascii85, func NewEncoder(io.Writer) io.WriteCloser
    pkg encoding/ascii85, method (CorruptInputError) Error() string
    pkg encoding/ascii85, type CorruptInputError int64
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top