database

Documentation

Index

• func CreateProduct(db *sql.DB, product *Product, ctx context.Context) error
• func DbHostDefault() string
• func DbNameDefault() string
• func DbPasswordDefault() string
• func DbPortDefault() int
• func DbSslModeDefault() string
• func DbUsernameDefault() string
• func DeleteProduct(db *sql.DB, productId int, ctx context.Context) error
• func DeleteProducts(db *sql.DB, ctx context.Context) error
• func GetProduct(db *sql.DB, product *Product, ctx context.Context) error
• func InitDb(db *sql.DB) error
• func LoadConfig() *config
• func New() (*sql.DB, error)
• func NewWithWrappedTracing() (*sql.DB, error)
• func PingDb(db *sql.DB, maxRetry uint64) error
• func UpdateProduct(db *sql.DB, product *Product, ctx context.Context) error
• type Product
  • func GetProducts(db *sql.DB, start, count int, ctx context.Context) ([]*Product, error)
  • func (p *Product) String() string

Functions

func CreateProduct

func CreateProduct(db *sql.DB, product *Product, ctx context.Context) error

func DbHostDefault

func DbHostDefault() string

func DbNameDefault

func DbNameDefault() string

func DbPasswordDefault

func DbPasswordDefault() string

func DbPortDefault

func DbPortDefault() int

func DbSslModeDefault

func DbSslModeDefault() string

func DbUsernameDefault

func DbUsernameDefault() string

func DeleteProduct

func DeleteProduct(db *sql.DB, productId int, ctx context.Context) error

func DeleteProducts

func DeleteProducts(db *sql.DB, ctx context.Context) error

func GetProduct

func GetProduct(db *sql.DB, product *Product, ctx context.Context) error

func InitDb

func InitDb(db *sql.DB) error

func LoadConfig

func LoadConfig() *config

func New

func New() (*sql.DB, error)

func NewWithWrappedTracing

func NewWithWrappedTracing() (*sql.DB, error)

func PingDb

func PingDb(db *sql.DB, maxRetry uint64) error

func UpdateProduct

func UpdateProduct(db *sql.DB, product *Product, ctx context.Context) error

Types

type Product

type Product struct {
	ID    int     `json:"id"`
	Name  string  `json:"name"`
	Price float64 `json:"price"`
}

func GetProducts

func GetProducts(db *sql.DB, start, count int, ctx context.Context) ([]*Product, error)

func (*Product) String

func (p *Product) String() string