- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Wrap (0.17 sec)
-
cmd/object-multipart-handlers.go
if isCompressed { wantEncryption := crypto.Requested(r.Header) || isEncrypted s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption) idxCb = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/grid/types.go
}() enc := json.NewEncoder(buf) err = enc.Encode(j.val) if err != nil { return b, err } return msgp.AppendBytes(b, buf.Bytes()), nil } // UnmarshalMsg will JSON marshal the value and wrap as a msgp byte array. // Nil values are supported. func (j *JSON[T]) UnmarshalMsg(bytes []byte) ([]byte, error) { if bytes, err := msgp.ReadNilBytes(bytes); err == nil { if j.val != nil { j.p.pool.Put(j.val)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/http/server.go
listenErrCallback(srv.Addrs[i], listenErrs[i]) } else { interfaceFound = true } } if !interfaceFound { return nil, errors.New("no available interface found") } // Wrap given handler to do additional // * return 503 (service unavailable) if the server in shutdown. wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // If server is in shutdown.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
func diskHealthReader(ctx context.Context, r io.Reader) io.Reader { // Check if context has a disk health check. tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue) if !ok { // No need to wrap return r } return &diskHealthWrapper{r: r, tracker: tracker} } // diskHealthWriter provides a wrapper that will update disk health on // ctx, on every successful write.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/object-handlers.go
wantEncryption := crypto.Requested(r.Header) s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption) dstOpts.IndexCB = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } else { delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression") delete(srcInfo.UserDefined, ReservedMetadataPrefix+"actual-size") reader = gr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
#!/bin/bash trap 'cleanup $LINENO' ERR # shellcheck disable=SC2120 cleanup() { MINIO_VERSION=dev docker-compose \ -f "buildscripts/upgrade-tests/compose.yml" \ rm -s -f docker volume prune -f } verify_checksum_after_heal() { local sum1 sum1=$(curl -s "$2" | sha256sum) mc admin heal --json -r "$1" >/dev/null # test after healing local sum1_heal sum1_heal=$(curl -s "$2" | sha256sum)
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 11:39:55 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/etag/reader.go
if r.Tagger == nil { return nil } return r.Tagger.ETag() } // Wrap returns an io.Reader that reads from the wrapped // io.Reader and implements the Tagger interaface. // // If content implements Tagger then the returned Reader // returns ETag of the content. Otherwise, it returns // nil as ETag. // // Wrap provides an adapter for io.Reader implementations // that don't implement the Tagger interface.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/iam-store.go
now := UTCNow().Round(time.Millisecond) return PolicyDoc{ Version: 1, Policy: p, CreateDate: now, UpdateDate: now, } } // defaultPolicyDoc - used to wrap a default policy as PolicyDoc. func defaultPolicyDoc(p policy.Policy) PolicyDoc { return PolicyDoc{ Version: 1, Policy: p, } } func (d *PolicyDoc) update(p policy.Policy) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
internal/rest/client_test.go
want: true, }, { name: "net.Error-unmatched", err: errors.New("something"), want: false, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { // Wrap error n := &NetworkError{ Err: tt.err, } //nolint:gocritic if tt.target == nil { var netErrInterface net.Error if errors.As(n, &netErrInterface) != tt.want {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 1.9K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0)