diff options
Diffstat (limited to 'internal/run.go')
| -rw-r--r-- | internal/run.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/internal/run.go b/internal/run.go index 2439928..d07ba28 100644 --- a/internal/run.go +++ b/internal/run.go @@ -7,6 +7,7 @@ import ( "codeberg.org/snonux/gorum/internal/client" "codeberg.org/snonux/gorum/internal/config" + "codeberg.org/snonux/gorum/internal/notifier" "codeberg.org/snonux/gorum/internal/quorum" "codeberg.org/snonux/gorum/internal/server" ) @@ -32,9 +33,12 @@ func Run(ctx context.Context, configFile string, loopIntervalS int64) error { log.Println("Starting everything up!") quo := quorum.New(conf) - myVoteCh := quo.Start(ctx) + notifier := notifier.New() + + myVoteCh, scoreCh := quo.Start(ctx) server.Start(ctx, conf, quo) client.Start(ctx, conf, myVoteCh) + notifier.Start(ctx, conf, scoreCh) <-ctx.Done() log.Println("Good bye and have a nice day!") |