- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 135 for loader (0.14 sec)
-
internal/bucket/bandwidth/reader.go
hdr := r.opts.HeaderSize // remaining header bytes var tokens int // number of tokens to request if hdr > 0 { // available tokens go towards header first if hdr < b { // all of header can be accommodated r.opts.HeaderSize = 0 need = int(math.Min(float64(b-hdr), float64(need))) // use remaining tokens towards payload tokens = need + hdr } else { // part of header can be accommodated r.opts.HeaderSize -= b - 1
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
"runtime" "sync" "unicode/utf8" csv "github.com/minio/csvparser" "github.com/minio/minio/internal/s3select/sql" ) // Reader - CSV record reader for S3Select. type Reader struct { args *ReaderArgs readCloser io.ReadCloser // raw input buf *bufio.Reader // input to the splitter columnNames []string // names of columns nameIndexMap map[string]int64 // name to column index
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/dsync/locker.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import "context" // NetLocker is dsync compatible locker interface. type NetLocker interface { // Do read lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
// it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
Klaus Post <******@****.***> 1708383286 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6.7K bytes - Viewed (0) -
internal/config/cache/remote.go
preamble() if !oi.ModTime.IsZero() { w.Header().Set(xhttp.LastModified, oi.ModTime.UTC().Format(http.TimeFormat)) } if oi.ETag != "" { w.Header()[xhttp.ETag] = []string{"\"" + oi.ETag + "\""} } if oi.Expires != "" { w.Header().Set(xhttp.Expires, oi.Expires) } if oi.CacheControl != "" { w.Header().Set(xhttp.CacheControl, oi.CacheControl) } statusCode() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/handler-utils_test.go
}, shouldFail: false, }, // Fail if header key is not in canonicalized form { header: http.Header{ "x-amz-meta-appid": []string{"amz-meta"}, }, metadata: map[string]string{ "x-amz-meta-appid": "amz-meta", }, shouldFail: false, }, // Support multiple values { header: http.Header{ "x-amz-meta-key": []string{"amz-meta1", "amz-meta2"}, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/metacache_test.go
lastHandout: metaCacheTestsetTimestamp, dataVersion: metacacheStreamVersion, }, 2: { id: "case-3-older", bucket: "bucket", root: "folder/prefix", recursive: false, status: scanStateSuccess, fileNotFound: true, error: "", started: metaCacheTestsetTimestamp.Add(-time.Minute), ended: metaCacheTestsetTimestamp,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 08 18:06:45 GMT 2021 - 6.8K bytes - Viewed (0) -
cmd/config.go
} // NewConfigSys - creates new config system object. func NewConfigSys() *ConfigSys { return &ConfigSys{} } // Initialize and load config from remote etcd or local config directory func initConfig(objAPI ObjectLayer) (err error) { bootstrapTraceMsg("load the configuration") defer func() { if err != nil { bootstrapTraceMsg(fmt.Sprintf("loading configuration failed: %v", err)) } }()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
internal/s3select/genmessage.go
buf.Write([]byte{0, 5}) buf.WriteString("event") buf.WriteByte(11) buf.WriteString(":event-type") buf.WriteByte(7) buf.Write([]byte{0, 4}) buf.WriteString("Cont") header := buf.Bytes() headerLength := len(header) payloadLength := 0 totalLength := totalByteLength(headerLength, payloadLength) buf = new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0)