Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var PgSqlWireSet = wire.NewSet( GetConfig, NewDbConnection, )
Functions ¶
func NewDbConnection ¶
Types ¶
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"`
}
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
Click to show internal directories.
Click to hide internal directories.