Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 40 for NewEncoder (0.11 sec)

  1. cmd/admin-handlers-config-kv.go

    	key := vars["key"]
    
    	_, envOnly := r.Form["env"]
    
    	rd, err := GetHelp(subSys, key, envOnly)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	json.NewEncoder(w).Encode(rd)
    }
    
    // SetConfigHandler - PUT /minio/admin/v3/config
    func (a adminAPIHandlers) SetConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    				default:
    					break drain
    				}
    			}
    		}
    	}()
    
    	lastBatchProcess := time.Now()
    
    	buf := bytebufferpool.Get()
    	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
    	defer bytebufferpool.Put(buf)
    
    	isDirQueue := h.config.QueueDir != ""
    
    	// globalBuffer is always created or adjusted
    	// before this method is launched.
    	logChLock.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    			return
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. cmd/utils.go

    	req := struct {
    		Method     string      `json:"method"`
    		RequestURI string      `json:"reqURI"`
    		Header     http.Header `json:"header"`
    	}{r.Method, rawURI, header}
    
    	var buffer bytes.Buffer
    	enc := json.NewEncoder(&buffer)
    	enc.SetEscapeHTML(false)
    	if err := enc.Encode(&req); err != nil {
    		// Upon error just return Go-syntax representation of the value
    		return fmt.Sprintf("%#v", req)
    	}
    
    	// Formatted string.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  5. api/go1.10.txt

    pkg encoding/asn1, func MarshalWithParams(interface{}, string) ([]uint8, error)
    pkg encoding/csv, type ParseError struct, StartLine int
    pkg encoding/hex, func NewDecoder(io.Reader) io.Reader
    pkg encoding/hex, func NewEncoder(io.Writer) io.Writer
    pkg encoding/json, method (*Decoder) DisallowUnknownFields()
    pkg encoding/xml, func NewTokenDecoder(TokenReader) *Decoder
    pkg encoding/xml, type TokenReader interface { Token }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Feb 06 05:00:01 UTC 2018
    - 30.1K bytes
    - Viewed (0)
  6. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  7. 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()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. docs/debugging/xl-meta/main.go

    						}
    					} else if err != nil {
    						fmt.Println("Error:", err)
    					}
    					return nil
    				})
    				if err != nil {
    					return nil, err
    				}
    				enc := json.NewEncoder(buf)
    				if err := enc.Encode(struct {
    					Versions []version
    				}{Versions: versions}); err != nil {
    					return nil, err
    				}
    				data = b
    			default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  9. 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
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. api/go1.txt

    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
    pkg encoding/asn1, func Marshal(interface{}) ([]uint8, error)
    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