Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 143 for unmarshalV1 (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top