- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for Flores (0.35 sec)
-
internal/s3select/simdj/reader.go
return nil, errJSONParsingError(*r.err) } return nil, io.EOF } dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
src/bufio/bufio.go
if b.Available() == 0 { err = b.Flush() } else { err = nil } } return n, err } // buffered input and output // ReadWriter stores pointers to a [Reader] and a [Writer]. // It implements [io.ReadWriter]. type ReadWriter struct { *Reader *Writer } // NewReadWriter allocates a new [ReadWriter] that dispatches to r and w.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
internal/config/config.go
currKVS.Set(delKey, defVal) } else { currKVS.Delete(delKey) } } c[subSys][tgt] = currKVS } else { delete(c[subSys], tgt) } return nil } // Clone - clones a config map entirely. func (c Config) Clone() Config { cp := New() for subSys, tgtKV := range c { cp[subSys] = make(map[string]KVS) for tgt, kv := range tgtKV {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
src/archive/tar/fuzz_test.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Jan 13 18:06:33 GMT 2022 - 2.2K bytes - Viewed (0) -
internal/s3select/sql/aggregation.go
} errInvalidAggregation = errors.New("Invalid aggregation seen") ) type aggVal struct { runningSum *Value runningCount int64 runningMax, runningMin *Value // Stores if at least one record has been seen seen bool } func newAggVal(fn FuncName) *aggVal { switch fn { case aggFnAvg, aggFnSum: return &aggVal{runningSum: FromFloat(0)} case aggFnMin:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/s3select/json/reader.go
} dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.KVS = kvs dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. err := r.readCloser.Close() for range r.valueCh { // Drain values so we don't leak a goroutine.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
dt.logEntry(duration) } // LogFailure logs an action that hit the timeout func (dt *dynamicTimeout) LogFailure() { dt.logEntry(maxDuration) } // logEntry stores a log entry func (dt *dynamicTimeout) logEntry(duration time.Duration) { if duration < 0 { return } entries := int(atomic.AddInt64(&dt.entries, 1)) index := entries - 1 if index < dynamicTimeoutLogSize {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } writeSuccessResponseXML(w, configData) } // PutBucketNotificationHandler - This HTTP handler stores given notification configuration as per // http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html. func (api objectAPIHandlers) PutBucketNotificationHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// to the peer. type WriteOnCloser struct { io.Writer hasWritten bool } func (w *WriteOnCloser) Write(p []byte) (int, error) { w.hasWritten = true return w.Writer.Write(p) } // Close closes the WriteOnCloser. It behaves like io.Closer. func (w *WriteOnCloser) Close() error { if !w.hasWritten { _, err := w.Write(nil) if err != nil { return err } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
internal/http/check_port_others.go
package http import ( "context" "net" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{}
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K bytes - Viewed (0)