func (m *driver) NewConnection(opts reader.ConnOpts) (reader.Reader, error) {
	conn, err := sql.Open("postgres", opts.DSN)
	if err != nil {
		return nil, err
	}
	conn.SetMaxOpenConns(opts.MaxConns)
	conn.SetMaxIdleConns(opts.MaxIdleConns)
	conn.SetConnMaxLifetime(opts.MaxConnLifetime)
	dumper, err := NewPgDump(opts.DSN)
	if err != nil {
		return nil, err
	}
	return NewStorage(conn, dumper, opts.Timeout), nil
}
NewConnection takes the connection options and returns a new Reader.
package postgres
import (
	"database/sql"
	"strings"
	_ "github.com/lib/pq"  
	"github.com/hellofresh/klepto/pkg/reader"
)
type driver struct{}
func (m *driver) IsSupported(dsn string) bool {
	return strings.HasPrefix(strings.ToLower(dsn), "postgres://")
}