diff options
| author | Paul Buetow <paul@buetow.org> | 2023-05-22 00:09:51 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2023-05-22 00:09:51 +0300 |
| commit | bb79f9f50a89507fb7db6d1d4c62630e431952f9 (patch) | |
| tree | a52d163f864b0d3a606023a9d0f864c577c30142 /internal/server.go | |
| parent | 14e73217895307983ae762cb5ffd29ac45d8d1d1 (diff) | |
move server and client into their own packages
Diffstat (limited to 'internal/server.go')
| -rw-r--r-- | internal/server.go | 39 |
1 files changed, 0 insertions, 39 deletions
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) - } -} |
