- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 164 for marshal (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)