logspam.go

package main

import (
        "log"
        "net"
        "time"
)

func Connect() (connection net.Conn, _ error) {
        connection, _ = net.Dial("tcp", "localhost:3333")

        log.Print("Connected to: ", connection.RemoteAddr())

        return
}

func main() {
        log.Print("Json Spammer")

        jsonsocket, _ := Connect()
        defer jsonsocket.Close()

        for {
                t := time.Now()
                var json = []byte(`{"save_at_master":true,"logger_name":"logspammer.Host","process_guid":"31F34CE2-7BD9-4FE7-B5799726C1B52C7C","exe":"logspam.go","pid":"27660","tag":"spamserver.on_close.01","file":"logspam.go","line":"0","@timestamp":"`)
                json = append(json, []byte(t.Format(time.RFC3339))...)
                json = append(json, []byte(`","log_line":{"msg":"I'm Spamming","remote_host":"[::ffff:10.355.13.11]:41717"}}
`)...)
                //log.Print("Sending: ", json)

                jsonsocket.Write(json)
        }
}