- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 84 for decode (0.2 sec)
-
internal/s3select/select.go
// writer is set later by Reset() before using it. return bufio.NewWriter(xioutil.Discard) }, } // UnmarshalXML - decodes XML data. func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string if err := d.DecodeElement(&s, &start); err != nil { return errMalformedXML(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0) -
internal/bucket/lifecycle/prefix.go
set bool Unused struct{} // Needed for GOB compatibility } // UnmarshalXML - decodes XML data. func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { var s string if err = d.DecodeElement(&s, &start); err != nil { return err } *p = Prefix{string: s, set: true} return nil } // MarshalXML - decodes XML data. func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 15 14:45:25 UTC 2023 - 1.5K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) // expecting the response status code to be http.StatusOK(200 OK) . c.Assert(response.StatusCode, http.StatusOK) // parse the response body and obtain the new upload ID. decoder := xml.NewDecoder(response.Body) newResponse := &InitiateMultipartUploadResponse{} err = decoder.Decode(newResponse) c.Assert(err, nil) c.Assert(len(newResponse.UploadID) > 0, true)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
cmd/signature-v2.go
// are equal. The signatures are expected to be base64 encoded strings // according to the AWS S3 signature V2 spec. func compareSignatureV2(sig1, sig2 string) bool { // Decode signature string to binary byte-sequence representation is required // as Base64 encoding of a value is not unique: // For example "aGVsbG8=" and "aGVsbG8=\r" will result in the same byte slice.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/perf-tests.go
Transport: globalRemoteTargetTransport, } resp, err := client.Do(req) if err != nil { result.Error = err.Error() return } defer xhttp.DrainBody(resp.Body) err = gob.NewDecoder(resp.Body).Decode(&result) // endpoint have been overwritten result.Endpoint = rp.String() if err != nil { result.Error = err.Error() } return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
internal/kms/config.go
if err != nil { return tls.Certificate{}, fmt.Errorf("Unable to load KES client private key as specified by the shell environment: %v", err) } privateKeyPEM, rest := pem.Decode(bytes.TrimSpace(keyBytes)) if len(rest) != 0 { return tls.Certificate{}, errors.New("Unable to load KES client private key as specified by the shell environment: private key contains additional data") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 14:31:26 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/metacache-server-pool.go
o.Recursive = o.Separator != slashSeparator o.Separator = slashSeparator } else { // Default is recursive, if delimiter is set then list non recursive. o.Recursive = true } // Decode and get the optional list id from the marker. o.parseMarker() if o.BaseDir == "" { o.BaseDir = baseDirFromPrefix(o.Prefix) } o.Transient = o.Transient || isReservedOrInvalidBucket(o.Bucket, false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 01:12:23 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/format-erasure.go
// same. 'volume not found' usually means its a fresh disk. if errors.Is(err, errFileNotFound) || errors.Is(err, errVolumeNotFound) { return nil, errUnformattedDisk } return nil, err } // Try to decode format json into formatConfigV1 struct. format = &formatErasureV3{} if err = json.Unmarshal(data, format); err != nil { return nil, err } if heal {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
cmd/metacache-entries.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
internal/etag/etag.go
var _ Tagger = ETag{} // compiler check // ETag returns the ETag itself. // // By providing this method ETag implements // the Tagger interface. func (e ETag) ETag() ETag { return e } // FromContentMD5 decodes and returns the Content-MD5 // as ETag, if set. If no Content-MD5 header is set // it returns an empty ETag and no error. func FromContentMD5(h http.Header) (ETag, error) { v, ok := h["Content-Md5"] if !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 10 21:09:36 UTC 2024 - 13.3K bytes - Viewed (0)