From bb79f9f50a89507fb7db6d1d4c62630e431952f9 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Mon, 22 May 2023 00:09:51 +0300 Subject: move server and client into their own packages --- internal/server.go | 39 --------------------------------------- 1 file changed, 39 deletions(-) delete mode 100644 internal/server.go (limited to 'internal/server.go') diff --git a/internal/server.go b/internal/server.go deleted file mode 100644 index 3c37d6a..0000000 --- a/internal/server.go +++ /dev/null @@ -1,39 +0,0 @@ -package internal - -import ( - "context" - "log" - "time" - - "codeberg.org/snonux/gorum/internal/config" - "codeberg.org/snonux/gorum/internal/quorum" - "codeberg.org/snonux/gorum/internal/vote" -) - -func runServer(ctx context.Context, conf config.Config) { - ch := make(chan vote.Vote) - quo := make(quorum.Quorum) - - go func() { - for { - select { - case vote := <-ch: - quo.Vote(vote) - winner, err := quo.Winner(conf) - if err != nil { - log.Println(err.Error()) - continue - } - log.Printf("The current leader node is %s", winner) - case <-time.After(vote.Expiry): - quo.CleanExpired() - case <-ctx.Done(): - return - } - } - }() - - if err := startTcpServer(ctx, conf, ch); err != nil { - panic(err) - } -} -- cgit v1.2.3