syslog

README

go-syslog

Syslog server library for go, build easy your custom syslog server over UDP, TCP or Unix sockets using RFC3164, RFC6587 or RFC5424

Installation

The recommended way to install go-syslog

go get github.com/mcuadros/go-syslog

Examples

How import the package

import "github.com/mcuadros/go-syslog"

Example of a basic syslog UDP server:

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.Boot()

go func(channel syslog.LogPartsChannel) {
    for logParts := range channel {
        fmt.Println(logParts)
    }
}(channel)

server.Wait()

License

MIT, see LICENSE

Documentation

Overview

Syslog server library for go, build easy your custom syslog server over UDP, TCP or Unix sockets using RFC3164 or RFC5424

Index

• type ChannelHandler
  • func NewChannelHandler(channel LogPartsChannel) *ChannelHandler
  • func (self *ChannelHandler) Handle(logParts syslogparser.LogParts, messageLength int64, err error)
  • func (self *ChannelHandler) SetChannel(channel LogPartsChannel)
• type Format
• type Handler
• type LogPartsChannel
• type ScanCloser
• type Server
  • func NewServer() *Server
  • func (self *Server) Boot() error
  • func (self *Server) GetLastError() error
  • func (self *Server) Kill() error
  • func (self *Server) ListenTCP(addr string) error
  • func (self *Server) ListenUDP(addr string) error
  • func (self *Server) ListenUnixgram(addr string) error
  • func (self *Server) SetFormat(format Format)
  • func (self *Server) SetHandler(handler Handler)
  • func (self *Server) SetTimeout(millseconds int64)
  • func (self *Server) Wait()
• type TimeoutCloser

Types

type ChannelHandler

type ChannelHandler struct {
	// contains filtered or unexported fields
}

The ChannelHandler will send all the syslog entries into the given channel

func NewChannelHandler

func NewChannelHandler(channel LogPartsChannel) *ChannelHandler

NewChannelHandler returns a new ChannelHandler

func (*ChannelHandler) Handle

func (self *ChannelHandler) Handle(logParts syslogparser.LogParts, messageLength int64, err error)

Syslog entry receiver

func (*ChannelHandler) SetChannel

func (self *ChannelHandler) SetChannel(channel LogPartsChannel)

The channel to be used

type Format

type Format int

const (
	RFC3164 Format = 1 + iota // RFC3164: http://www.ietf.org/rfc/rfc3164.txt
	RFC5424                   // RFC5424: http://www.ietf.org/rfc/rfc5424.txt
	RFC6587                   // RFC6587: http://www.ietf.org/rfc/rfc6587.txt
)

type Handler

type Handler interface {
	Handle(syslogparser.LogParts, int64, error)
}

The handler receive every syslog entry at Handle method

type LogPartsChannel

type LogPartsChannel chan syslogparser.LogParts

type ScanCloser

type ScanCloser struct {
	*bufio.Scanner
	// contains filtered or unexported fields
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

NewServer returns a new Server

func (*Server) Boot

func (self *Server) Boot() error

Starts the server, all the go routines goes to live

func (*Server) GetLastError

func (self *Server) GetLastError() error

Returns the last error

func (*Server) Kill

func (self *Server) Kill() error

Kill the server

func (*Server) ListenTCP

func (self *Server) ListenTCP(addr string) error

Configure the server for listen on a TCP addr

func (*Server) ListenUDP

func (self *Server) ListenUDP(addr string) error

Configure the server for listen on an UDP addr

func (*Server) ListenUnixgram

func (self *Server) ListenUnixgram(addr string) error

Configure the server for listen on an unix socket

func (*Server) SetFormat

func (self *Server) SetFormat(format Format)

Sets the syslog format (RFC3164 or RFC5424 or RFC6587)

func (*Server) SetHandler

func (self *Server) SetHandler(handler Handler)

Sets the handler, this handler with receive every syslog entry

func (*Server) SetTimeout

func (self *Server) SetTimeout(millseconds int64)

Sets the connection timeout for TCP connections, in milliseconds

func (*Server) Wait

func (self *Server) Wait()

Waits until the server stops

type TimeoutCloser

type TimeoutCloser interface {
	Close() error
	SetReadDeadline(t time.Time) error
}