type github.com/go-pg/pg/v10/internal/pool.WriteBuffer
54 uses
github.com/go-pg/pg/v10/internal/pool (current package)
conn.go#L98: ctx context.Context, timeout time.Duration, fn func(wb *WriteBuffer) error,
conn.go#L110: func (cn *Conn) WriteBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) error {
conn.go#L117: wb *WriteBuffer,
write_buffer.go#L17: func GetWriteBuffer() *WriteBuffer {
write_buffer.go#L18: wb := wbPool.Get().(*WriteBuffer)
write_buffer.go#L22: func PutWriteBuffer(wb *WriteBuffer) {
write_buffer.go#L27: type WriteBuffer struct {
write_buffer.go#L34: func NewWriteBuffer() *WriteBuffer {
write_buffer.go#L35: return &WriteBuffer{
write_buffer.go#L40: func (buf *WriteBuffer) Reset() {
write_buffer.go#L44: func (buf *WriteBuffer) StartMessage(c byte) {
write_buffer.go#L54: func (buf *WriteBuffer) FinishMessage() {
write_buffer.go#L59: func (buf *WriteBuffer) Query() []byte {
write_buffer.go#L63: func (buf *WriteBuffer) StartParam() {
write_buffer.go#L68: func (buf *WriteBuffer) FinishParam() {
write_buffer.go#L75: func (buf *WriteBuffer) FinishNullParam() {
write_buffer.go#L80: func (buf *WriteBuffer) Write(b []byte) (int, error) {
write_buffer.go#L85: func (buf *WriteBuffer) WriteInt16(num int16) {
write_buffer.go#L90: func (buf *WriteBuffer) WriteInt32(num int32) {
write_buffer.go#L95: func (buf *WriteBuffer) WriteString(s string) {
write_buffer.go#L100: func (buf *WriteBuffer) WriteBytes(b []byte) {
write_buffer.go#L105: func (buf *WriteBuffer) WriteByte(c byte) error {
write_buffer.go#L110: func (buf *WriteBuffer) ReadFrom(r io.Reader) (int64, error) {
github.com/go-pg/pg/v10
base.go#L401: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L414: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L425: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L483: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L537: return cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L544: c context.Context, cn *pool.Conn, wb *pool.WriteBuffer,
base.go#L563: c context.Context, cn *pool.Conn, model interface{}, wb *pool.WriteBuffer,
base.go#L592: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L613: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
listener.go#L173: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
listener.go#L206: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L81: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L143: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L239: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L258: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L330: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L370: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L446: func writeStartupMsg(buf *pool.WriteBuffer, user, database, appName string) {
messages.go#L461: func writeSSLMsg(buf *pool.WriteBuffer) {
messages.go#L467: func writePasswordMsg(buf *pool.WriteBuffer, password string) {
messages.go#L473: func writeFlushMsg(buf *pool.WriteBuffer) {
messages.go#L478: func writeCancelRequestMsg(buf *pool.WriteBuffer, processID, secretKey int32) {
messages.go#L487: buf *pool.WriteBuffer,
messages.go#L529: func writeSyncMsg(buf *pool.WriteBuffer) {
messages.go#L534: func writeParseDescribeSyncMsg(buf *pool.WriteBuffer, name, q string) {
messages.go#L610: func writeBindExecuteMsg(buf *pool.WriteBuffer, name string, params ...interface{}) error {
messages.go#L639: func writeCloseMsg(buf *pool.WriteBuffer, name string) {
messages.go#L1213: func writeCopyData(buf *pool.WriteBuffer, r io.Reader) error {
messages.go#L1220: func writeCopyDone(buf *pool.WriteBuffer) {
stmt.go#L232: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L259: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {