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 ErrPermissionDenied struct {
	Details string
}

type ErrPreconditionFailed struct {
	Details string
}

type ErrRelationAlreadyExists struct {
	Details string
}

type ErrRelationDoesNotExist struct {
	Details string
}

type ErrRuleViolation 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 PGDumpAllFn func(context.Context, PGDumpAllOptions) ([]byte, error)

type PGDumpAllOptions struct {
	// ConnectionString
	ConnectionString string
	// RolesOnly if true, only roles will be exported (no schema)
	RolesOnly bool
	// Clean if true, the target database will be cleaned before the dump is restored
	Clean bool
	// NoPasswords if true, no role passwords will be included in the dump
	NoPasswords bool
	// Role specifies the role to be used for the dump
	Role string
	// Do not output commands to set ownership of objects to match the original database
	NoOwner bool
	// Do not dump privileges (grant/revoke)
	NoPrivileges bool
	// Options to pass to pg_dumpall
	Options []string
}

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

type PGDumpOptions struct {
	// ConnectionString
	ConnectionString string
	// Format (c custom, d directory, t tar, p plain text)
	Format string
	// Schemas to export
	Schemas []string
	// Schemas to be excluded from the dump, regex patterns supported
	ExcludeSchemas []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
	// DataOnly if true, only data will be exported (no schema)
	DataOnly bool
	// Do not dump privileges (grant/revoke)
	NoPrivileges bool
	// Do not output commands to set ownership of objects to match the original database
	NoOwner bool
	// Clean all the objects that will be dumped
	Clean bool
	// Create the database
	Create bool
	// Specifies a role name to be used to create the dump
	Role string
	// Options to pass to pg_dump
	Options []string
}

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

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

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
	// Create target database
	Create bool
	// Format (c custom, d directory, t tar, p plain text)
	Format string
	// Options to pass to pg_restore
	Options []string
}

type Pool struct {
	*pgxpool.Pool
}

type PoolOption func(*pgxpool.Config)

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

type Querier interface {
	Query(ctx context.Context, query string, args ...any) (Rows, error)
	QueryRow(ctx context.Context, dest []any, query string, args ...any) error
	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
	CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)
	Ping(ctx context.Context) 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 ReplicationQuerier interface {
	IdentifySystem(ctx context.Context) (IdentifySystemResult, error)
	StartReplication(ctx context.Context, cfg ReplicationConfig) error
	SendStandbyStatusUpdate(ctx context.Context, lsn uint64) error
	ReceiveMessage(ctx context.Context) (*ReplicationMessage, error)
	Close(ctx context.Context) error
}

type Row interface {
	pgx.Row
}

type Rows interface {
	pgx.Rows
}

type SchemaTableMap map[string]map[string]struct{}

type Tx interface {
	Query(ctx context.Context, query string, args ...any) (Rows, error)
	QueryRow(ctx context.Context, dest []any, query string, args ...any) error
	Exec(ctx context.Context, query string, args ...any) (CommandTag, error)
	CopyFrom(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)
}

type TxAccessMode string

type TxIsolationLevel string

type TxOptions struct {
	IsolationLevel TxIsolationLevel
	AccessMode     TxAccessMode
}

type Txn struct {
	pgx.Tx
}