- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 187 for renamer (0.14 sec)
-
internal/s3select/parquet/reader.go
"github.com/minio/minio/internal/s3select/sql" ) // Reader implements reading records from parquet input. type Reader struct { io.Closer r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser. func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) { fr, err := parquetgo.NewFileReader(rsc) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/os-rename_nolinux.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 985 bytes - Viewed (0) -
internal/hash/reader_test.go
} } // Tests hash reader checksum verification. func TestHashReaderVerification(t *testing.T) { testCases := []struct { desc string src io.Reader size int64 actualSize int64 md5hex, sha256hex string err error }{ 0: {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.3K bytes - Viewed (0) -
cmd/tier-journal.go
if fi, err = f.Stat(); err != nil { return err } f.Close() // close before rename() // Skip renaming active journal if empty. if fi.Size() == tierJournalHdrLen { return os.Remove(jd.JournalPath()) } jPath := jd.JournalPath() jroPath := jd.ReadOnlyPath() // Rotate active journal to perform pending deletes. return os.Rename(jPath, jroPath) }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
internal/s3select/select.go
return rsc.offset, errors.New("seek past end of object") } if rsc.reader != nil { _ = rsc.reader.Close() rsc.reader = nil } return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
Klaus Post <******@****.***> 1663610716 +0200
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.5K bytes - Viewed (0) -
cmd/erasure-object.go
// Make sure to return object info to provide extra information. return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object) } return objInfo, wquorum, nil } // Similar to rename but renames data from srcEntry to dstEntry at dataDir func renameData(ctx context.Context, disks []StorageAPI, srcBucket, srcEntry string, metadata []FileInfo, dstBucket, dstEntry string, writeQuorum int) ([]StorageAPI, []byte, string, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/os-instrumented.go
func MkdirAll(dirPath string, mode os.FileMode, baseDir string) (err error) { defer updateOSMetrics(osMetricMkdirAll, dirPath)(err) return osMkdirAll(dirPath, mode, baseDir) } // Rename captures time taken to call os.Rename func Rename(src, dst string) (err error) { defer updateOSMetrics(osMetricRename, src, dst)(err) return RenameSys(src, dst) } // OpenFile captures time taken to call os.OpenFile
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
plSize += len(key) + len(value) + msgp.StringPrefixSize + msgp.ArrayHeaderSize } // Reserialize... x.serialize(plSize, keys, vals) } // rename will rename a key. // Returns whether the key was found. func (x *xlMetaInlineData) rename(oldKey, newKey string) bool { in := x.afterVersion() sz, buf, _ := msgp.ReadMapHeaderBytes(in) keys := make([][]byte, 0, sz) vals := make([][]byte, 0, sz)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/untar.go
// disconnectReader will ensure that no reads can take place on // the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock() defer d.mu.Unlock() if d.r != nil { return d.r.Read(p) } return 0, errors.New("reader closed") } func (d *disconnectReader) Close() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)