diff options
Diffstat (limited to 'internal/server/server.go')
| -rw-r--r-- | internal/server/server.go | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/internal/server/server.go b/internal/server/server.go index 55d7c9a..d388e01 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -11,6 +11,21 @@ import ( ) func Start(ctx context.Context, conf config.Config) { + go func() { + for { + log.Println("Starting server") + start(ctx, conf) + + select { + case <-time.After(time.Second): + case <-ctx.Done(): + return + } + } + }() +} + +func start(ctx context.Context, conf config.Config) { ch := make(chan vote.Vote) quo := make(quorum.Quorum) |