github.com/go-pg/pg/v10/internal/pool.Conn.WithReader (method)
13 uses
github.com/go-pg/pg/v10/internal/pool (current package)
conn.go#L73: func (cn *Conn) WithReader(
github.com/go-pg/pg/v10
base.go#L408: err = cn.WithReader(ctx, db.opt.ReadTimeout, readCopyInResponse)
base.go#L433: err = cn.WithReader(ctx, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L490: err = cn.WithReader(ctx, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L551: if err := cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L570: if err := cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L601: err = cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L622: err = cn.WithReader(c, db.opt.ReadTimeout, readCloseCompleteMsg)
listener.go#L233: err = cn.WithReader(ctx, timeout, func(rd *pool.ReaderContext) error {
messages.go#L89: return cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
messages.go#L151: err = cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
stmt.go#L240: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
stmt.go#L267: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {