postrgres

Documentation

Index

• Variables
• func NewGoQuConnector(poolDB map[string]*sqlx.DB, logger *zap.Logger, cfg *config.Config) map[string]connectors.DBConnector[*goqu.Database, *goqu.TxDatabase]
• func NewPGXPool(ctx context.Context, config PostgresConfig) (map[string]*pgxpool.Pool, error)
• func NewPGXPoolConn(ctx context.Context, pgxPool map[string]*pgxpool.Pool, logger *zap.Logger, ...) (map[string]connectors.DBConnector[dbtypes.PgxConn, dbtypes.PgxTx], error)
• func NewPostgres(config PostgresConfig) (map[string]*sqlx.DB, error)
• func NewSQLConnector(poolDB map[string]*sqlx.DB, logger *zap.Logger, cfg *config.Config) map[string]connectors.DBConnector[*sqlx.DB, *sqlx.Tx]
• type DBConfig
• type GoQuConn
  • func (s *GoQuConn) CallContext(ctx context.Context, queryName string, ...) error
  • func (s *GoQuConn) CallTransaction(ctx context.Context, txName string, ...) error
• type PGXPoolConn
  • func (c *PGXPoolConn) CallContext(ctx context.Context, queryName string, ...) error
  • func (c *PGXPoolConn) CallTransaction(ctx context.Context, txName string, ...) error
  • func (c *PGXPoolConn) Get(ctx context.Context, dst any, query string, args ...any) error
  • func (c *PGXPoolConn) Select(ctx context.Context, dst any, query string, args ...any) error
  • func (c *PGXPoolConn) Stats() sql.DBStats
• type PostgresConfig
  • func NewPostgresConfig(cfg *config.Config) PostgresConfig
• type SQLConn
  • func (s *SQLConn) CallContext(ctx context.Context, queryName string, ...) error
  • func (s *SQLConn) CallTransaction(ctx context.Context, txName string, ...) error

Variables

var Module = types.Module{
	{CreateFunc: NewPostgresConfig},
	{CreateFunc: NewPostgres},
	{CreateFunc: NewSQLConnector},
	{CreateFunc: NewGoQuConnector},
	{CreateFunc: NewPGXPoolConn},
	{CreateFunc: NewPGXPool},
}

Functions

func NewGoQuConnector

func NewGoQuConnector(
	poolDB map[string]*sqlx.DB,
	logger *zap.Logger,
	cfg *config.Config,
) map[string]connectors.DBConnector[*goqu.Database, *goqu.TxDatabase]

func NewPGXPool

func NewPGXPool(
	ctx context.Context,
	config PostgresConfig,
) (map[string]*pgxpool.Pool, error)

func NewPGXPoolConn

func NewPGXPoolConn(
	ctx context.Context,
	pgxPool map[string]*pgxpool.Pool,
	logger *zap.Logger,
	cfg *config.Config,
) (map[string]connectors.DBConnector[dbtypes.PgxConn, dbtypes.PgxTx], error)

func NewPostgres

func NewPostgres(config PostgresConfig) (map[string]*sqlx.DB, error)

func NewSQLConnector

func NewSQLConnector(
	poolDB map[string]*sqlx.DB,
	logger *zap.Logger,
	cfg *config.Config,
) map[string]connectors.DBConnector[*sqlx.DB, *sqlx.Tx]

Types

type DBConfig

type DBConfig struct {
	DSN  string
	Name string
	// Type pgx|sqlx
	Type               string
	MaxOpenConnections int
	MaxIdleConnections int
	ConnMaxLifetime    time.Duration
}

type GoQuConn

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

func (*GoQuConn) CallContext

func (s *GoQuConn) CallContext(
	ctx context.Context,
	queryName string,
	callFunc func(ctx context.Context, gq *goqu.Database) error,
) error

func (*GoQuConn) CallTransaction

func (s *GoQuConn) CallTransaction(
	ctx context.Context,
	txName string,
	callFunc func(ctx context.Context, gqx *goqu.TxDatabase) error,
) error

type PGXPoolConn

type PGXPoolConn struct {
	*pgxpool.Pool
	// contains filtered or unexported fields
}

func (*PGXPoolConn) CallContext

func (c *PGXPoolConn) CallContext(
	ctx context.Context,
	queryName string,
	callFunc func(ctx context.Context, db dbtypes.PgxConn) error,
) error

func (*PGXPoolConn) CallTransaction

func (c *PGXPoolConn) CallTransaction(
	ctx context.Context,
	txName string,
	callFunc func(ctx context.Context, tx dbtypes.PgxTx) error,
) error

func (*PGXPoolConn) Get

func (c *PGXPoolConn) Get(ctx context.Context, dst any, query string, args ...any) error

func (*PGXPoolConn) Select

func (c *PGXPoolConn) Select(ctx context.Context, dst any, query string, args ...any) error

func (*PGXPoolConn) Stats

func (c *PGXPoolConn) Stats() sql.DBStats

type PostgresConfig

type PostgresConfig struct {
	Configs []DBConfig
}

func NewPostgresConfig

func NewPostgresConfig(cfg *config.Config) PostgresConfig

type SQLConn

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

func (*SQLConn) CallContext

func (s *SQLConn) CallContext(
	ctx context.Context,
	queryName string,
	callFunc func(ctx context.Context, db *sqlx.DB) error,
) error

func (*SQLConn) CallTransaction

func (s *SQLConn) CallTransaction(
	ctx context.Context,
	txName string,
	callFunc func(ctx context.Context, tx *sqlx.Tx) error,
) error