|
@@ -17,7 +17,6 @@ limitations under the License.
|
|
|
package priorities
|
|
|
|
|
|
import (
|
|
|
- "database/sql"
|
|
|
"fmt"
|
|
|
"os"
|
|
|
|
|
@@ -96,13 +95,13 @@ func customResourceScorer(nodeName string) int64 {
|
|
|
-------------------------------------*/
|
|
|
|
|
|
//Access the Database
|
|
|
- DBstring := cfg.Database.Username + ":" + cfg.Database.Password + "@tcp(" + cfg.Server.Host + ":" + cfg.Server.Port + ")/" + cfg.Database.Name
|
|
|
- _, err := sql.Open(cfg.Database.Type, DBstring)
|
|
|
- if err != nil {
|
|
|
- panic(err.Error())
|
|
|
- }
|
|
|
+ // DBstring := cfg.Database.Username + ":" + cfg.Database.Password + "@tcp(" + cfg.Server.Host + ":" + cfg.Server.Port + ")/" + cfg.Database.Name
|
|
|
+ // _, err := sql.Open(cfg.Database.Type, DBstring)
|
|
|
+ // if err != nil {
|
|
|
+ // panic(err.Error())
|
|
|
+ // }
|
|
|
|
|
|
- //TODO InfluxDB
|
|
|
+ // InfluxDB
|
|
|
c, err := client.NewHTTPClient(client.HTTPConfig{
|
|
|
Addr: "http://" + cfg.Server.Host + ":" + cfg.Server.Port + "",
|
|
|
})
|