36 lines
832 B
Go
36 lines
832 B
Go
|
package syslog
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/jeromer/syslogparser"
|
||
|
|
)
|
||
|
|
|
||
|
|
//The handler receive every syslog entry at Handle method
|
||
|
|
type Handler interface {
|
||
|
|
Handle(syslogparser.LogParts, int64, error)
|
||
|
|
}
|
||
|
|
|
||
|
|
type LogPartsChannel chan syslogparser.LogParts
|
||
|
|
|
||
|
|
//The ChannelHandler will send all the syslog entries into the given channel
|
||
|
|
type ChannelHandler struct {
|
||
|
|
channel LogPartsChannel
|
||
|
|
}
|
||
|
|
|
||
|
|
//NewChannelHandler returns a new ChannelHandler
|
||
|
|
func NewChannelHandler(channel LogPartsChannel) *ChannelHandler {
|
||
|
|
handler := new(ChannelHandler)
|
||
|
|
handler.SetChannel(channel)
|
||
|
|
|
||
|
|
return handler
|
||
|
|
}
|
||
|
|
|
||
|
|
//The channel to be used
|
||
|
|
func (h *ChannelHandler) SetChannel(channel LogPartsChannel) {
|
||
|
|
h.channel = channel
|
||
|
|
}
|
||
|
|
|
||
|
|
//Syslog entry receiver
|
||
|
|
func (h *ChannelHandler) Handle(logParts syslogparser.LogParts, messageLength int64, err error) {
|
||
|
|
h.channel <- logParts
|
||
|
|
}
|