Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for newEncoder (0.1 seconds)

  1. cmd/peer-rest-server.go

    		return
    	}
    
    	ctx := newContext(r, w, "DownloadProfiling")
    	profileData, err := getProfileData()
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	peersLogIf(ctx, gob.NewEncoder(w).Encode(profileData))
    }
    
    func (s *peerRESTServer) LocalStorageInfoHandler(mss *grid.MSS) (*grid.JSON[madmin.StorageInfo], *grid.RemoteErr) {
    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  2. cmd/admin-handlers-users.go

    	for name, p := range policies {
    		_, err = json.Marshal(p)
    		if err != nil {
    			adminLogIf(ctx, err)
    			continue
    		}
    		newPolicies[name] = p
    	}
    	if err = json.NewEncoder(w).Encode(newPolicies); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    // ListCannedPolicies - GET /minio/admin/v3/list-canned-policies
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
  3. cmd/bucket-handlers.go

    					UserAgent:    r.UserAgent() + " " + "MinIO-Fan-Out",
    					Host:         handlers.GetSourceIP(r),
    				})
    			}
    
    			if done {
    				break
    			}
    		}
    
    		enc := json.NewEncoder(w)
    		for i, fanOutResp := range fanOutResp {
    			if err = enc.Encode(&fanOutResp); err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  4. cmd/batch-handlers.go

    				ID:      req.ID,
    				Type:    req.Type(),
    				Started: req.Started,
    				User:    req.User,
    				Elapsed: time.Since(req.Started),
    			})
    		}
    	}
    
    	batchLogIf(ctx, json.NewEncoder(w).Encode(&listResult))
    }
    
    // BatchJobStatus - returns the status of a batch job saved in the disk
    func (a adminAPIHandlers) BatchJobStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  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