Help us shape the future of Go! Take the 2026 Go Developer Survey

sql

package
v0.6.25 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2023 License: Apache-2.0 Imports: 7 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var PgSqlWireSet = wire.NewSet(
	GetConfig,
	NewDbConnection,
)

Functions

func NewDbConnection

func NewDbConnection(cfg *Config, logger *zap.SugaredLogger) (*pg.DB, error)

Types

type AuditLog

type AuditLog struct {
	CreatedOn time.Time `sql:"created_on,type:timestamptz"`
	CreatedBy int32     `sql:"created_by,type:integer"`
	UpdatedOn time.Time `sql:"updated_on,type:timestamptz"`
	UpdatedBy int32     `sql:"updated_by,type:integer"`
}

type Config

type Config struct {
	Addr                   string `env:"PG_ADDR" envDefault:"127.0.0.1"`
	Port                   string `env:"PG_PORT" envDefault:"5432"`
	User                   string `env:"PG_USER" envDefault:""`
	Password               string `env:"PG_PASSWORD" envDefault:"" secretData:"-"`
	Database               string `env:"PG_DATABASE" envDefault:"orchestrator"`
	ApplicationName        string `env:"APP" envDefault:"orchestrator"`
	LogQuery               bool   `env:"PG_LOG_QUERY" envDefault:"true"`
	LogAllQuery            bool   `env:"PG_LOG_ALL_QUERY" envDefault:"false"`
	ExportPromMetrics      bool   `env:"PG_EXPORT_PROM_METRICS" envDefault:"false"`
	QueryDurationThreshold int64  `env:"PG_QUERY_DUR_THRESHOLD" envDefault:"5000"`
}

func GetConfig

func GetConfig() (*Config, error)

type TransactionUtilImpl added in v0.6.19

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

func NewTransactionUtilImpl added in v0.6.19

func NewTransactionUtilImpl(db *pg.DB) *TransactionUtilImpl

func (*TransactionUtilImpl) CommitTx added in v0.6.19

func (impl *TransactionUtilImpl) CommitTx(tx *pg.Tx) error

func (*TransactionUtilImpl) RollbackTx added in v0.6.19

func (impl *TransactionUtilImpl) RollbackTx(tx *pg.Tx) error

func (*TransactionUtilImpl) StartTx added in v0.6.19

func (impl *TransactionUtilImpl) StartTx() (*pg.Tx, error)

type TransactionWrapper added in v0.6.19

type TransactionWrapper interface {
	StartTx() (*pg.Tx, error)
	RollbackTx(tx *pg.Tx) error
	CommitTx(tx *pg.Tx) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL