func Open()

in internal/dal/config.go [33:51]


func Open() error {
	var err error
	d, err := sql.Open("mysql", pmysql.PluginConfig.DSN)
	d.SetMaxOpenConns(pmysql.PluginConfig.MaxOpen)
	d.SetMaxIdleConns(pmysql.PluginConfig.MaxIdle)
	d.SetConnMaxLifetime(time.Millisecond * time.Duration(pmysql.PluginConfig.MaxLifetime))

	workflowDB, err = gorm.Open(mysql.New(mysql.Config{Conn: d}),
		&gorm.Config{Logger: logger.Default.LogMode(logger.Silent)})
	if err != nil {
		return err
	}
	db, err := workflowDB.DB()
	if err != nil {
		return err
	}
	workflowLock = dblock.NewMysqlLocker(db)
	return nil
}