postgres

type CommandTag struct {
	pgconn.CommandTag
}

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

type Error struct {
	Severity string
	Msg      string
}

type IdentifySystemResult pglogrepl.IdentifySystemResult

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

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 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
}