- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 191 for Read (0.13 sec)
-
internal/crypto/error.go
) // errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able // to produce enough random data. This is fatal error and should cause a panic.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/bucket-policy-handlers.go
return } // Check if bucket exists. if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Read bucket access policy. config, err := globalPolicySys.Get(bucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } configData, err := json.Marshal(config)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.1K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
for _, disk := range localDisks { expectedDisksName[fmt.Sprintf("%d-%d", disk.index/setSize, disk.index%setSize)] = disk.path format, err := getFormatJSON(disk.path) if err != nil { log.Printf("Unable to read format.json from `%s`, error: %v\n", disk.path, err) continue } foundDiskLoc, err := getDiskLocation(format) if err != nil { log.Printf("Unable to get disk location of `%s`, error: %v\n", disk.path, err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/http/server.go
return srv } // UseIdleTimeout configure idle connection timeout func (srv *Server) UseIdleTimeout(d time.Duration) *Server { srv.IdleTimeout = d return srv } // UseReadHeaderTimeout configure read header timeout func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server { srv.ReadHeaderTimeout = d return srv } // UseHandler configure final handler for this HTTP *Server
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/object-multipart-handlers.go
return } if s3Error := checkRequestAuthType(ctx, r, policy.PutObjectAction, dstBucket, dstObject); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Read escaped copy source path to check for parameters. cpSrcPath := r.Header.Get(xhttp.AmzCopySource) var vid string if u, err := url.Parse(cpSrcPath); err == nil { vid = strings.TrimSpace(u.Query().Get(xhttp.VersionID))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/object_api_suite_test.go
return &testOneByteReadNoEOF{false, data} } // testOneByteReadNoEOF - implements io.Reader which returns 1 byte and nil error, but // returns io.EOF on the next Read(). type testOneByteReadNoEOF struct { eof bool data []byte } func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
"time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. } // Sets read deadline func (c *DeadlineConn) setReadDeadline() { if c.readDeadline > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dst chan [][]string // result of block decode err error // any error encountered will be set here } // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error. for len(r.current) <= r.recordsRead { if r.err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/config/certs.go
certPEMBlock, err := os.ReadFile(certFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the public key: %s", err) } keyPEMBlock, err := os.ReadFile(keyFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the private key: %s", err) } key, rest := pem.Decode(keyPEMBlock) if len(rest) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0)