Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewDecoder (0.23 sec)

  1. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    			writeErrorResponse(ctx, w, apiErr, r.URL)
    			return
    		}
    
    		var b bytes.Buffer
    		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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  3. 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)
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  4. 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")
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
Back to top