service

Jan 16, 2025

Changes in this version

type DefaultService

+ func (d *DefaultService) RunQueriesConcurrentlyWithCancel(queries ...func(db *sql.DB, ctx context.Context) error) *[]error

Jan 16, 2025

Changes in this version

type DefaultService

+ func (d *DefaultService) RunQueriesConcurrently(queries ...func(db *sql.DB, ctx context.Context) error) *[]error

Jan 9, 2025

Changes in this version

+ var ErrNilService = errors.New("service cannot be nil")

+ type DefaultService struct

+ func NewDefaultService(db *sql.DB) (instance *DefaultService, err error)

+ func (d *DefaultService) DB() *sql.DB

+ func (d *DefaultService) Exec(query *string, params ...interface{}) (sql.Result, error)

+ func (d *DefaultService) Migrate(queries ...string) error

+ func (d *DefaultService) QueryRow(query *string, params ...interface{}) *sql.Row

+ func (d *DefaultService) RunTransaction(fn func(tx *sql.Tx) error) error

+ func (d *DefaultService) ScanRow(row *sql.Row, destinations ...interface{}) error

+ type Service interface

+ DB func() *sql.DB

+ Exec func(query *string, params ...interface{}) (sql.Result, error)

+ Migrate func(queries ...string) error

+ QueryRow func(query *string, params ...interface{}) *sql.Row

+ RunTransaction func(fn func(tx *sql.Tx) error) error

+ ScanRow func(row *sql.Row, destinations ...interface{}) error