type github.com/go-pg/pg/v10/internal/pool.ReaderContext
45 uses
github.com/go-pg/pg/v10/internal/pool (current package)
conn.go#L15: rd *ReaderContext
conn.go#L74: ctx context.Context, timeout time.Duration, fn func(rd *ReaderContext) error,
reader.go#L53: type ReaderContext struct {
reader.go#L58: func NewReaderContext() *ReaderContext {
reader.go#L60: return &ReaderContext{
reader.go#L72: func GetReaderContext() *ReaderContext {
reader.go#L73: rd := readerPool.Get().(*ReaderContext)
reader.go#L77: func PutReaderContext(rd *ReaderContext) {
github.com/go-pg/pg/v10
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 {
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 {
messages.go#L170: c context.Context, cn *pool.Conn, rd *pool.ReaderContext, user, password string,
messages.go#L198: rd *pool.ReaderContext,
messages.go#L237: c context.Context, cn *pool.Conn, rd *pool.ReaderContext, password string,
messages.go#L250: c context.Context, cn *pool.Conn, rd *pool.ReaderContext, user, password string,
messages.go#L269: func readAuthOK(rd *pool.ReaderContext) error {
messages.go#L297: c context.Context, cn *pool.Conn, rd *pool.ReaderContext, user, password string,
messages.go#L396: func readAuthSASLFinal(rd *pool.ReaderContext, client *sasl.Negotiator) error {
messages.go#L549: func readParseDescribeSync(rd *pool.ReaderContext) ([]types.ColumnInfo, error) {
messages.go#L646: func readCloseCompleteMsg(rd *pool.ReaderContext) error {
messages.go#L676: func readSimpleQuery(rd *pool.ReaderContext) (*result, error) {
messages.go#L739: func readExtQuery(rd *pool.ReaderContext) (*result, error) {
messages.go#L804: rd *pool.ReaderContext, columnAlloc *pool.ColumnAlloc,
messages.go#L839: rd *pool.ReaderContext,
messages.go#L903: ctx context.Context, rd *pool.ReaderContext, mod interface{},
messages.go#L988: ctx context.Context, rd *pool.ReaderContext, mod interface{}, columns []types.ColumnInfo,
messages.go#L1067: func readCopyInResponse(rd *pool.ReaderContext) error {
messages.go#L1107: func readCopyOutResponse(rd *pool.ReaderContext) error {
messages.go#L1147: func readCopyData(rd *pool.ReaderContext, w io.Writer) (*result, error) {
messages.go#L1225: func readReadyForQuery(rd *pool.ReaderContext) (*result, error) {
messages.go#L1274: func readNotification(rd *pool.ReaderContext) (channel, payload string, err error) {
messages.go#L1332: func logNotice(rd *pool.ReaderContext, msgLen int) error {
messages.go#L1337: func logParameterStatus(rd *pool.ReaderContext, msgLen int) error {
messages.go#L1342: func readInt16(rd *pool.ReaderContext) (int16, error) {
messages.go#L1350: func readInt32(rd *pool.ReaderContext) (int32, error) {
messages.go#L1358: func readString(rd *pool.ReaderContext) (string, error) {
messages.go#L1366: func readError(rd *pool.ReaderContext) (error, error) {
messages.go#L1385: func readMessageType(rd *pool.ReaderContext) (byte, int, 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 {