db

type Client struct {
	Pgx PgxIface

	// This is the stdlib connection that is used for transactions
	SqlDB *sql.DB
	// contains filtered or unexported fields
}

type Config struct {
	Host          string `yaml:"host" default:"localhost"`
	Port          int    `yaml:"port" default:"5432"`
	Database      string `yaml:"database" default:"opentdf"`
	User          string `yaml:"user" default:"postgres"`
	Password      string `yaml:"password" default:"changeme"`
	RunMigrations bool   `yaml:"runMigrations" default:"true"`
	SSLMode       string `yaml:"sslmode" default:"prefer"`
	Schema        string `yaml:"schema" default:"opentdf"`

	VerifyConnection bool `yaml:"verifyConnection" default:"true"`
	MigrationsFS     *embed.FS
}

type DBError string

type OptsFunc func(c Config) Config

type PgxIface interface {
	Acquire(ctx context.Context) (*pgxpool.Conn, error)
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
	QueryRow(context.Context, string, ...any) pgx.Row
	Query(context.Context, string, ...any) (pgx.Rows, error)
	Ping(context.Context) error
	Close()
	Config() *pgxpool.Config
}

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