db

Sep 13, 2022

Changes in this version

type Settings

+ Host string

+ MaxIdleConnections int

+ MaxOpenConnections int

+ Name string

+ Password string

+ Port string

+ User string

Sep 13, 2022

Changes in this version

+ type ConnectOptions struct

+ ConnMaxLifetime time.Duration

+ ConnectTimeout time.Duration

+ DSN string

+ DriverName string

+ MaxIdleConnections int

+ MaxOpenConnections int

+ Retries int

+ RetryDelay time.Duration

+ type DB struct

+ type ReaderWriter struct

+ Reader *DB

+ Writer *DB

+ func NewDbConnection(ctx context.Context, ready *bool, ro ConnectOptions, wo ConnectOptions) *ReaderWriter

+ func (dbs *ReaderWriter) GetReaderConn() *sql.DB

+ func (dbs *ReaderWriter) GetWriterConn() *sql.DB

+ type Settings struct

+ DBHost string

+ DBMaxIdleConnections int

+ DBMaxOpenConnections int

+ DBName string

+ DBPassword string

+ DBPort string

+ DBUser string

+ func (app *Settings) BuildConnectionString(withSearchPath bool) string

+ type Store struct

+ func NewDbConnectionForTest(ctx context.Context, settings *Settings, withSearchPath bool) Store

+ func NewDbConnectionFromSettings(ctx context.Context, settings *Settings, withSearchPath bool) Store

+ func (store *Store) DBS() *ReaderWriter

+ func (store *Store) IsReady() bool

+ func (store *Store) WaitForDB(logger zerolog.Logger)

+ type Tx struct