- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 134 for closer (0.04 seconds)
-
cmd/bitrot.go
} return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum) } // Close all the readers. func closeBitrotReaders(rs []io.ReaderAt) { for _, r := range rs { if r != nil { if br, ok := r.(io.Closer); ok { br.Close() } } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) []error { errs := make([]error, len(ws))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.7K bytes - Click Count (0) -
cmd/metrics.go
for _, mf := range mfs { if err := enc.Encode(mf); err != nil { // client may disconnect for any reasons // we do not have to log this. return } } if closer, ok := enc.(expfmt.Closer); ok { closer.Close() } }) } // NoAuthMiddleware no auth middle ware. func NoAuthMiddleware(h http.Handler) http.Handler { return h }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (0) -
cmd/metrics-v2.go
for _, mf := range mfs { if err := enc.Encode(mf); err != nil { // client may disconnect for any reasons // we do not have to log this. return } } if closer, ok := enc.(expfmt.Closer); ok { closer.Close() } }) } func metricsBucketHandler() http.Handler { return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket") }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
architecture/standards/0008-use-nullaway.md
## Status ACCEPTED ## Consequences * Classes are forced to have consistent nullability annotations. * IDE warnings become more accurate, reducing warnings fatigue. * Public API nullability annotations become closer to reality. * Java compilation of Gradle code suffers from small performance penalty (up to 10%). * Time has to be allocated to clean up existing projects. * One has to write NullAway-conformant code even when hacking.
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Dec 11 10:24:40 GMT 2025 - 4K bytes - Click Count (0) -
docs/en/docs/how-to/custom-docs-ui-assets.md
By default, those files are served from a <abbr title="Content Delivery Network: A service, normally composed of several servers, that provides static files, like JavaScript and CSS. It's commonly used to serve those files from the server closer to the client, improving performance.">CDN</abbr>. But it's possible to customize it, you can set a specific CDN, or serve the files yourself. ## Custom CDN for JavaScript and CSS { #custom-cdn-for-javascript-and-css }
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 7.8K bytes - Click Count (0) -
docs/en/docs/alternatives.md
Routes are declared in a single place, using functions declared in other places (instead of using decorators that can be placed right on top of the function that handles the endpoint). This is closer to how Django does it than to how Flask (and Starlette) does it. It separates in the code things that are relatively tightly coupled. /// check | Inspired **FastAPI** to
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 23.6K bytes - Click Count (0) -
cmd/xl-storage.go
} w.Close() return errMoreData } // Only interested in flushing the size_t not mtime/atime if err = Fdatasync(w); err != nil { w.Close() return err } // Dealing with error returns from close() - 'man 2 close' // // A careful programmer will check the return value of close(), since it is quite possible that
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
cmd/erasure-object.go
closeErrs := closeBitrotWriters(writers) if erasureErr != nil { return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key) } if closeErr := reduceWriteQuorumErrs(ctx, closeErrs, objectOpIgnoredErrs, writeQuorum); closeErr != nil { return ObjectInfo{}, toObjectErr(closeErr, minioMetaBucket, key) } // Should return IncompleteBody{} error when reader has fewer bytes // than specified in request header.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
internal/http/listener.go
case <-listener.ctxDoneCh: } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.8K bytes - Click Count (0) -
internal/rest/client.go
return c.CallWithHTTPMethod(ctx, http.MethodPost, rpcMethod, values, body, length) } // Close closes all idle connections of the underlying http client func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, auth func() string) *Client { connected := int32(online)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0)