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 | |
| parent | 14e73217895307983ae762cb5ffd29ac45d8d1d1 (diff) | |
move server and client into their own packages
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/client.go | 10 | ||||
| -rw-r--r-- | internal/client/client.go | 10 | ||||
| -rw-r--r-- | internal/run.go | 6 | ||||
| -rw-r--r-- | internal/server/server.go (renamed from internal/server.go) | 6 | ||||
| -rw-r--r-- | internal/server/tcpserver.go (renamed from internal/tcpserver.go) | 4 |
5 files changed, 19 insertions, 17 deletions
diff --git a/internal/client.go b/internal/client.go deleted file mode 100644 index 6775ab2..0000000 --- a/internal/client.go +++ /dev/null @@ -1,10 +0,0 @@ -package internal - -import ( - "context" - - "codeberg.org/snonux/gorum/internal/config" -) - -func runClient(ctx context.Context, conf config.Config) { -} diff --git a/internal/client/client.go b/internal/client/client.go new file mode 100644 index 0000000..299623d --- /dev/null +++ b/internal/client/client.go @@ -0,0 +1,10 @@ +package client + +import ( + "context" + + "codeberg.org/snonux/gorum/internal/config" +) + +func Start(ctx context.Context, conf config.Config) { +} diff --git a/internal/run.go b/internal/run.go index d575ded..e1139d7 100644 --- a/internal/run.go +++ b/internal/run.go @@ -3,7 +3,9 @@ package internal import ( "context" + "codeberg.org/snonux/gorum/internal/client" "codeberg.org/snonux/gorum/internal/config" + "codeberg.org/snonux/gorum/internal/server" ) func Run(ctx context.Context, configFile string) { @@ -12,6 +14,6 @@ func Run(ctx context.Context, configFile string) { panic(err) } - go runClient(ctx, conf) - runServer(ctx, conf) + go client.Start(ctx, conf) + server.Start(ctx, conf) } diff --git a/internal/server.go b/internal/server/server.go index 3c37d6a..55d7c9a 100644 --- a/internal/server.go +++ b/internal/server/server.go @@ -1,4 +1,4 @@ -package internal +package server import ( "context" @@ -10,7 +10,7 @@ import ( "codeberg.org/snonux/gorum/internal/vote" ) -func runServer(ctx context.Context, conf config.Config) { +func Start(ctx context.Context, conf config.Config) { ch := make(chan vote.Vote) quo := make(quorum.Quorum) @@ -33,7 +33,7 @@ func runServer(ctx context.Context, conf config.Config) { } }() - if err := startTcpServer(ctx, conf, ch); err != nil { + if err := tcpServerStart(ctx, conf, ch); err != nil { panic(err) } } diff --git a/internal/tcpserver.go b/internal/server/tcpserver.go index b1fd11e..4157c29 100644 --- a/internal/tcpserver.go +++ b/internal/server/tcpserver.go @@ -1,4 +1,4 @@ -package internal +package server import ( "bufio" @@ -11,7 +11,7 @@ import ( "codeberg.org/snonux/gorum/internal/vote" ) -func startTcpServer(ctx context.Context, conf config.Config, +func tcpServerStart(ctx context.Context, conf config.Config, ch chan<- vote.Vote) error { listener, err := net.Listen("tcp", conf.Address) |
