Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 127 for unmarshal (0.12 sec)

  1. cmd/data-scanner_test.go

    </LifecycleConfiguration>
    `
    	lc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(lcXML))
    	if err != nil {
    		t.Fatalf("Failed to unmarshal lifecycle config: %v", err)
    	}
    
    	vcfg := versioning.Versioning{
    		Status: "Enabled",
    	}
    	vcfgXML, err := xml.Marshal(vcfg)
    	if err != nil {
    		t.Fatalf("Failed to marshal versioning config: %v", err)
    	}
    
    	bucket := "bucket"
    	now := time.Now()
    	meta := BucketMetadata{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v1.go

    		Algorithm: c.Algorithm.String(),
    		Hash:      hex.EncodeToString(c.Hash),
    	}
    	return json.Marshal(info)
    }
    
    // UnmarshalJSON - custom checksum info unmarshaller
    func (c *ChecksumInfo) UnmarshalJSON(data []byte) error {
    	var info checksumInfoJSON
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(data, &info); err != nil {
    		return err
    	}
    	sum, err := hex.DecodeString(info.Hash)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. cmd/bucket-handlers_test.go

    		}
    		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())
    		}
    		if errorResponse.Resource != testCase.errorResponse.Resource {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 39.8K bytes
    - Viewed (0)
  4. 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)
  5. cmd/admin-handlers-site-replication.go

    		data, err = madmin.DecryptData(encryptionKey, bytes.NewReader(data))
    		if err != nil {
    			return SRError{
    				Cause: err,
    				Code:  ErrSiteReplicationInvalidRequest,
    			}
    		}
    	}
    	return json.Unmarshal(data, v)
    }
    
    // SiteReplicationStatus - GET /minio/admin/v3/site-replication/status
    func (a adminAPIHandlers) SiteReplicationStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  6. cmd/admin-handlers-idp-ldap.go

    	if err != nil {
    		adminLogIf(ctx, err)
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigBadJSON), r.URL)
    		return
    	}
    
    	var par madmin.PolicyAssociationReq
    	err = json.Unmarshal(reqBytes, &par)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	if err := par.IsValid(); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:46:04 UTC 2025
    - 19.2K bytes
    - Viewed (0)
  7. cmd/bucket-metadata-sys.go

    		if e != nil && !errors.Is(e, errConfigNotFound) {
    			return updatedAt, e
    		}
    		var expiryRuleRemoved bool
    		if len(meta.LifecycleConfigXML) > 0 {
    			var lcCfg lifecycle.Lifecycle
    			if err := xml.Unmarshal(meta.LifecycleConfigXML, &lcCfg); err != nil {
    				return updatedAt, err
    			}
    			// find a single expiry rule set the flag
    			for _, rl := range lcCfg.Rules {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  8. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  9. cmd/iam-etcd-store.go

    func getIAMConfig(item any, data []byte, itemPath string) error {
    	data, err := decryptData(data, itemPath)
    	if err != nil {
    		return err
    	}
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	return json.Unmarshal(data, item)
    }
    
    func (ies *IAMEtcdStore) loadIAMConfig(ctx context.Context, item any, path string) error {
    	data, err := readKeyEtcd(ctx, ies.client, path)
    	if err != nil {
    		return err
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  10. cmd/bucket-metadata.go

    		if err != nil {
    			return err
    		}
    	} else {
    		b.policyConfig = nil
    	}
    
    	if len(b.NotificationConfigXML) != 0 {
    		if err = xml.Unmarshal(b.NotificationConfigXML, b.notificationConfig); err != nil {
    			return err
    		}
    	}
    
    	if len(b.LifecycleConfigXML) != 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
Back to top