Print syslog request per sec.

syslog_count.go

package main

import (
	"fmt"
	"gopkg.in/mcuadros/go-syslog.v2"
	"time"
)

func check(e error) {
	if e != nil {
		panic(e)
	}
}

func main() {
	channel := make(syslog.LogPartsChannel)
	handler := syslog.NewChannelHandler(channel)

	server := syslog.NewServer()
	server.SetFormat(syslog.RFC5424)
	server.SetHandler(handler)
	server.ListenUDP("0.0.0.0:514")
	server.ListenTCP("0.0.0.0:514")
	server.Boot()

	go func(channel syslog.LogPartsChannel) {
		i := 0
		for logParts := range channel {
			fmt.Println(logParts)
			timer2 := time.NewTimer(time.Second)
			go func() {
				<-timer2.C
				fmt.Println("Req/sec = ", i)
				i = 0
			}()
			i = i + 1
		}
	}(channel)
	server.Wait()
}