diff options
| author | Paul Buetow <paul@buetow.org> | 2023-05-22 00:26:30 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2023-05-22 00:26:30 +0300 |
| commit | 688ac52705c2e4bd015e8f369969de6a91e26d80 (patch) | |
| tree | de2f160b3ffaf750c60585f59257045d7dda3c14 /internal/server | |
| parent | bb79f9f50a89507fb7db6d1d4c62630e431952f9 (diff) | |
catch signals for shutdown
Diffstat (limited to 'internal/server')
| -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) |
