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

Function newInputReader

ztest/ztest.go:531–543  ·  view source on GitHub ↗
(sctx *super.Context, input string, flags []string)

Source from the content-addressed store, hash-verified

529}
530
531func newInputReader(sctx *super.Context, input string, flags []string) (sio.ReadCloser, error) {
532 var inflags inputflags.Flags
533 var fs flag.FlagSet
534 inflags.SetFlags(&fs, true)
535 if err := fs.Parse(flags); err != nil {
536 return nil, err
537 }
538 r, err := anyio.GzipReader(strings.NewReader(input))
539 if err != nil {
540 return nil, err
541 }
542 return anyio.NewReader(sctx, r, inflags.ReaderOpts)
543}

Callers 1

runInternalFunction · 0.85

Calls 5

SetFlagsMethod · 0.95
GzipReaderFunction · 0.92
NewReaderFunction · 0.92
ParseMethod · 0.80
NewReaderMethod · 0.45

Tested by

no test coverage detected