eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-02 11:43:40 +02:00
Code Releases Activity

main.go: setup redis pubsub publisher.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-01-13 13:32:23 +01:00
parent 45bf043d8a
commit eec834a338
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
main.go
View file

@ -11,6 +11,9 @@ import (
"eosio-ship-trace-reader/config" "eosio-ship-trace-reader/config"
"eosio-ship-trace-reader/internal/redis" "eosio-ship-trace-reader/internal/redis"
"eosio-ship-trace-reader/transport"
"eosio-ship-trace-reader/transport/redis_pubsub"
"github.com/nikoksr/notify" "github.com/nikoksr/notify"
"github.com/nikoksr/notify/service/telegram" "github.com/nikoksr/notify/service/telegram"
@ -39,6 +42,8 @@ var (
var abi_mgr *abi.AbiManager var abi_mgr *abi.AbiManager
var publisher transport.Publisher
var redisNs redis.Namespace var redisNs redis.Namespace
// Reader states // Reader states
@ -220,6 +225,9 @@ func main() {
return return
} }
// Setup publisher
publisher = redis_pubsub.New(redis.Client())
// Connect client and get chain info. // Connect client and get chain info.
log.Printf("Get chain info from api at: %s", conf.Api) log.Printf("Get chain info from api at: %s", conf.Api)
eosClient = eos.New(conf.Api) eosClient = eos.New(conf.Api)