Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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 module

Go to main page

Versions in this module

v3

v3.0.6

Jun 20, 2026

v3.0.5

Jun 13, 2026

Changes in this version

+ const ALL_ROOMS

+ const BROADCAST

+ const BROADCAST_ACK

+ const BROADCAST_CLIENT_COUNT

+ const REMOTE_DISCONNECT

+ const REMOTE_FETCH

+ const REMOTE_JOIN

+ const REMOTE_LEAVE

+ const SERVER_SIDE_EMIT

+ const SOCKETS

+ const VERSION

+ var ErrNilPostgresPacket = errors.New("cannot unmarshal into nil PostgresPacket")

+ type NotificationMessage struct

+ AttachmentId string

+ Type adapter.MessageType

+ Uid adapter.ServerId

+ type Parser interface

+ Decode func([]byte, any) error

+ Encode func(any) ([]byte, error)

+ type PostgresClient struct

+ Context context.Context

+ Pool *pgxpool.Pool

+ func NewPostgresClient(ctx context.Context, pool *pgxpool.Pool) *PostgresClient

+ func (c *PostgresClient) CleanupAttachments(ctx context.Context, tableName string, cleanupIntervalMs int64) error

+ func (c *PostgresClient) Close()

+ func (c *PostgresClient) EnsureTable(ctx context.Context, tableName string) error

+ func (c *PostgresClient) GetAttachment(ctx context.Context, tableName string, id int64) ([]byte, error)

+ func (c *PostgresClient) InsertAttachment(ctx context.Context, tableName string, payload []byte) (int64, error)

+ func (c *PostgresClient) Listen(ctx context.Context, channels ...string) error

+ func (c *PostgresClient) Notify(ctx context.Context, channel, payload string) error

+ func (c *PostgresClient) Unlisten(ctx context.Context, channels ...string) error

+ func (c *PostgresClient) WaitForNotification(ctx context.Context) (*pgconn.Notification, error)

v3.0.5-beta.1

Jun 13, 2026