- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for Dec (0.11 sec)
-
internal/s3select/simdj/reader_amd64_test.go
type tester interface { Fatal(args ...interface{}) } func loadCompressed(t tester, file string) (js []byte) { dec, err := zstd.NewReader(nil) if err != nil { t.Fatal(err) } defer dec.Close() js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst")) if err != nil { t.Fatal(err) } js, err = dec.DecodeAll(js, nil) if err != nil { t.Fatal(err) } return js } var testCases = []struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/crypto/doc.go
// - SealedKey <- metadata // - KeyEncKey := HMAC-SHA256(ClientKey, IV || 'SSE-C' || 'DAREv2-HMAC-SHA256' || bucket || '/' || object) // - ObjectKey := DAREv2_Dec(KeyEncKey, SealedKey) // - object_data := DAREv2_Dec(ObjectKey, enc_object_data) // Output: object_data // // ## SSE-S3 // // SSE-S3 can use either a master key or a KMS as root-of-trust.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 26 19:52:29 GMT 2022 - 5K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
"github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err } return result, nil } func TestJsonpathEval(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
internal/bucket/lifecycle/delmarker-expiration.go
return de.Days == 0 } // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error { type delMarkerExpiration DelMarkerExpiration var dexp delMarkerExpiration err := dec.DecodeElement(&dexp, &start) if err != nil { return err } if dexp.Days <= 0 { return errInvalidDaysDelMarkerExpiration }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/untar.go
} defer gz.Close() r = gz case formatS2: r = s2.NewReader(bf) case formatZstd: // Limit to 16 MiB per stream. dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20)) if err != nil { return err } defer dec.Close() r = dec case formatBZ2: ctx, cancel := context.WithCancel(ctx) defer cancel() r = pbzip2.NewReader(ctx, bf, pbzip2.DecompressionOptions(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
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) } } } func BenchmarkEncodeDiskInfoMsgp(b *testing.B) { v := DiskInfo{ Total: 1000, Free: 1000,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
internal/config/subnet/config.go
var DefaultKVS = config.KVS{ config.KV{ Key: config.License, // Deprecated Dec 2021 Value: "", }, config.KV{ Key: config.APIKey, Value: "", }, config.KV{ Key: config.Proxy, Value: "", }, } // Config represents the subnet related configuration type Config struct { // The subnet license token - Deprecated Dec 2021 License string `json:"license"` // The subnet api key
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/bucket/replication/destination.go
return e.EncodeToken(xml.EndElement{Name: start.Name}) } // UnmarshalXML - decodes XML data. func (d *Destination) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) { // Make subtype to avoid recursive UnmarshalXML(). type destination Destination dest := destination{} if err := dec.DecodeElement(&dest, &start); err != nil { return err } parsedDest, err := parseDestination(dest.Bucket) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4K bytes - Viewed (2) -
internal/config/subnet/help.go
return config.DefaultHelpPostfix(DefaultKVS, key) } // HelpSubnet - provides help for subnet api key config HelpSubnet = config.HelpKVS{ config.HelpKV{ Key: config.License, // Deprecated Dec 2021 Type: "string", Description: "[DEPRECATED use api_key] Subnet license token for the cluster" + defaultHelpPostfix(config.License), Optional: true, Sensitive: true, }, config.HelpKV{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jul 13 19:24:47 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/storage-rest-client.go
respBody, err := client.call(ctx, storageRESTMethodReadVersion, values, nil, -1) if err != nil { return fi, err } defer xhttp.DrainBody(respBody) dec := msgpNewReader(respBody) defer readMsgpReaderPoolPut(dec) err = fi.DecodeMsg(dec) return fi, err } // ReadXL - reads all contents of xl.meta of a file.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0)