Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 250 for marshal (0.08 sec)

  1. internal/s3select/sql/evaluate.go

    	case uint64:
    		if rval <= math.MaxInt64 {
    			return FromInt(int64(rval)), nil
    		}
    		return FromFloat(float64(rval)), nil
    	case bool:
    		return FromBool(rval), nil
    	case jstream.KVS:
    		bs, err := json.Marshal(result)
    		if err != nil {
    			return nil, err
    		}
    		return FromBytes(bs), nil
    	case []interface{}:
    		dst := make([]Value, len(rval))
    		for i := range rval {
    			v, err := jsonToValue(rval[i])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. istioctl/pkg/workload/workload_test.go

    	}
    }
    
    func TestWorkloadEntryToPodPortsMeta(t *testing.T) {
    	cases := []struct {
    		description string
    		ports       map[string]uint32
    		want        string
    	}{
    		{
    			description: "test json marshal",
    			ports: map[string]uint32{
    				"HTTP":  80,
    				"HTTPS": 443,
    			},
    			want: `[{"name":"HTTP","containerPort":80,"protocol":""},{"name":"HTTPS","containerPort":443,"protocol":""}]`,
    		},
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. cmd/metacache-stream.go

    	Last  string `json:"l"`
    	EOS   bool   `json:"eos,omitempty"`
    }
    
    func (b metacacheBlock) headerKV() map[string]string {
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	v, err := json.Marshal(b)
    	if err != nil {
    		bugLogIf(context.Background(), err) // Unlikely
    		return nil
    	}
    	return map[string]string{fmt.Sprintf("%s-metacache-part-%d", ReservedMetadataPrefixLower, b.n): string(v)}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers-config-kv.go

    		return
    	}
    
    	chEntries, err := listServerConfigHistory(ctx, objectAPI, true, count)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	data, err := json.Marshal(chEntries)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	password := cred.SecretKey
    	econfigData, err := madmin.EncryptData(password, data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. cmd/tier.go

    	data := make([]byte, 4, config.Msgsize()+4)
    
    	// Initialize the header.
    	binary.LittleEndian.PutUint16(data[0:2], tierConfigFormat)
    	binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion)
    
    	// Marshal the tier config
    	return config.MarshalMsg(data)
    }
    
    // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. internal/s3select/jstream/decoder.go

    func (kvs KVS) MarshalJSON() ([]byte, error) {
    	b := new(bytes.Buffer)
    	b.Write([]byte("{"))
    	for i, kv := range kvs {
    		b.Write([]byte("\"" + kv.Key + "\"" + ":"))
    		valBuf, err := json.Marshal(kv.Value)
    		if err != nil {
    			return nil, err
    		}
    		b.Write(valBuf)
    		if i < len(kvs)-1 {
    			b.Write([]byte(","))
    		}
    	}
    	b.Write([]byte("}"))
    	return b.Bytes(), nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2.go

    				bts, err = tmp.unmarshalV(1, bts)
    				if err != nil {
    					return msgp.WrapError(err, "Versions", za0001)
    				}
    				end := len(allMeta) - len(bts)
    				// We reference the marshaled data, so we don't have to re-marshal.
    				x.versions[za0001] = xlMetaV2ShallowVersion{
    					header: tmp.header(),
    					meta:   allMeta[start:end],
    				}
    			}
    		default:
    			bts, err = msgp.Skip(bts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  8. cmd/batch-expire.go

    	// immediately one last time before we exit this method.
    	xioutil.SafeClose(saverQuitCh)
    
    	// Notify expire jobs final status to the configured endpoint
    	buf, _ := json.Marshal(ri)
    	if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil {
    		batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err))
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2_test.go

    			t.Fatal(err)
    		}
    		vers = append(vers, xl.versions)
    	}
    	for _, v2 := range vers {
    		for _, ver := range v2 {
    			b, _ := json.Marshal(ver.header)
    			t.Log(string(b))
    			var x xlMetaV2Version
    			_, _ = x.unmarshalV(0, ver.meta)
    			b, _ = json.Marshal(x)
    			t.Log(string(b), x.getSignature())
    		}
    	}
    
    	for i := range vers {
    		t.Run(fmt.Sprintf("non-strict-q%d", i), func(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
Back to top