grassrootseconomics
/
cic-dw
mirror of https://github.com/GrassrootsEconomics/cic-dw.git
5
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: (redis) bootstrap connection struct properly

This commit is contained in:
Mohamed Sohail 2022-05-05 19:39:25 +03:00
parent da66f70bf9
commit a68ae5a9eb
Signed by: kamikazechaser
GPG Key ID: 7DD45520C01CD85D
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/init.go
View File

@ -47,13 +47,17 @@ func loadConfig(configFilePath string, k *koanf.Koanf) error {
return nil return nil
} }
func connectDb(dsn string) error { func connectDbs(dsn string) error {
var err error var err error
db, err = pgxpool.Connect(context.Background(), dsn) db, err = pgxpool.Connect(context.Background(), dsn)
if err != nil { if err != nil {
return err return err
} }
rClient = asynq.RedisClientOpt{
Addr: conf.Db.Redis,
}
return nil return nil
} }

2
cmd/main.go
View File

@ -35,7 +35,7 @@ func init() {
log.Fatal().Err(err).Msg("failed to load sql file") log.Fatal().Err(err).Msg("failed to load sql file")
} }
if err := connectDb(conf.Db.Postgres); err != nil { if err := connectDbs(conf.Db.Postgres); err != nil {
log.Fatal().Err(err).Msg("failed to connect to postgres") log.Fatal().Err(err).Msg("failed to connect to postgres")
} }

4
config.toml
View File

@ -8,5 +8,5 @@ rpc = "http://127.0.0.1:8545"
[syncers] [syncers]
cache = "@every 20s" cache = "@every 20s"
ussd = "@every 1m" ussd = "@every 30"
token = "@every 10s" token = "@every 1m"