quality fixtures

Author: jancajthaml

CONTRIBUTING

@@ -0,0 +1,4 @@
+All development activity takes place on github.
+
+If you think you've discovered a bug, or you would like
+to make a feature request please do this through github.

README.md

@@ -1,44 +1,35 @@
 # DataDog Server mock
 
-2MB golang server listening on port 8125 writing metrics to stdout.
+golang server listening on port 8125 writing metrics to stdout. (datadog/mock 3.02MB)
 
 ### Bootstrap
 
-```
-make install
-make test
-```
+Require docker to assembly
+
+`make install test`
 
 ### Running
 
-```
-make run
-```
+automagically
+
+`make run`
 
-or
+run in docker
 
-```
-docker run -it --log-driver none --rm -p 0.0.0.0:8125:8125/UDP datadog/mock
-```
+`docker run -it --log-driver none --rm -p 0.0.0.0:8125:8125/UDP datadog/mock`
 
-or
+run on host
 
-```
-./target/datadog_mock
-```
+`./target/datadog_mock`
 
 
 ### Verify
 
-When datadog/mock is running 
+When datadog/mock is running run manually
 
-```
-echo "deploys.test.myservice:1|c" > /dev/udp/127.0.0.1/8125
-```
+`echo "deploys.test.myservice:1|c" > /dev/udp/127.0.0.1/8125`
 
-or
+or send MESSAGE repeat EACH second
 
-```
-EACH=.001 ./dev/event-producer.sh
-```
+`MESSAGE="deploys.test.myservice:1|c" EACH=.001 ./dev/event-producer.sh`
 

dev/event-producer.sh

@@ -5,16 +5,16 @@ set -eo pipefail
 trap exit INT TERM
 
 ####
-sample="deploys.test.myservice:1|c"
 
 [ -z $EACH ] && EACH=2 || :
+[ -z $MESSAGE ] && MESSAGE="deploys.test.myservice:1|c" || :
 
-printf "[info] sending \"%s\" every %ssec\n" $sample $EACH
+printf "[info] sending \"%s\" every %ssec\n" $MESSAGE $EACH
 
 ####
 
 while true; do
-    echo $sample > /dev/udp/127.0.0.1/8125
+    echo $MESSAGE > /dev/udp/127.0.0.1/8125
     sleep $EACH
 done
 

src/datadog-mock/main.go

@@ -26,7 +26,7 @@ func main() {
 	stream, err := net.ResolveUDPAddr("udp", ":8125")
 
 	if err != nil {
-		fmt.Println("Fatal: %v", err)
+		fmt.Println(err)
 		os.Exit(1)
 	}
 

src/datadog-mock/sink.go

@@ -28,7 +28,7 @@ func (r *sink) Run(addr *net.UDPAddr) {
 	inputStreamConn, err := net.ListenUDP("udp", addr)
 
 	if err != nil {
-		fmt.Println("Fatal: %v", err)
+		fmt.Println(err)
 		os.Exit(1)
 	}
 
@@ -39,7 +39,7 @@ func (r *sink) Run(addr *net.UDPAddr) {
 forever:
 	n, _, err := inputStreamConn.ReadFromUDP(buf)
 	if err != nil {
-		fmt.Println("Error: %v", err)
+		fmt.Println(err)
 		goto forever
 	}