For real sending logs to logstash agent

logstash/crispy/main.go

@@ -1,9 +1,11 @@
 package main
 
 import (
+	"encoding/json"
+	"fmt"
 	"log"
+	"net"
 	"net/http"
-	"os"
 )
 
 func main() {
@@ -24,9 +26,25 @@ func newCrispyServer() *crispyServer {
 }
 
 func (me *crispyServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
-	me.logstasher.Printf("%+v\n", r)
+	j, err := json.Marshal(r)
+	if err == nil {
+		me.logstasher.Println(string(j))
+	}
 }
 
 func newLogstashLogger() *log.Logger {
-	return log.New(os.Stderr, "", 0)
+	return log.New(&logstashWriter{}, "", 0)
+}
+
+type logstashWriter struct{}
+
+func (me *logstashWriter) Write(b []byte) (int, error) {
+	conn, err := net.Dial("tcp", ":55784")
+	if err == nil {
+		defer conn.Close()
+		fmt.Fprintf(conn, string(b))
+	} else {
+		fmt.Printf(string(b))
+	}
+	return 0, nil
 }