- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 102 for decode (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
cmd/storage-datatypes_test.go
ID: "uuid", Error: "", } var buf bytes.Buffer gob.NewEncoder(&buf).Encode(v) encoded := buf.Bytes() b.Log("Size:", buf.Len(), "bytes") b.SetBytes(1) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { dec := gob.NewDecoder(bytes.NewBuffer(encoded)) err := dec.Decode(&v) if err != nil { b.Fatal(err) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 9.4K bytes - Viewed (0) -
internal/config/cache/remote_gen_test.go
func TestEncodeDecodeCondCheck(t *testing.T) { v := CondCheck{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeCondCheck Msgsize() is inaccurate") } vn := CondCheck{} 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 Nov 22 21:46:17 UTC 2023 - 4.4K bytes - Viewed (0) -
internal/kms/secret-key_test.go
t.Fatalf("Failed to initialize KMS: %v", err) } for i, test := range decryptKeyTests { dataKey, err := base64.StdEncoding.DecodeString(test.Plaintext) if err != nil { t.Fatalf("Test %d: failed to decode plaintext key: %v", i, err) } plaintext, err := KMS.Decrypt(context.TODO(), &DecryptRequest{ Name: test.KeyID, Ciphertext: []byte(test.Ciphertext), AssociatedData: test.Context, })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 2.9K bytes - Viewed (0)