- Sort Score
- Result 10 results
- Languages All
Results 21 - 29 of 29 for unwrap (0.16 sec)
-
cmd/utils.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K 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) -
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) -
cmd/metrics-v3-types.go
// and the Metrics API handler returns a 500 HTTP status code. This should // normally not happen, and usually indicates a bug. logger.CriticalIf(GlobalContext, errors.Wrap(err, "failed to get metrics")) promMetrics := metricValues.ToPromMetrics(mg.CollectorPath.metricPrefix(), mg.ExtraLabels) for _, metric := range promMetrics { ch <- metric } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
internal/ioutil/read_file.go
// as an error to be reported. // // passes NOATIME flag for reads on Unix systems to avoid atime updates. func ReadFile(name string) ([]byte, error) { // Don't wrap with un-needed buffer. // Don't use os.ReadFile, since it doesn't pass NO_ATIME when present. f, err := OsOpenFile(name, readMode, 0o666) if err != nil { return nil, err } defer f.Close() st, err := f.Stat()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/s3select/json/reader.go
d := jstream.NewDecoder(readCloser, 0).ObjectAsKVS() return &Reader{ args: args, decoder: d, valueCh: d.Stream(), readCloser: readCloser, } } // syncReadCloser will wrap a readcloser and make it safe to call Close while // reads are running. type syncReadCloser struct { rc io.ReadCloser mu sync.Mutex } func (pr *syncReadCloser) Read(p []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/etag/etag_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package etag import ( "context" "io" "net/http" "strings" "testing" ) var _ Tagger = Wrap(nil, nil).(Tagger) // runtime check that wrapReader implements Tagger var parseTests = []struct { String string ETag ETag ShouldFail bool }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 12.6K bytes - Viewed (0) -
cmd/server-main.go
return fmt.Errorf("Unable to initialize sub-systems: %w", err) } } func initConfigSubsystem(ctx context.Context, newObject ObjectLayer) error { // %w is used by all error returns here to make sure // we wrap the underlying error, make sure when you // are modifying this code that you do so, if and when // you want to add extra context to your error. This // ensures top level retry works accordingly.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (2) -
cmd/erasure-sets.go
disk.Close() return nil, nil, fmt.Errorf("Drive: %s is a root drive", disk) } } disk.Close() return nil, nil, fmt.Errorf("Drive: %s returned %w", disk, err) // make sure to '%w' to wrap the error } disk.Close() disk, err = newStorageAPI(endpoint, storageOpts{ cleanUp: true, healthCheck: true, }) if err != nil { return nil, nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5)