Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 164 for marshal (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/data-usage-cache_gen.go

    			return
    		}
    		err = en.WriteInt(za0002.NumObjects)
    		if err != nil {
    			err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")
    			return
    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *allTierStats) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 1
    	// string "ts"
    	o = append(o, 0x81, 0xa2, 0x74, 0x73)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 85.5K bytes
    - Click Count (0)
  2. docs/debugging/reorder-disks/main.go

    }
    
    func getFormatJSON(path string) (format, error) {
    	formatJSON, err := os.ReadFile(filepath.Join(path, ".minio.sys/format.json"))
    	if err != nil {
    		return format{}, err
    	}
    	var f format
    	err = json.Unmarshal(formatJSON, &f)
    	if err != nil {
    		return format{}, err
    	}
    
    	return f, nil
    }
    
    func getDiskLocation(f format) (string, error) {
    	for i, set := range f.XL.Sets {
    		for j, disk := range set {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  3. cmd/site-replication-utils_gen.go

    	}
    	err = z.TargetReplicationResyncStatus.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "TargetReplicationResyncStatus")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *SiteResyncStatus) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 6
    	// string "v"
    	o = append(o, 0x86, 0xa1, 0x76)
    	o = msgp.AppendInt(o, z.Version)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  4. cmd/server-main.go

    	cfReader := bytes.NewReader(rd)
    
    	cv := config.ServerConfigVersion{}
    	if err = yaml.Unmarshal(rd, &cv); err != nil {
    		return err
    	}
    
    	switch cv.Version {
    	case "v1", "v2":
    	default:
    		return fmt.Errorf("unexpected version: %s", cv.Version)
    	}
    
    	cfCommon := config.ServerConfigCommon{}
    	if err = yaml.Unmarshal(rd, &cfCommon); err != nil {
    		return err
    	}
    
    	configCommonToSrvCtx(cfCommon, ctxt)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  5. cmd/utils_test.go

    	type jsonResult struct {
    		Method     string      `json:"method"`
    		RequestURI string      `json:"reqURI"`
    		Header     http.Header `json:"header"`
    	}
    	res := jsonResult{}
    	if err = json.Unmarshal([]byte(strings.ReplaceAll(jsonReq, "%%", "%")), &res); err != nil {
    		t.Fatal(err)
    	}
    
    	// Look for expected method.
    	if res.Method != http.MethodGet {
    		t.Fatalf("Unexpected method %s, expected 'GET'", res.Method)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  6. cmd/mrf_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteBool(z.BitrotScan)
    	if err != nil {
    		err = msgp.WrapError(err, "BitrotScan")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *PartialOperation) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 8
    	// string "Bucket"
    	o = append(o, 0x88, 0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  7. cmd/metacache-walk_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.DiskID)
    	if err != nil {
    		err = msgp.WrapError(err, "DiskID")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *WalkDirOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 8
    	// string "Bucket"
    	o = append(o, 0x88, 0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7K bytes
    - Click Count (0)
  8. internal/config/api/api.go

    func (sCfg *Config) UnmarshalJSON(data []byte) error {
    	type Alias Config
    	aux := &struct {
    		*Alias
    	}{
    		Alias: (*Alias)(sCfg),
    	}
    	return json.Unmarshal(data, &aux)
    }
    
    // LookupConfig - lookup api config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	deprecatedKeys := []string{
    		apiReadyDeadline,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.5K bytes
    - Click Count (1)
  9. docs/es/docs/advanced/behind-a-proxy.md

    Estos proxies podrían manejar certificados HTTPS y otras cosas.
    
    ## Headers reenviados por el Proxy { #proxy-forwarded-headers }
    
    Un **proxy** delante de tu aplicación normalmente establecería algunos headers sobre la marcha antes de enviar los requests a tu **server** para que el servidor sepa que el request fue **reenviado** por el proxy, informándole la URL original (pública), incluyendo el dominio, que está usando HTTPS, etc.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  10. cmd/admin-handlers_test.go

    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to receive %d status code but received %d. Body (%s)",
    			http.StatusOK, rec.Code, string(resp))
    	}
    
    	result := &serviceResult{}
    	if err := json.Unmarshal(resp, result); err != nil {
    		t.Error(err)
    	}
    	_ = result
    
    	// Wait until testServiceSignalReceiver() called in a goroutine quits.
    	wg.Wait()
    }
    
    // Test for service restart management REST API.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
Back to Top