Function NewScanner

sbuf/scanner.go:39–48

NewScanner returns a Scanner for r that filters records by filterExpr and s. If r implements fmt.Stringer, the scanner reports errors using a prefix of the string returned by its String method.

(ctx context.Context, r sio.Reader, filterExpr Pushdown)

// If r implements fmt.Stringer, the scanner reports errors using a prefix of the
// string returned by its String method.
func NewScanner(ctx context.Context, r sio.Reader, filterExpr Pushdown) (Scanner, error) {
	s, err := newScanner(ctx, r, filterExpr)
	if err != nil {
		return nil, err
	}
	if stringer, ok := r.(fmt.Stringer); ok {
		s = NamedScanner(s, stringer.String())
	}
	return s, nil
}

func newScanner(ctx context.Context, r sio.Reader, filterExpr Pushdown) (Scanner, error) {
	var sa ScannerAble