Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postgres

package

Go to main page

Versions in this module

v0

v0.3.1

Jan 9, 2025

v0.3.0

Dec 12, 2024

Changes in this version

+ var ErrNoRows = errors.New("no rows")

+ func DefaultReplicationSlotName(dbName string) string

type Conn

+ func (c *Conn) ExecInTx(ctx context.Context, fn func(Tx) error) error

+ func (c *Conn) ExecInTxWithOptions(ctx context.Context, fn func(Tx) error, opts TxOptions) error

+ type Mapper struct

+ func NewMapper() *Mapper

+ func (m *Mapper) TypeForOID(oid uint32) string

type Pool

+ func (c *Pool) ExecInTx(ctx context.Context, fn func(Tx) error) error

+ func (c *Pool) ExecInTxWithOptions(ctx context.Context, fn func(Tx) error, opts TxOptions) error

type Querier

+ ExecInTx func(ctx context.Context, fn func(tx Tx) error) error

+ ExecInTxWithOptions func(ctx context.Context, fn func(tx Tx) error, txOpts TxOptions) error

+ type Tx interface

+ Exec func(ctx context.Context, query string, args ...any) (CommandTag, error)

+ Query func(ctx context.Context, query string, args ...any) (Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...any) Row

+ type TxAccessMode string

+ const ReadOnly

+ const ReadWrite

+ type TxIsolationLevel string

+ const ReadCommitted

+ const ReadUncommitted

+ const RepeatableRead

+ const Serializable

+ type TxOptions struct

+ AccessMode TxAccessMode

+ IsolationLevel TxIsolationLevel

+ type Txn struct

+ func (t *Txn) Exec(ctx context.Context, query string, args ...any) (CommandTag, error)

+ func (t *Txn) Query(ctx context.Context, query string, args ...any) (Rows, error)

+ func (t *Txn) QueryRow(ctx context.Context, query string, args ...any) Row

v0.2.0

Sep 3, 2024

v0.1.0

Jul 11, 2024

Changes in this version

+ var ErrConnTimeout = errors.New("connection timeout")

+ var ErrUnsupportedCopyDataMessage = errors.New("unsupported copy data message")

+ type CommandTag struct

+ type Conn struct

+ func NewConn(ctx context.Context, url string) (*Conn, error)

+ func (c *Conn) Close(ctx context.Context) error

+ func (c *Conn) Exec(ctx context.Context, query string, args ...any) (CommandTag, error)

+ func (c *Conn) Query(ctx context.Context, query string, args ...any) (Rows, error)

+ func (c *Conn) QueryRow(ctx context.Context, query string, args ...any) Row

+ type Error struct

+ Msg string

+ Severity string

+ func (e *Error) Error() string

+ type IdentifySystemResult pglogrepl.IdentifySystemResult

+ type Pool struct

+ func NewConnPool(ctx context.Context, url string) (*Pool, error)

+ func (c *Pool) Close(_ context.Context) error

+ func (c *Pool) Exec(ctx context.Context, query string, args ...any) (CommandTag, error)

+ func (c *Pool) Query(ctx context.Context, query string, args ...any) (Rows, error)

+ func (c *Pool) QueryRow(ctx context.Context, query string, args ...any) Row

+ type Querier interface

+ Close func(ctx context.Context) error

+ Exec func(ctx context.Context, query string, args ...any) (CommandTag, error)

+ Query func(ctx context.Context, query string, args ...any) (Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...any) Row

+ type ReplicationConfig struct

+ PluginArguments []string

+ SlotName string

+ StartPos uint64

+ type ReplicationConn struct

+ func NewReplicationConn(ctx context.Context, url string) (*ReplicationConn, error)

+ func (c *ReplicationConn) Close(ctx context.Context) error

+ func (c *ReplicationConn) IdentifySystem(ctx context.Context) (IdentifySystemResult, error)

+ func (c *ReplicationConn) ReceiveMessage(ctx context.Context) (*ReplicationMessage, error)

+ func (c *ReplicationConn) SendStandbyStatusUpdate(ctx context.Context, lsn uint64) error

+ func (c *ReplicationConn) StartReplication(ctx context.Context, cfg ReplicationConfig) error

+ type ReplicationMessage struct

+ LSN uint64

+ ReplyRequested bool

+ ServerTime time.Time

+ WALData []byte

+ type Row interface

+ type Rows interface