pos-lachesis docker

.dockerignore

@@ -0,0 +1 @@
+vendor

src/poslachesis/README.md

@@ -0,0 +1,21 @@
+# PoS-Lachesis node
+
+Package assembles functionality of [network node](../posnode/) and [consensus](../posposet/) into solid Lachesis-node.
+
+
+### Executables
+
+[`cmd/`](./cmd/) - contains cli (only for fakenet now):
+
+  - run single node: `go run main.go`;
+  - for args see `go run main.go --help`;
+  - build: `go build .`;
+
+
+### Docker
+
+[`docker/`](./docker/) - contains docker scripts to try lachesis fakenet:
+
+  - build node docker image "pos-lachesis": `make`;
+  - run network of N nodes: `n=N ./start.sh`;
+  - drop network: `./stop.sh`;

src/poslachesis/docker/Dockerfile

@@ -0,0 +1,18 @@
+FROM golang:1.12 as build
+
+WORKDIR /go/src/github.com/Fantom-foundation/go-lachesis
+COPY . .
+
+RUN go get github.com/Masterminds/glide 
+
+RUN glide install && CGO_ENABLED=0 go build -ldflags "-s -w" -o /tmp/lachesis ./src/poslachesis/cmd
+
+
+
+FROM scratch as prod
+
+COPY --from=build /tmp/lachesis /
+
+EXPOSE 55555 55556
+
+ENTRYPOINT ["/lachesis"]

src/poslachesis/docker/Makefile

@@ -0,0 +1,13 @@
+.PHONY: build start stop
+
+all: build
+
+
+build:
+	cd ../../.. && docker build -f src/poslachesis/docker/Dockerfile -t "pos-lachesis" .
+
+start:
+	./start.sh
+
+stop:
+	./stop.sh

src/poslachesis/docker/start.sh

@@ -0,0 +1,15 @@
+#!/usr/bin/env bash
+
+declare -ri n="${n:-3}"
+
+docker network create lachesis
+
+limit_cpu=$(echo "scale=2; 1/$n" | bc)
+limit_io=$(echo "500/$n" | bc)
+limits="--cpus=${limit_cpu} --blkio-weight=${limit_io}"
+
+for i in $(seq $n)
+do
+    j=$(($i % $n + 1)) # ring
+    docker run -d --rm --name=pos-lachesis-node-$i ${limits} --net=lachesis "pos-lachesis" --fakegen=$i/$n --db=/tmp --peer=pos-lachesis-node-$j
+done

src/poslachesis/docker/stop.sh

@@ -0,0 +1,8 @@
+#!/usr/bin/env bash
+
+docker ps -q --filter "network=lachesis" | while read id
+do
+    docker stop $id
+done
+
+docker network rm lachesis

src/posnode/emitter.go

@@ -24,9 +24,8 @@ func (n *Node) StartEventEmission() {
 		return
 	}
 	n.emitter.done = make(chan struct{})
-	done := n.emitter.done
 
-	go func() {
+	go func(done chan struct{}) {
 		ticker := time.NewTicker(n.conf.EmitInterval)
 		for {
 			select {
@@ -36,7 +35,7 @@ func (n *Node) StartEventEmission() {
 				return
 			}
 		}
-	}()
+	}(n.emitter.done)
 }
 
 // StopEventEmission stops event emission.