Merge pull request #2 from jancajthaml/feature/circle-ci

Quality Assurance (codacy), Continuous Improvements (circle) Coordinates (DockerHUB) integration

Author: jancajthaml

.circleci/config.yml

@@ -0,0 +1,74 @@
+version: 2
+
+jobs:
+  test:
+    docker:
+      - image: circleci/golang:1.9
+      
+    working_directory: /go/src/jancajthaml
+    steps:
+      - checkout
+
+      - run:
+          name: Sync dependencies
+          command: |
+            go get -u github.com/kardianos/govendor
+            govendor sync -v
+
+      - run:
+          name: Run tests
+          command: |
+            cd /go/src/jancajthaml/src/datadog-mock
+            go test -v ./...
+
+      - run:
+          name: Build server
+          command: |
+            cd /go/src/jancajthaml/src/datadog-mock
+            go clean
+            CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o /go/src/github.com/jancajthaml/target/datadog_mock
+
+      - persist_to_workspace: 
+          root: /go/src/github.com/jancajthaml
+          paths:
+            - target/datadog_mock
+
+  deploy:
+    docker:
+      - image: docker:17.05.0-ce-git
+
+    working_directory: /app
+    steps:
+      - attach_workspace:
+          at: /go/src/github.com/jancajthaml
+
+      - checkout
+
+      - setup_remote_docker
+
+      - run:
+          name: Build application Docker image
+          command: |
+            cp -r /go/src/github.com/jancajthaml/target /app/target
+            docker build -t bundle .
+
+      - run:
+          name: List images
+          command: |
+            docker images
+
+      - deploy:
+          name: Push image to DockerHUB
+          command: |
+            docker login -e ${DOCKER_EMAIL} -u ${DOCKER_USER} -p ${DOCKER_PASSWORD}
+            docker tag bundle "jancajthaml/datadog_mock:${CIRCLE_SHA1}"
+            docker push "jancajthaml/datadog_mock:${CIRCLE_SHA1}"
+
+workflows:
+  version: 2
+  test_and_deploy:
+    jobs:
+      - test
+      - deploy:
+          requires:
+            - test

AUTHORS

@@ -1 +1 @@
-AUTHORS
+Jan Cajthaml <[email protected]>

Makefile

@@ -6,6 +6,10 @@ all: install test authors run
 .PHONY: install
 install: prepare-dev lint bundle
 
+.PHONY: perf
+perf:
+	@./dev/siege.sh
+
 .PHONY: fmt
 fmt:
 	docker-compose run --rm fmt

README.md

@@ -1,35 +1,24 @@
-# DataDog Server mock
+# datadog-mock #
 
-golang server listening on port 8125 writing metrics to stdout. (datadog/mock 3.02MB)
+datadog-mock is a golang statsd mock server listening on port 8125 and relaying events to stdout.
 
-### Bootstrap
+[![Build Status](https://circleci.com/gh/jancajthaml/datadog-mock.svg?style=svg)](https://circleci.com/gh/jancajthaml/datadog-mock) [![Static Analysis](https://api.codacy.com/project/badge/Grade/c5c255a292f84cf88972f92f74f9174d)](https://www.codacy.com/app/jan-cajthaml/datadog-mock?utm_source=github.com&utm_medium=referral&utm_content=jancajthaml/datadog-mock&utm_campaign=Badge_Grade) [![Test Coverage](https://coveralls.io/repos/github/jancajthaml/datadog-mock/badge.svg?branch=master)](https://coveralls.io/github/jancajthaml/datadog-mock?branch=master)
 
-Require docker to assembly
+## Getting started ##
 
-`make install test`
+Bootstrap environment with `make install test` then grab `./target/datadog_mock`
+or docker image `datadog/mock`.
 
-### Running
+## Usage ##
 
-automagically
+Run in docker with `make run` or `./target/datadog_mock` locally.
 
-`make run`
+## Testing ##
 
-run in docker
+When datadog/mock is running you can either test simple relay
+`./dev/event-producer.sh` or siege with `make perf`.
 
-`docker run -it --log-driver none --rm -p 0.0.0.0:8125:8125/UDP datadog/mock`
-
-run on host
-
-`./target/datadog_mock`
-
-
-### Verify
-
-When datadog/mock is running run manually
-
-`echo "deploys.test.myservice:1|c" > /dev/udp/127.0.0.1/8125`
-
-or send MESSAGE repeat EACH second
-
-`MESSAGE="deploys.test.myservice:1|c" EACH=.001 ./dev/event-producer.sh`
+## License ##
 
+This service is distributed under the Apache License, Version 2.0 license found
+in the [LICENSE](./LICENSE) file.

dev/event-producer.sh

@@ -1,13 +1,12 @@
 #!/bin/bash
 
 set -eo pipefail
-
 trap exit INT TERM
 
 ####
 
-[ -z $EACH ] && EACH=2 || :
-[ -z $MESSAGE ] && MESSAGE="deploys.test.myservice:1|c" || :
+if [ -z $EACH ]; then EACH=2; fi
+if [ -z $MESSAGE ]; then MESSAGE="deploys.test.myservice:1|c"; fi
 
 printf "[info] sending \"%s\" every %ssec\n" $MESSAGE $EACH
 

dev/siege.sh

@@ -0,0 +1,28 @@
+#!/bin/bash
+
+set -eo pipefail
+
+exec 3>&1 4>&2
+
+post_stop() {
+    exit_code=$?
+    printf "\n"
+    if [ -n "$error" ]; then
+        printf "Error: %s\n" $error
+    fi
+    exec 3>&- 4>&-
+    exit $exit_code
+}
+
+trap post_stop INT TERM
+trap "kill 0" EXIT
+
+MESSAGE="deploys.test.myservice:1|c" EACH=.0001 ./dev/event-producer.sh &> /dev/null &
+MESSAGE="deploys.test.myservice:2|c" EACH=.0001 ./dev/event-producer.sh &> /dev/null &
+MESSAGE="deploys.test.myservice:3|c" EACH=.0001 ./dev/event-producer.sh &> /dev/null &
+
+docker rm -f $(docker ps -aq --filter="name=datadog" --filter="status=running") &> /dev/null || :
+
+printf "processing [0 / sec]"
+
+error=$( { (docker-compose run --rm --no-deps --service-ports artefact 2>&4 || :) | perl -e 'open(TTY, ">:unix", "/dev/tty");while (<>) {$l++;if (time > $e) {$e=time;print TTY "\rprocessing [$l / sec]";$l=0}}' 1>&3; } 2>&1 )

src/datadog-mock/processor.go

@@ -31,13 +31,14 @@ func init() {
 
 var pattern = regexp.MustCompile(`(?P<name>.*?):(?P<value>.*?)\|(?P<type>[a-z])(?:\|#(?P<tags>.*))?`)
 
-func processEvent(event string) {
-	match := pattern.FindStringSubmatch(event)
+func processEvent(event []byte) {
+	parsed := string(event)
+	match := pattern.FindStringSubmatch(parsed)
 
 	if len(match) < 3 {
 		return
 	}
 
-	nanolog.Log(h, strings.TrimSuffix(event, "\n")+"\r\n")
+	nanolog.Log(h, strings.TrimSuffix(parsed, "\n")+"\r\n")
 	nanolog.Flush()
 }

src/datadog-mock/sink.go

@@ -20,10 +20,12 @@ import (
 	"os"
 )
 
+// NewSink creates new UDP sink with channel for complete events
 func NewSink() *sink {
-	return &sink{event: make(chan string)}
+	return &sink{event: make(chan []byte)}
 }
 
+// Run starts UDP sink with UPD stream source
 func (r *sink) Run(addr *net.UDPAddr) {
 	inputStreamConn, err := net.ListenUDP("udp", addr)
 
@@ -34,7 +36,7 @@ func (r *sink) Run(addr *net.UDPAddr) {
 
 	defer inputStreamConn.Close()
 
-	buf := make([]byte, BUF_SIZE)
+	buf := make([]byte, BufferSize)
 
 forever:
 	n, _, err := inputStreamConn.ReadFromUDP(buf)
@@ -43,7 +45,7 @@ forever:
 		goto forever
 	}
 
-	r.event <- string(buf[0:n])
+	r.event <- buf[0:n]
 
 	goto forever
 }

src/datadog-mock/types.go

@@ -15,7 +15,8 @@
 package main
 
 type sink struct {
-	event chan string
+	event chan []byte
 }
 
-const BUF_SIZE int = 1024
+// BufferSize is upper boundary of UDP recieve window
+const BufferSize int = 1024