- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 143 for unmarshalV1 (0.07 seconds)
-
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 Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 5.4K bytes - Click Count (0) -
cmd/site-replication-utils_gen.go
o, err = z.TargetReplicationResyncStatus.MarshalMsg(o) if err != nil { err = msgp.WrapError(err, "TargetReplicationResyncStatus") return } return } // UnmarshalMsg implements msgp.Unmarshaler func (z *SiteResyncStatus) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - 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 Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:18:36 GMT 2025 - 35.9K bytes - Click Count (4) -
internal/event/name.go
func (name Name) MarshalJSON() ([]byte, error) { return json.Marshal(name.String()) } // UnmarshalJSON - decodes JSON data. func (name *Name) UnmarshalJSON(data []byte) error { var s string if err := json.Unmarshal(data, &s); err != nil { return err } eventName, err := ParseName(s) if err != nil { return err } *name = eventName return nil } // ParseName - parses string to Name.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 10.4K bytes - Click Count (0) -
tests/soft_delete_test.go
t.Errorf("Can't find permanently deleted record") } } func TestDeletedAtUnMarshal(t *testing.T) { expected := &gorm.Model{} b, _ := json.Marshal(expected) result := &gorm.Model{} _ = json.Unmarshal(b, result) if result.DeletedAt != expected.DeletedAt { t.Errorf("Failed, result.DeletedAt: %v is not same as expected.DeletedAt: %v", result.DeletedAt, expected.DeletedAt) } } func TestDeletedAtOneOr(t *testing.T) {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 5.7K bytes - Click Count (0) -
cmd/bucket-lifecycle-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } expiryRuleRemoved := false if len(meta.LifecycleConfigXML) > 0 { var lcCfg lifecycle.Lifecycle if err := xml.Unmarshal(meta.LifecycleConfigXML, &lcCfg); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } for _, rl := range lcCfg.Rules { updRule, ok := updatedRules[rl.ID]Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jan 20 14:49:07 GMT 2025 - 7K bytes - Click Count (0) -
cmd/metacache-walk_gen.go
o = msgp.AppendInt(o, z.Limit) // string "DiskID" o = append(o, 0xa6, 0x44, 0x69, 0x73, 0x6b, 0x49, 0x44) o = msgp.AppendString(o, z.DiskID) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *WalkDirOptions) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7K bytes - Click Count (0) -
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 Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K 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 Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.5K bytes - Click Count (1) -
internal/config/dns/etcd_dns.go
if domain && r.Count == 0 { return nil, ErrDomainMissing } } var srvRecords []SrvRecord for _, n := range r.Kvs { var srvRecord SrvRecord if err = json.Unmarshal(n.Value, &srvRecord); err != nil { return nil, err } srvRecord.Key = strings.TrimPrefix(string(n.Key), key) srvRecord.Key = strings.TrimSuffix(srvRecord.Key, srvRecord.Host)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 8K bytes - Click Count (0)