Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 190 for unmarshal (0.06 sec)

  1. cmd/metacache-set.go

    		v, ok := fi.Metadata[partKey]
    		if !ok {
    			o.debugln("no match in metadata, waiting")
    			return -1, io.ErrUnexpectedEOF
    		}
    		err := json.Unmarshal([]byte(v), &tmp)
    		if !ok {
    			bugLogIf(context.Background(), err)
    			return -1, err
    		}
    		if tmp.First == "" && tmp.Last == "" && tmp.EOS {
    			return 0, errFileNotFound
    		}
    		if tmp.First >= search {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  2. internal/bucket/object/lock/lock_test.go

    			expectErr:   true,
    		},
    	}
    	for _, tt := range tests {
    		d, err := xml.MarshalIndent(&tt.value, "", "\t")
    		if err != nil {
    			t.Fatal(err)
    		}
    		var dr DefaultRetention
    		err = xml.Unmarshal(d, &dr)
    		//nolint:gocritic
    		if tt.expectedErr == nil {
    			if err != nil {
    				t.Fatalf("error: expected = <nil>, got = %v", err)
    			}
    		} else if err == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 18.4K bytes
    - Viewed (0)
  3. cmd/admin-bucket-handlers.go

    		return
    	}
    	tgtBytes, err := json.Marshal(&targets)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrAdminConfigBadJSON, err), r.URL)
    		return
    	}
    	if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketTargetsFile, tgtBytes); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	data, err := json.Marshal(target.Arn)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    	var ver struct {
    		Version int `json:"version"`
    	}
    	err = json.Unmarshal(buf, &ver)
    	if err != nil {
    		return err
    	}
    	if ver.Version != srStateFormatVersion1 {
    		return fmt.Errorf("Unexpected ClusterRepl state version: %d", ver.Version)
    	}
    
    	var sdata srStateData
    	err = json.Unmarshal(buf, &sdata)
    	if err != nil {
    		return err
    	}
    
    	c.Lock()
    	defer c.Unlock()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
  5. cmd/xl-storage.go

    			// This code-path is to preserve the legacy data.
    			xlMetaLegacy := &xlMetaV1Object{}
    			json := jsoniter.ConfigCompatibleWithStandardLibrary
    			if err := json.Unmarshal(dstBuf, xlMetaLegacy); err != nil {
    				storageLogOnceIf(ctx, err, "read-data-unmarshal-"+dstFilePath)
    				// Data appears corrupt. Drop data.
    			} else {
    				xlMetaLegacy.DataDir = legacyDataDir
    				if err = xlMeta.AddLegacy(xlMetaLegacy); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    				Host:           client.String(),
    				Err:            fmt.Sprintf("server is running the latest version: %s", Version),
    				CurrentVersion: Version,
    			})
    		}
    
    		// Marshal API response
    		jsonBytes, err := json.Marshal(updateStatus)
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    
    		writeSuccessResponseJSON(w, jsonBytes)
    		return
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/lifecycle_test.go

    	}
    	var lc1 Lifecycle
    	err = xml.Unmarshal(b, &lc1)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	ruleSet := make(map[string]struct{})
    	for _, rule := range lc.Rules {
    		ruleBytes, err := xml.Marshal(rule)
    		if err != nil {
    			t.Fatal(err)
    		}
    		ruleSet[string(ruleBytes)] = struct{}{}
    	}
    	for _, rule := range lc1.Rules {
    		ruleBytes, err := xml.Marshal(rule)
    		if err != nil {
    			t.Fatal(err)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 55.5K bytes
    - Viewed (0)
  8. cmd/kms-handlers_test.go

    		t.Errorf("want status code %d, got %d", test.wantStatusCode, rec.Code)
    	}
    
    	// Check returned key list is correct
    	if test.wantKeyNames != nil {
    		keys := []madmin.KMSKeyInfo{}
    		err := json.Unmarshal(rec.Body.Bytes(), &keys)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if len(keys) != len(test.wantKeyNames) {
    			t.Fatalf("want %d keys, got %d", len(test.wantKeyNames), len(keys))
    		}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    		if err != nil {
    			t.Fatal(failTestStr(anonTestStr, fmt.Sprintf("Failed parsing response body: <ERROR> %v", err)))
    		}
    
    		actualError := &APIErrorResponse{}
    		if err = xml.Unmarshal(actualContent, actualError); err != nil {
    			t.Fatal(failTestStr(anonTestStr, "error response failed to parse error XML"))
    		}
    
    		if actualError.BucketName != bucketName {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  10. cmd/iam-object-store.go

    	data, _, err := iamOS.loadIAMConfigBytesWithMetadata(ctx, objPath)
    	if err != nil {
    		return err
    	}
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	return json.Unmarshal(data, item)
    }
    
    func (iamOS *IAMObjectStore) deleteIAMConfig(ctx context.Context, path string) error {
    	return deleteConfig(ctx, iamOS.objAPI, path)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
Back to top