update

Dockerfile

@@ -0,0 +1,15 @@
+FROM daocloud.io/library/ubuntu:16.04
+
+MAINTAINER Jiawen Guan <[email protected]>
+
+WORKDIR /pentadb
+
+ADD . /pentadb
+
+ENV GOPATH=/pentadb
+
+RUN apt update && apt install golang -y
+
+RUN chmod +x /pentadb/entry.sh
+
+CMD . /pentadb/entry.sh

entry.sh

@@ -0,0 +1,24 @@
+#!/bin/sh
+
+port=${PENTADB_PORT:-'4567'}
+path=${PENTADB_PATH:-'/tmp/pentadb'}
+
+base_dir="/pentadb/src/"
+
+packages=(
+    "github.com/golang/snappy",
+    "github.com/satori/go.uuid",
+    "github.com/syndtr/goleveldb/leveldb"
+)
+
+# delete invalid packages
+# then download the newer packages
+for package in packages
+do
+    rm -r ${base_dir}${package}
+    go get ${package}
+done
+
+# exec
+cd /pentadb/src/github.com/shenaishiren/pentadb/commands
+go run server.go -p ${port} -a ${path}

src/github.com/shenaishiren/pentadb/client/client_test.go

@@ -6,18 +6,19 @@ import (
 	"testing"
 )
 
-//func TestNewClient_NoEnoughNodes(t *testing.T) {
-//	var nodes = []string{"127.0.0.1:5000"}
-//	var weights = map[string]int{"127.0.0.1:5000": 1}
-//	if _, err := NewClient(nodes, weights, 3); err != nil {
-//		t.Errorf(err.Error())
-//	}
-//}
+func TestNewClient_NoEnoughNodes(t *testing.T) {
+	var nodes = []string{"127.0.0.1:5000"}
+	if _, err := NewClient(nodes, nil, 3); err != nil {
+		t.Errorf(err.Error())
+	}
+}
 
 func TestNewClient_WrongReplicas(t *testing.T) {
-	var nodes = []string{"127.0.0.1:5000"}
-	var weights = map[string]int{"127.0.0.1:5000": 1}
-	if _, err := NewClient(nodes, weights, 3); err != nil {
+	var nodes = []string{
+		"127.0.0.1:5000",
+		"10.19.126.55:4567",
+	}
+	if _, err := NewClient(nodes, nil, 3); err != nil {
 		t.Errorf(err.Error())
 	}
 }

src/github.com/shenaishiren/pentadb/client/node.go

@@ -66,10 +66,10 @@ func NewNode(ipaddr string) *Node {
 	}
 	// check whether this node is connectable or not
 	// TODO
-	//proxy := NewNodeProxy(node)
-	//if proxy == nil {
-	//	return nil
-	//}
-	//node.Proxy = proxy
+	proxy := NewNodeProxy(node)
+	if proxy == nil {
+		return nil
+	}
+	node.Proxy = proxy
 	return node
 }

src/github.com/shenaishiren/pentadb/commands/server.go

@@ -90,7 +90,6 @@ func (s *Server) listen(port string, path string) error {
 	return nil
 }
 
-
 func main() {
 	var (
 		help bool
@@ -101,6 +100,11 @@ func main() {
 	flag.StringVar(&port, "p", "4567", "The port to listen on (default: 4567)")
 	flag.StringVar(&path, "a", opt.DeafultPath, "The path to use for the LevelDB store")
 
+	// change default usage
+	flag.Usage = func() {
+		fmt.Println(helpPrompt)
+	}
+
 	// run
 	flag.Parse()
 

src/github.com/shenaishiren/pentadb/opt/options.go

@@ -3,7 +3,7 @@ package opt
 import "time"
 
 const (
-	DefaultReplicas = 0                 // default replicas for raft algorithm
+	DefaultReplicas = 1                 // default replicas for raft algorithm
 	DeafultPath = "/tmp/pentadb"        // default path for levelDB
 	DefaultProtocol = "tcp"
 	DefaultTimeout = 3 * time.Second