database

package module

v0.0.0-...-16b7803 Latest Latest Go to latest Published: Feb 18, 2025 License: MIT Imports: 19 Imported by: 3

Details

The database module provides access to Pippin's database schema as well as a redis client.

ent is uses as an ORM, supporting postgres, mysql, and sqlite3 databases.

This section is empty.

View Source

var ErrLockNotObtained = errors.New("couldn't obtain lock")

View Source

var LockRetryStrategy = redislock.Options{
	RetryStrategy: redislock.LimitRetry(redislock.LinearBackoff(2*time.Second), 3),
}

Retry every 100ms, for up-to 3x

func GetRedisDB() *redisManager

func NewEntClient(connInfo SqlDBConn) (*ent.Client, error)

type MysqlConn struct {
	Host     string
	Port     string
	Password string
	User     string
	DBName   string
}

func (c *MysqlConn) DSN() string

func (c *MysqlConn) Dialect() string

func (c *MysqlConn) Driver() string

type PostgresConn struct {
	Host     string
	Port     string
	Password string
	User     string
	DBName   string
}

func (c *PostgresConn) DSN() string

func (c *PostgresConn) Dialect() string

func (c *PostgresConn) Driver() string

type SqlDBConn interface {
	DSN() string
	Dialect() string
	Driver() string
}

func GetSqlDbConn(mock bool) (SqlDBConn, error)

Gets the DB connection information based on environment variables

type SqliteConn struct {
	FileName string
	Mode     string
}

func (c *SqliteConn) DSN() string

func (c *SqliteConn) Dialect() string

func (c *SqliteConn) Driver() string