db

type Client struct {
	Pgx    PgxIface
	Logger *logger.Logger

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

type Config struct {
	Host           string     `mapstructure:"host" json:"host" default:"localhost"`
	Port           int        `mapstructure:"port" json:"port" default:"5432"`
	Database       string     `mapstructure:"database" json:"database" default:"opentdf"`
	User           string     `mapstructure:"user" json:"user" default:"postgres"`
	Password       string     `mapstructure:"password" json:"password" default:"changeme"`
	SSLMode        string     `mapstructure:"sslmode" json:"sslmode" default:"prefer"`
	Schema         string     `mapstructure:"schema" json:"schema" default:"opentdf"`
	ConnectTimeout int        `mapstructure:"connect_timeout_seconds" json:"connect_timeout_seconds" default:"15"`
	Pool           PoolConfig `mapstructure:"pool" json:"pool"`

	RunMigrations    bool      `mapstructure:"runMigrations" json:"runMigrations" default:"true"`
	MigrationsFS     *embed.FS `mapstructure:"-" json:"-"`
	VerifyConnection bool      `mapstructure:"verifyConnection" json:"verifyConnection" default:"true"`
}

type OptsFunc func(c Config) Config

type PgxIface interface {
	Acquire(ctx context.Context) (*pgxpool.Conn, error)
	Begin(ctx context.Context) (pgx.Tx, 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
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type PoolConfig struct {
	// Maximum amount of connections to keep in the pool.
	MaxConns int32 `mapstructure:"max_connection_count" json:"max_connection_count" default:"4"`

	// Minimum amount of connections to keep in the pool.
	MinConns int32 `mapstructure:"min_connection_count" json:"min_connection_count" default:"0"`

	// Minimum amount of idle connections to keep in the pool.
	MinIdleConns int32 `mapstructure:"min_idle_connections_count" json:"min_idle_connections_count" default:"0"`

	// Maximum amount of time a connection may be reused, in seconds. Default: 3600 seconds (1 hour).
	MaxConnLifetime int `mapstructure:"max_connection_lifetime_seconds" json:"max_connection_lifetime_seconds" default:"3600"`

	// Maximum amount of time a connection may be idle before being closed, in seconds. Default: 1800 seconds (30 minutes).
	MaxConnIdleTime int `mapstructure:"max_connection_idle_seconds" json:"max_connection_idle_seconds" default:"1800"`

	// Period at which the pool will check the health of idle connections, in seconds. Default: 60 seconds (1 minute).
	HealthCheckPeriod int `mapstructure:"health_check_period_seconds" json:"health_check_period_seconds" default:"60"`
}

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