- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 98 for Read (0.72 sec)
-
docs/debugging/inspect/export.go
// Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, e = msgp.CopyToJSON(buf, bytes.NewReader(v)) if e != nil { return nil, e } data = b case 3: v, b, e := msgp.ReadBytesZC(b) if e != nil { return nil, e } if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil { // Read metadata CRC (added in v2, ignore if not found)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 08 15:58:02 GMT 2022 - 9.1K bytes - Viewed (0) -
cmd/bitrot.go
defer xioutil.ODirectPoolSmall.Put(bufp) for left > 0 { // Read expected hash... h.Reset() n, err := io.ReadFull(r, hashBuf) if err != nil { // Read's failed for object with right size, file is corrupt. return err } // Subtract hash length.. left -= int64(n) if left < shardSize { shardSize = left } read, err := io.CopyBuffer(h, io.LimitReader(r, shardSize), *bufp)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
) (bool, error) { a, err := os.ReadFile(args[0]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[0], err) } b, err := os.ReadFile(args[1]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[1], err) } diff, err := compare.ManifestDiffWithRenameSelectIgnore(string(a), string(b), renameResources, selectResources,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
func (r *PipeReader) CloseWithError(err error) error { err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide // synchronization between read() end with write() end. func WaitPipe() (*PipeReader, *PipeWriter) { r, w := io.Pipe() var wg sync.WaitGroup wg.Add(1) return &PipeReader{ PipeReader: r, wait: wg.Wait, }, &PipeWriter{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
internal/config/identity/ldap/help.go
}, config.HelpKV{ Key: LookupBindDN, Description: `DN for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindDN), Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: LookupBindPassword, Description: `Password for LDAP read-only service account used to perform DN and group lookups` + defaultHelpPostfix(LookupBindPassword),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 23 14:45:27 GMT 2023 - 3.6K bytes - Viewed (0) -
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) -
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)