feat: add flinkApiUrl and database path configs

This commit is contained in:
Mohamad Khani 2024-12-01 02:05:21 +03:30
parent dd700b6007
commit ac8453bb57
2 changed files with 11 additions and 17 deletions

View File

@ -1,6 +1,7 @@
package main
import (
"flink-kube-operator/internal/config"
"flink-kube-operator/internal/crd"
"flink-kube-operator/internal/manager"
"fmt"
@ -16,17 +17,21 @@ import (
func main() {
lc.Logger.Debug("start")
// load yaml config file
config := lc.LoadYamlConfig[config.Config]("./config.yaml")
// init kubernetes flink job crd watch
crd.New()
// create database instance
db, err := buntdb.Open("./bunt.db")
db, err := buntdb.Open(config.DatabasePath)
if err != nil {
lc.Logger.Fatal("[main] error on open db", zap.Error(err))
}
defer db.Close()
c, err := api.New("127.0.0.1:8981")
// create flink api instance
c, err := api.New(config.FlinkApiUrl)
if err != nil {
panic(err)
}
@ -38,21 +43,9 @@ func main() {
}
fmt.Println(clusterConfig)
jars, err := c.Jars()
if err != nil {
lc.Logger.Error("error on getting jars", zap.Error(err))
}
lc.Logger.Debug("[main] jars", zap.Any("jars", jars))
jobs, err := c.Jobs()
if err != nil {
lc.Logger.Error("error on getting jars", zap.Error(err))
}
lc.Logger.Debug("[main] jobs", zap.Any("jobs", jobs))
// init flink job manager
manager.Setup(c, db)
//config := lc.LoadYamlConfig[config.Config]("./config.yaml")
// for _, jobDef := range config.Jobs {
// managed_job.NewManagedJob(c, db, jobDef)
// }

View File

@ -1 +1,2 @@
jobs:
flinkApiUrl: 127.0.0.1:8981
databasePath: ./bunt.db