Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Unmarshal (0.16 sec)

  1. cmd/format-erasure.go

    	for _, set := range f.Erasure.Sets {
    		drives += len(set)
    	}
    	return drives
    }
    
    func (f *formatErasureV3) Clone() *formatErasureV3 {
    	b, err := json.Marshal(f)
    	if err != nil {
    		panic(err)
    	}
    	var dst formatErasureV3
    	if err = json.Unmarshal(b, &dst); err != nil {
    		panic(err)
    	}
    	return &dst
    }
    
    // Returns formatErasure.Erasure.Version
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. internal/event/name.go

    	return nil
    }
    
    // MarshalJSON - encodes to JSON data.
    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
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    	if len(cmetadata) != 0 {
    		if err := json.Unmarshal(cmetadata, &meta); err != nil {
    			return nil, err
    		}
    		if crypto.S3.IsEncrypted(meta) {
    			if data, err = decryptBucketMetadata(cdata, bucket, meta, kms.Context{
    				bucket:            bucket,
    				bucketTargetsFile: bucketTargetsFile,
    			}); err != nil {
    				return nil, err
    			}
    		}
    	}
    
    	if err = json.Unmarshal(data, &t); err != nil {
    		return nil, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  5. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  6. cni/pkg/plugin/plugin.go

    	conf := Config{}
    
    	if err := json.Unmarshal(stdin, &conf); err != nil {
    		return nil, fmt.Errorf("failed to parse network configuration: %v", err)
    	}
    
    	log.Debugf("istio-cni: Config is: %+v", conf)
    	// Parse previous result. Remove this if your plugin is not chained.
    	if conf.RawPrevResult != nil {
    		resultBytes, err := json.Marshal(conf.RawPrevResult)
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    		return backgroundHealInfo{}
    	}
    	var info backgroundHealInfo
    	if err = json.Unmarshal(buf, &info); err != nil {
    		bugLogIf(ctx, err, backgroundHealInfoPath)
    	}
    	return info
    }
    
    func saveBackgroundHealInfo(ctx context.Context, objAPI ObjectLayer, info backgroundHealInfo) {
    	if globalIsErasureSD {
    		return
    	}
    
    	b, err := json.Marshal(info)
    	if err != nil {
    		bugLogIf(ctx, err)
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  9. istioctl/pkg/waypoint/waypoint.go

    		RunE: func(cmd *cobra.Command, args []string) error {
    			gw, err := makeGateway(false)
    			if err != nil {
    				return fmt.Errorf("failed to create gateway: %v", err)
    			}
    			b, err := yaml.Marshal(gw)
    			if err != nil {
    				return err
    			}
    			// strip junk
    			res := strings.ReplaceAll(string(b), `  creationTimestamp: null
    `, "")
    			res = strings.ReplaceAll(res, `status: {}
    `, "")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top