eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-04 12:03:41 +02:00
Code Releases Activity

cmd/main/main.go: close processor when application is done.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-29 11:55:42 +02:00
parent 0034225e7a
commit 834adb6ca8
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
cmd/main/main.go
View file

@ -220,7 +220,7 @@ func main() {
c.IrreversibleOnly = conf.IrreversibleOnly c.IrreversibleOnly = conf.IrreversibleOnly
}) })
app.SpawnProccessor( processor := app.SpawnProccessor(
shClient, shClient,
redis_pubsub.NewPublisher(rdb, redis_common.Namespace{ redis_pubsub.NewPublisher(rdb, redis_common.Namespace{
Prefix: conf.Redis.Prefix, Prefix: conf.Redis.Prefix,
@ -231,4 +231,7 @@ func main() {
// Run the application // Run the application
run() run()
// Close the processor properly
processor.Close()
} }