Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 97 for unmarshalV (0.04 sec)

  1. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. 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]
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jan 20 14:49:07 UTC 2025
    - 7K bytes
    - Viewed (0)
  4. 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) {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server_gen.go

    	}
    	// string "Checksum"
    	o = append(o, 0xa8, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x73, 0x75, 0x6d)
    	o = msgp.AppendString(o, z.Checksum)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *ServerSystemConfig) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 21 14:49:49 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. cmd/batch-handlers_gen.go

    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0003 := range z {
    		o = msgp.AppendString(o, z[zb0003])
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobPrefix) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0002 uint32
    	zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. cmd/mrf_gen.go

    	// string "BitrotScan"
    	o = append(o, 0xaa, 0x42, 0x69, 0x74, 0x72, 0x6f, 0x74, 0x53, 0x63, 0x61, 0x6e)
    	o = msgp.AppendBool(o, z.BitrotScan)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *PartialOperation) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle-handlers_test.go

    			t.Errorf("Test %d: %s: Expected the response to be `%s`, but instead found `%s`", i+1, instanceType, string(testCase.lifecycleResponse), rec.Body.String())
    		}
    		errorResponse := APIErrorResponse{}
    		err = xml.Unmarshal(rec.Body.Bytes(), &errorResponse)
    		if err != nil && !testCase.shouldPass {
    			t.Fatalf("Test %d: %s: Unable to marshal response body %s", i+1, instanceType, rec.Body.String())
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
Back to top