restructure

broadcast/broadcast.go

@@ -0,0 +1,11 @@
+package broadcast
+
+type Configuration struct {
+	SelfAddress   string
+	PeerAddresses []string
+}
+
+type Broadcaster interface {
+	Init() (chan []byte, error)
+	Broadcast([]byte) error
+}

communication.go → broadcast/communication.go

@@ -1,4 +1,4 @@
-package gofret
+package broadcast
 
 import (
 	"bytes"

communication_test.go → broadcast/communication_test.go

@@ -1,4 +1,4 @@
-package gofret
+package broadcast
 
 import (
 	"testing"

gofret.go → broadcast/fifo.go

@@ -1,15 +1,10 @@
-package gofret
+package broadcast
 
 import (
 	"encoding/json"
 	"fmt"
 )
 
-type FIFOBroadcaster interface {
-	Broadcaster
-	Wait() chan bool
-}
-
 type fifo_broadcast_message struct {
 	Address string // we should find another identifier since address for a node might not be same across nodes
 	SendSeq uint64

gofret_test.go → broadcast/fifo_test.go

@@ -1,4 +1,4 @@
-package gofret
+package broadcast
 
 import (
 	"math/rand"

broadcast.go → broadcast/unordered.go

@@ -1,4 +1,4 @@
-package gofret
+package broadcast
 
 type broadcast_container struct {
 	Communicator communicator
@@ -7,16 +7,6 @@ type broadcast_container struct {
 	messages     chan []byte
 }
 
-type Configuration struct {
-	SelfAddress   string
-	PeerAddresses []string
-}
-
-type Broadcaster interface {
-	Init() (chan []byte, error)
-	Broadcast([]byte) error
-}
-
 func (bc *broadcast_container) Connect(address string) {}
 
 func (bc *broadcast_container) Broadcast(message []byte) error {

broadcast_test.go → broadcast/unordered_test.go

@@ -1,11 +1,11 @@
-package gofret
+package broadcast
 
 import (
 	"testing"
 	"time"
 )
 
-func TestBroadcast(t *testing.T) {
+func TestUnorderedBroadcast(t *testing.T) {
 	peer_addrs := []string{"localhost:8881", "localhost:8882", "localhost:8883", "localhost:8884", "localhost:8885"}
 	message := "hello gofret!"