- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for desc (0.24 sec)
-
internal/bucket/replication/destination.go
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 { return err } if dest.StorageClass != "" { switch dest.StorageClass {
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/bucket/replication/sourceselectioncriteria.go
} return nil } // UnmarshalXML - decodes XML data. func (s *SourceSelectionCriteria) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) { // Make subtype to avoid recursive UnmarshalXML(). type sourceSelectionCriteria SourceSelectionCriteria ssc := sourceSelectionCriteria{} if err := dec.DecodeElement(&ssc, &start); err != nil { return err } if len(ssc.ReplicaModifications.Status) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.5K 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/identity/openid/jwt.go
return d, err } defer closeRespFn(resp.Body) if resp.StatusCode != http.StatusOK { return d, fmt.Errorf("unexpected error returned by %s : status(%s)", u, resp.Status) } dec := json.NewDecoder(resp.Body) if err = dec.Decode(&d); err != nil { return d, err } return d, nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5) -
internal/bucket/replication/rule.go
} return nil } // UnmarshalXML - decodes XML data. func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) { // Make subtype to avoid recursive UnmarshalXML(). type deleteReplication DeleteReplication drep := deleteReplication{} if err := dec.DecodeElement(&drep, &start); err != nil { return err } if len(drep.Status) == 0 { drep.Status = Disabled }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 23:22:20 GMT 2022 - 8.3K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
restoreHdr string expectedStatus restoreObjStatus expectedErr error }{ { // valid: represents a restored object, 'pending' expiry. restoreHdr: `ongoing-request="false", expiry-date="Fri, 21 Dec 2012 00:00:00 GMT"`, expectedStatus: restoreObjStatus{ ongoing: false, expiry: time.Date(2012, 12, 21, 0, 0, 0, 0, time.UTC), }, expectedErr: nil, }, {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 31 09:57:57 GMT 2022 - 7K bytes - Viewed (0) -
docs/sts/web-identity.go
if err != nil { return d, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return d, fmt.Errorf("unexpected error returned by %s : status(%s)", ustr, resp.Status) } dec := json.NewDecoder(resp.Body) if err = dec.Decode(&d); err != nil { return d, err } return d, nil } func init() { flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
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)