postgres

type CommandTag struct {
	pgconn.CommandTag
}

type Conn struct {
	// contains filtered or unexported fields
}

type ErrConstraintViolation struct {
	Details string
}

type ErrDataException struct {
	Details string
}

type ErrRelationDoesNotExist struct {
	Details string
}

type ErrSyntaxError struct {
	Details string
}

type Error struct {
	Severity string
	Msg      string
}

type IdentifySystemResult pglogrepl.IdentifySystemResult

type Mapper struct {
	// contains filtered or unexported fields
}

type PGDumpOptions struct {
	// ConnectionString
	ConnectionString string
	// Format (c custom, d directory, t tar, p plain text)
	Format string
	// Schemas to export
	Schemas []string
	// Tables to export
	Tables []string
	// Tables to be excluded from the dump, regex patterns supported
	ExcludeTables []string
	// SchemaOnly if true, only schema will be exported (no data)
	SchemaOnly bool
	// do not dump privileges (grant/revoke)
	NoPrivileges bool
	// Options to pass to pg_dump
	Options []string
}

type PGRestoreOptions struct {
	// ConnectionString
	ConnectionString string
	// SchemaOnly if true, only schema will be restored (no data)
	SchemaOnly bool
	// Clean all the objects that will be restored
	Clean bool
	// Options to pass to pg_restore
	Options []string
}

type Pool struct {
	*pgxpool.Pool
}

type Querier interface {
	Query(ctx context.Context, query string, args ...any) (Rows, error)
	QueryRow(ctx context.Context, query string, args ...any) Row
	Exec(ctx context.Context, query string, args ...any) (CommandTag, error)
	ExecInTx(ctx context.Context, fn func(tx Tx) error) error
	ExecInTxWithOptions(ctx context.Context, fn func(tx Tx) error, txOpts TxOptions) error
	Close(ctx context.Context) error
}

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

type ReplicationConfig struct {
	SlotName        string
	StartPos        uint64
	PluginArguments []string
}

type ReplicationConn struct {
	// contains filtered or unexported fields
}

type ReplicationMessage struct {
	LSN            uint64
	ServerTime     time.Time
	WALData        []byte
	ReplyRequested bool
}

type Row interface {
	pgx.Row
}

type Rows interface {
	pgx.Rows
}

type Tx interface {
	Query(ctx context.Context, query string, args ...any) (Rows, error)
	QueryRow(ctx context.Context, query string, args ...any) Row
	Exec(ctx context.Context, query string, args ...any) (CommandTag, error)
}

type TxAccessMode string

type TxIsolationLevel string

type TxOptions struct {
	IsolationLevel TxIsolationLevel
	AccessMode     TxAccessMode
}

type Txn struct {
	pgx.Tx
}