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.2.1

Dec 14, 2022

v0.2.0

Dec 8, 2022

Changes in this version

+ var ErrColumnOutOfRange = errors.New("column out of range")

+ var ErrTypeNotFound = errors.New("can not find discovered type")

+ var ErrUnknownType = errors.New("unknown type")

+ var ErrZeroType = errors.New("postgres type OID can't be zero")

v0.1.1

Jun 21, 2022

v0.1.0

Jun 21, 2022

Changes in this version

+ var ErrChClosed = errors.New("document channel is closed")

+ var ErrTimeout = errors.New("timeout")

+ type Column struct

+ func (col *Column) MarshalJSON() ([]byte, error)

+ func (col *Column) Omit() bool

+ type Database struct

+ Publication string

+ SlotName string

+ StandbyTimeout time.Duration

+ func New(stream *StreamPipe, logger *zap.Logger) *Database

+ func (db *Database) Close(ctx context.Context) error

+ func (db *Database) Commit(ctx context.Context) error

+ func (db *Database) Connect(ctx context.Context) error

+ func (db *Database) CreateReplicationSlot(ctx context.Context)

+ func (db *Database) Discover(ctx context.Context) error

+ func (db *Database) DropReplicationSlot(ctx context.Context)

+ func (db *Database) HandleLogical(ctx context.Context, lsn pglogrepl.LSN, msg pglogrepl.Message) error

+ func (db *Database) PrintSatus()

+ func (db *Database) RegisterSlotLagMetric(ctx context.Context)

+ func (db *Database) Reindex(ctx context.Context) error

+ func (db *Database) StartReplication(ctx context.Context, at pglogrepl.LSN) error

+ func (db *Database) Tx(ctx context.Context) error

+ type DecoderValue interface

+ type Doc interface

+ LSN func() pglogrepl.LSN

+ NDJSON func() [][]byte

+ type Document struct

+ Data []byte

+ Meta []byte

+ func (d Document) NDJSON() [][]byte

+ type ESAction string

+ const ESDelete

+ const ESIndex

+ const ESInsert

+ const ESUpdate

+ type Inline struct

+ type Position pglogrepl.LSN

+ func (d Position) NDJSON() [][]byte

+ func (p Position) LSN() pglogrepl.LSN

+ type Schema struct

+ type StreamPipe struct

+ func NewStreamPipe(ctx context.Context) *StreamPipe

+ func (p *StreamPipe) CommitPosition(pos pglogrepl.LSN)

+ func (p *StreamPipe) Next(ctx context.Context) (Doc, error)

+ func (p *StreamPipe) Position() pglogrepl.LSN

+ type Table struct

+ func (t *Table) Column(name string) (col *Column)

+ func (t *Table) CopyAll(ctx context.Context, conn *pgconn.PgConn) error

+ func (t *Table) EncodeUpdateRowJSON() ([]byte, error)

+ func (t *Table) MarshalJSON() ([]byte, error)

+ func (t *Table) Schema() *Schema

+ func (t *Table) SetRelationID(id uint32)