- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for decode (0.19 sec)
-
cmd/erasure-decode.go
} // If we cannot decode, just return read quorum error. return nil, fmt.Errorf("%w (offline-disks=%d/%d)", errErasureReadQuorum, disksNotFound, len(p.readers)) } // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
return errors.New("cannot combine --data and --combine") } // file / version / file filemap := make(map[string]map[string]string) // versionID -> combineFiles := make(map[string][]string) decode := func(r io.Reader, file string) ([]byte, error) { file = strings.ReplaceAll(file, ":", "_") b, err := io.ReadAll(r) if err != nil { return nil, err } b, _, minor, err := checkXL2V1(b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/auth-handler.go
// secret key, temporary credentials become invalid if // server admin credentials change. This is done to ensure // that clients cannot decode the token using the temp // secret keys and generate an entirely new claim by essentially // hijacking the policies. We need to make sure that this is // based on admin credential such that token cannot be decoded // on the client side and is treated like an opaque value.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K 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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
v := localLockMap{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodelocalLockMap Msgsize() is inaccurate") } vn := localLockMap{} 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) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6.7K bytes - Viewed (0) -
internal/bucket/lifecycle/delmarker-expiration.go
package lifecycle import ( "encoding/xml" "time" ) var errInvalidDaysDelMarkerExpiration = Errorf("Days must be a positive integer with DelMarkerExpiration") // DelMarkerExpiration used to xml encode/decode ILM action by the same name type DelMarkerExpiration struct { XMLName xml.Name `xml:"DelMarkerExpiration"` Days int `xml:"Days,omitempty"` } // Empty returns if a DelMarkerExpiration XML element is empty.
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/kms-handlers.go
manager, ok := GlobalKMS.(kms.KeyManager) if !ok { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } var request importKeyRequest if err := json.NewDecoder(r.Body).Decode(&request); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err := manager.ImportKey(ctx, r.Form.Get("key-id"), []byte(request.Bytes)); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen_test.go
v := DailyAllTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeDailyAllTierStats Msgsize() is inaccurate") } vn := DailyAllTierStats{} 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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/peer-rest-client.go
respBody, err := client.call(peerRESTMethodDownloadProfilingData, nil, nil, -1) if err != nil { return } defer xhttp.DrainBody(respBody) err = gob.NewDecoder(respBody).Decode(&data) return data, err } // GetBucketStats - load bucket statistics func (client *peerRESTClient) GetBucketStats(bucket string) (BucketStats, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/config/identity/openid/jwks.go
errMalformedJWKECKey = errors.New("malformed JWK EC key") ) // DecodePublicKey - decodes JSON Web Key (JWK) as public key func (key *JWKS) DecodePublicKey() (crypto.PublicKey, error) { switch key.Kty { case "RSA": if key.N == "" || key.E == "" { return nil, errMalformedJWKRSAKey } // decode exponent ebuf, err := base64.RawURLEncoding.DecodeString(key.E) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 23:02:35 GMT 2024 - 3.1K bytes - Viewed (0)