- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 244 for Read (3.44 sec)
-
internal/grid/stream.go
"context" "errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator_test.go
func TestComparatorMismatchedConfigs(t *testing.T) { cfg, err := os.ReadFile("testdata/configdump.json") if err != nil { t.Fatalf("Failed to read test data: %v", err) } diffCfg, err := os.ReadFile("testdata/configdump_diff.json") if err != nil { t.Fatalf("Failed to read test data: %v", err) } var outputBuffer bytes.Buffer comparator, err := NewComparator(&outputBuffer, map[string][]byte{"default": cfg}, diffCfg)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
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) -
cni/test/install_cni.go
func checkResult(result, expected string) error { resultFile, err := os.ReadFile(result) if err != nil { return fmt.Errorf("couldn't read result: %v", err) } expectedFile, err := os.ReadFile(expected) if err != nil { return fmt.Errorf("couldn't read expected: %v", err) } if !bytes.Equal(resultFile, expectedFile) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/storage-datatypes.go
} return fi } // ReadMultipleReq contains information of multiple files to read from disk. type ReadMultipleReq struct { Bucket string // Bucket. Can be empty if multiple buckets. Prefix string // Shared prefix of all files. Can be empty. Will be joined to filename without modification. Files []string // Individual files to read. MaxSize int64 // Return error if size is exceed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/encryption-v1_test.go
t.Fatalf("Impossible read specified: %d %d %d", skipLen, readLen, oSize) } var cumulativeSum, cumulativeEncSum int64 toRead := readLen readStart := false for i, v := range s { partOffset := int64(0) partDarePkgOffset := int64(0) if !readStart && cumulativeSum+v > skipLen { // Read starts at the current part readStart = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
cmd/erasure-utils.go
if offset >= int64(len(block)) { // Decrement offset. offset -= int64(len(block)) continue } // Skip until offset. block = block[offset:] // Reset the offset for next iteration to read everything // from subsequent blocks. offset = 0 // We have written all the blocks, write the last remaining block. if write < int64(len(block)) { n, err := dst.Write(block[:write]) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
t.Run(tc.str, func(t *testing.T) { jp := JSONPath{} err := p.ParseString(tc.str, &jp) // fmt.Println(jp) if err != nil { t.Fatalf("parse failed!: %d %v %s", i, err, tc) } // Read only the first json object from the file recs, err := getJSONStructs(b) if err != nil || len(recs) != 3 { t.Fatalf("%v or length was not 3", err) } for j, rec := range recs { // fmt.Println(rec)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
cmd/encryption-v1.go
} d.decrypter = decrypter return nil } func (d *DecryptBlocksReader) Read(p []byte) (int, error) { var err error var n1 int decPartSize, _ := sio.DecryptedSize(uint64(d.parts[d.partIndex].Size)) unreadPartLen := int64(decPartSize) - d.partDecRelOffset if int64(len(p)) < unreadPartLen { n1, err = d.decrypter.Read(p) if err != nil { return 0, err } d.partDecRelOffset += int64(n1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
internal/lock/lock_windows.go
} var access uint32 switch flag { case syscall.O_RDONLY: access = syscall.GENERIC_READ case syscall.O_WRONLY: access = syscall.GENERIC_WRITE case syscall.O_RDWR: fallthrough case syscall.O_RDWR | syscall.O_CREAT: fallthrough case syscall.O_WRONLY | syscall.O_CREAT: access = syscall.GENERIC_READ | syscall.GENERIC_WRITE case syscall.O_WRONLY | syscall.O_CREAT | syscall.O_APPEND:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0)