summaryrefslogtreecommitdiff
path: root/internal/server.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2023-05-22 00:09:51 +0300
committerPaul Buetow <paul@buetow.org>2023-05-22 00:09:51 +0300
commitbb79f9f50a89507fb7db6d1d4c62630e431952f9 (patch)
treea52d163f864b0d3a606023a9d0f864c577c30142 /internal/server.go
parent14e73217895307983ae762cb5ffd29ac45d8d1d1 (diff)
move server and client into their own packages
Diffstat (limited to 'internal/server.go')
-rw-r--r--internal/server.go39
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)
- }
-}