MCPcopy Create free account
hub / github.com/brimdata/super / NewScanner

Function NewScanner

api/queryio/client.go:26–37  ·  view source on GitHub ↗
(ctx context.Context, rc io.ReadCloser)

Source from the content-addressed store, hash-verified

24}
25
26func NewScanner(ctx context.Context, rc io.ReadCloser) (vio.Scanner, error) {
27 sctx := super.NewContext()
28 s, err := bsupio.NewReader(sctx, rc).NewScanner(ctx, nil)
29 if err != nil {
30 return nil, err
31 }
32 return &scanner{
33 sctx: sctx,
34 scanner: s,
35 closer: rc,
36 }, nil
37}
38
39func (s *scanner) Progress() vio.Progress {
40 return s.progress

Callers 1

QueryMethod · 0.92

Calls 3

NewContextFunction · 0.92
NewReaderFunction · 0.92
NewScannerMethod · 0.65

Tested by

no test coverage detected