Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 112 for decode (0.11 sec)

  1. cmd/bucket-stats_gen_test.go

    	v := BucketReplicationStat{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBucketReplicationStat Msgsize() is inaccurate")
    	}
    
    	vn := BucketReplicationStat{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  2. cmd/last-minute_gen_test.go

    func TestEncodeDecodeAccElem(t *testing.T) {
    	v := AccElem{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeAccElem Msgsize() is inaccurate")
    	}
    
    	vn := AccElem{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 6.8K bytes
    - Viewed (0)
  3. cmd/batch-expire_gen_test.go

    	v := BatchJobExpire{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBatchJobExpire Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobExpire{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  4. docs/debugging/healing-bin/main.go

    						return err
    					}
    
    					dec := json.NewDecoder(buf)
    					// Use number to preserve integers.
    					dec.UseNumber()
    					var htr map[string]interface{}
    					if err = dec.Decode(&htr); err != nil {
    						return err
    					}
    					ht[file.Name] = htr
    				}
    			}
    			b, err := json.MarshalIndent(ht, "", "  ")
    			if err != nil {
    				return err
    			}
    			fmt.Println(string(b))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server_gen_test.go

    	v := ServerSystemConfig{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeServerSystemConfig Msgsize() is inaccurate")
    	}
    
    	vn := ServerSystemConfig{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jan 24 21:36:44 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. internal/config/policy/plugin/config.go

    		Result bool `json:"result"`
    	}
    
    	respBody := bytes.NewReader(opaRespBytes)
    
    	var result opaResult
    	if err = json.NewDecoder(respBody).Decode(&result); err != nil {
    		respBody.Seek(0, 0)
    		var resultAllow opaResultAllow
    		if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil {
    			return false, err
    		}
    		return resultAllow.Result.Allow, nil
    	}
    
    	return result.Result, nil
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. internal/bucket/object/lock/lock.go

    	return !l.Status.Valid()
    }
    
    // ParseObjectLegalHold decodes the XML into ObjectLegalHold
    func ParseObjectLegalHold(reader io.Reader) (hold *ObjectLegalHold, err error) {
    	buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize))
    	if err != nil {
    		return nil, err
    	}
    
    	hold = &ObjectLegalHold{}
    	if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil {
    		return nil, err
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  8. cmd/bitrot.go

    		if !algorithm.Available() {
    			continue
    		}
    
    		checksum, err := hex.DecodeString(checksums[algorithm])
    		if err != nil {
    			logger.Fatal(errSelfTestFailure, fmt.Sprintf("bitrot: failed to decode %v checksum %s for selftest: %v", algorithm, checksums[algorithm], err))
    		}
    		var (
    			hash = algorithm.New()
    			msg  = make([]byte, 0, hash.Size()*hash.BlockSize())
    			sum  = make([]byte, 0, hash.Size())
    		)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. internal/crypto/key_test.go

    }
    
    func TestDerivePartKey(t *testing.T) {
    	var key ObjectKey
    	for i, test := range derivePartKeyTest {
    		expectedPartKey, err := hex.DecodeString(test.PartKey)
    		if err != nil {
    			t.Fatalf("Test %d failed to decode expected part-key: %v", i, err)
    		}
    		partKey := key.DerivePartKey(test.PartID)
    		if !bytes.Equal(partKey[:], expectedPartKey) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 02 00:13:57 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  10. internal/bucket/replication/replication.go

    // ParseConfig parses ReplicationConfiguration from xml
    func ParseConfig(reader io.Reader) (*Config, error) {
    	config := Config{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxReplicationConfigSize)).Decode(&config); err != nil {
    		return nil, err
    	}
    	// By default, set replica modification to enabled if unset.
    	for i := range config.Rules {
    		if len(config.Rules[i].SourceSelectionCriteria.ReplicaModifications.Status) == 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top