summaryrefslogtreecommitdiff
path: root/internal
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
parent14e73217895307983ae762cb5ffd29ac45d8d1d1 (diff)
move server and client into their own packages
Diffstat (limited to 'internal')
-rw-r--r--internal/client.go10
-rw-r--r--internal/client/client.go10
-rw-r--r--internal/run.go6
-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)