postgres

package

Go to main page

Versions in this module

v0

v0.9.3

Dec 16, 2025

Changes in this version

+ func IsValidReplicationSlotName(name string) error

v0.9.2

Dec 4, 2025

v0.9.1

Nov 25, 2025

Changes in this version

+ type ErrPreconditionFailed struct

+ Details string

+ func (e *ErrPreconditionFailed) Error() string

v0.9.0

Nov 21, 2025

Changes in this version

+ type ErrRuleViolation struct

+ Details string

+ func (e *ErrRuleViolation) Error() string

v0.8.10

Nov 13, 2025

Changes in this version

+ func MapError(err error) error

v0.8.9

Nov 11, 2025

v0.8.8

Nov 6, 2025

Changes in this version

+ type PoolOption func(*pgxpool.Config)

+ func WithMaxConnections(maxConns int32) PoolOption

+ type ReplicationQuerier interface

+ Close func(ctx context.Context) error

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

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

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

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

v0.8.7

Nov 3, 2025

v0.8.6

Oct 29, 2025

v0.8.5

Oct 15, 2025

v0.8.4

Oct 14, 2025

Changes in this version

+ func ParseConfig(pgurl string) (*pgx.ConnConfig, error)

+ type ErrPermissionDenied struct

+ Details string

+ func (e *ErrPermissionDenied) Error() string

type PGRestoreErrors

+ func (e PGRestoreErrors) HasErrors() bool

v0.8.3

Sep 24, 2025

v0.8.2

Sep 17, 2025

Changes in this version

type PGDumpAllOptions

+ NoOwner bool

+ NoPrivileges bool

v0.8.1

Sep 10, 2025

v0.8.0

Sep 5, 2025

Changes in this version

+ const DiscoverAllSchemaTablesQuery

+ const DiscoverAllSchemasQuery

+ func DiscoverAllSchemaTables(ctx context.Context, conn Querier, schema string) ([]string, error)

+ func DiscoverAllSchemas(ctx context.Context, conn Querier) ([]string, error)

type PGDumpAllOptions

+ Clean bool

+ NoPasswords bool

v0.7.9

Aug 25, 2025

Changes in this version

+ func RunPGDumpAll(_ context.Context, opts PGDumpAllOptions) ([]byte, error)

+ type PGDumpAllFn func(context.Context, PGDumpAllOptions) ([]byte, error)

+ type PGDumpAllOptions struct

+ ConnectionString string

+ Options []string

+ Role string

+ RolesOnly bool

+ func (opts *PGDumpAllOptions) ToArgs() []string

v0.7.8

Aug 11, 2025

Changes in this version

+ const PublicSchema

+ var ErrInvalidTableName = errors.New("invalid table name format")

+ type SchemaTableMap map[string]map[string]struct

+ func NewSchemaTableMap(tables []string) (SchemaTableMap, error)

+ func (t SchemaTableMap) Add(table string) error

+ func (t SchemaTableMap) ContainsSchemaTable(schema, table string) bool

+ func (t SchemaTableMap) GetSchemaTables(schema string) map[string]struct{}

v0.7.7

Aug 6, 2025

v0.7.6

Jul 18, 2025

Changes in this version

+ func IsQuotedIdentifier(s string) bool

v0.7.5

Jul 15, 2025

Changes in this version

type QualifiedName

+ func (qn *QualifiedName) String() string

v0.7.4

Jul 14, 2025

v0.7.3

Jul 8, 2025

v0.7.2

Jun 25, 2025

v0.7.1

Jun 20, 2025

v0.7.0

Jun 19, 2025

v0.6.7

Jun 17, 2025

v0.6.6

Jun 13, 2025

v0.6.5

Jun 6, 2025

v0.6.4

Jun 3, 2025

Changes in this version

type PGDumpOptions

+ NoOwner bool

+ Role string

v0.6.3

May 30, 2025

v0.6.2

May 30, 2025

Changes in this version

type PGDumpOptions

+ Create bool

+ DataOnly bool

type PGRestoreOptions

+ Create bool

+ type QualifiedName struct

+ func NewQualifiedName(s string) (*QualifiedName, error)

+ func (qn *QualifiedName) Name() string

+ func (qn *QualifiedName) Schema() string

type Tx

+ CopyFrom func(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)

type Txn

+ func (t *Txn) CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)

v0.6.1

May 28, 2025

v0.6.0

May 28, 2025

Changes in this version

type Conn

+ func (c *Conn) CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)

+ type PGDumpFn func(context.Context, PGDumpOptions) ([]byte, error)

type PGDumpOptions

+ ExcludeSchemas []string

+ type PGRestoreFn func(context.Context, PGRestoreOptions, []byte) (string, error)

type Pool

+ func (c *Pool) CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)

type Querier

+ CopyFrom func(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)

v0.5.0

May 7, 2025

Changes in this version

+ func QuoteIdentifier(s string) string

+ func QuoteQualifiedIdentifier(schema, table string) string

type Conn

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

+ type ErrRelationAlreadyExists struct

+ Details string

+ func (e *ErrRelationAlreadyExists) Error() string

type PGDumpOptions

+ Clean bool

+ type PGRestoreErrors struct

+ func NewPGRestoreErrors(errs ...error) *PGRestoreErrors

+ func (e *PGRestoreErrors) GetIgnoredErrors() []error

+ func (e *PGRestoreErrors) HasCriticalErrors() bool

+ func (e PGRestoreErrors) Error() string

type PGRestoreOptions

+ Format string

type Pool

+ func (c *Pool) Ping(ctx context.Context) error

type Querier

+ Ping func(ctx context.Context) error

v0.4.1

Mar 28, 2025

Changes in this version

+ type ErrDataException struct

+ Details string

+ func (e *ErrDataException) Error() string

type Querier

+ func ConnBuilder(ctx context.Context, url string) (Querier, error)

+ func ConnPoolBuilder(ctx context.Context, url string) (Querier, error)

+ type QuerierBuilder func(context.Context, string) (Querier, error)

v0.4.0

Mar 14, 2025

Changes in this version

+ func RunPGDump(opts PGDumpOptions) ([]byte, error)

+ func RunPGRestore(opts PGRestoreOptions, dump []byte) (string, error)

+ type ErrConstraintViolation struct

+ Details string

+ func (e *ErrConstraintViolation) Error() string

+ type ErrRelationDoesNotExist struct

+ Details string

+ func (e *ErrRelationDoesNotExist) Error() string

+ type ErrSyntaxError struct

+ Details string

+ func (e *ErrSyntaxError) Error() string

+ type PGDumpOptions struct

+ ConnectionString string

+ ExcludeTables []string

+ Format string

+ NoPrivileges bool

+ Options []string

+ SchemaOnly bool

+ Schemas []string

+ Tables []string

+ func (opts *PGDumpOptions) ToArgs() []string

+ type PGRestoreOptions struct

+ Clean bool

+ ConnectionString string

+ Options []string

+ SchemaOnly bool

+ func (opts PGRestoreOptions) ToArgs() []string

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL