- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for readInt (0.17 sec)
-
internal/grid/grid_types_msgp_test.go
} for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Num": z.Num, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Num") return } case "String": z.String, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "String") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 8.1K bytes - Viewed (0) -
cmd/site-replication-utils_gen.go
} for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "v": z.Version, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Version") return } case "ss": err = z.Status.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Status") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 7.2K bytes - Viewed (0) -
internal/bucket/replication/datatypes_gen.go
s = msgp.StringPrefixSize + len(string(z)) return } // DecodeMsg implements msgp.Decodable func (z *Type) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 int zb0001, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err) return } (*z) = Type(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z Type) EncodeMsg(en *msgp.Writer) (err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/storage-rest-common_gen.go
} switch msgp.UnsafeString(field) { case "id": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } case "m": z.ScanMode, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "ScanMode") return } case "c": if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "Cache") return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
} r := NewReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF { t.Fatalf("Reading failed with %s, %s", err, file.Name()) } }) t.Run(file.Name()+"-close", func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) }
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) -
docs/debugging/xattr/main.go
if err := setxattr(path, name, value); err != nil { log.Fatalln(fmt.Errorf("setting attribute %s failed with: %v", name, err)) } } else { if name == "" { log.Fatalln("you must specify an attribute name for reading") } var names []string if name == "." { attrs, err := listxattr(path) if err != nil { log.Fatalln(fmt.Errorf("listing attributes failed with: %v", err)) } names = append(names, attrs...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/bitrot-whole.go
tillOffset int64 // Affects the length of data requested in disk.ReadFile depending on Read()'s offset buf []byte // Holds bit-rot verified data } func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) { if b.buf == nil { b.buf = make([]byte, b.tillOffset-offset) if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 2.7K bytes - Viewed (0) -
docs/sts/assume-role.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", err) } else { defer f.Close() bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 { stsOpts.DurationSeconds = int(expiryDuration.Seconds()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
internal/s3select/parquet/reader.go
parquettypes "github.com/fraugster/parquet-go/parquet" jsonfmt "github.com/minio/minio/internal/s3select/json" "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.
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) -
internal/disk/stat_linux.go
stats, err := readStat(statsFile) if err != nil { return IOStats{}, err } if len(stats) < 11 { return IOStats{}, fmt.Errorf("found invalid format while reading %v", statsFile) } // refer https://www.kernel.org/doc/Documentation/block/stat.txt iostats = IOStats{ ReadIOs: stats[0], ReadMerges: stats[1], ReadSectors: stats[2], ReadTicks: stats[3],
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0)