Barebones Riemann server for integration tests

riemann_server.go

package main

import (
	pb "code.google.com/p/goprotobuf/proto"
	msg "github.com/amir/raidman/proto"
	"log"
	"net"
)

func createRiemannServer() {
	addr, _ := net.ResolveUDPAddr("udp", "localhost:5555")
	server, _ := net.ListenUDP("udp", addr)

	for {
		buf := make([]byte, 1024)
		rlen, _, err := server.ReadFromUDP(buf)

		if err != nil {
			log.Fatal(err.Error())
		}

		msg := &msg.Msg{}
		pb.Unmarshal(buf[:rlen], msg)
		log.Print(msg.Events[0])
	}
}