ReceiveSyslog

README

Receive Syslog trigger

This trigger receives syslog messages.

installation

flogo install github.com/TIBCOSoftware/lmi-flogo-collectors/ReceiveSyslog

Settings

Trigger

Setting	Description
protocol	protocol to use, only tcp is supported at the moment
port	port to bind for listening to incoming syslog messages

Handler

Setting	Description
regex	Filter messages (not implemented yet)

Schema

name	type	Description
body	string	The whole message received
severity	integer	The severity
facility	integer	The facility
sourceIP	string	The source of the syslog connection
source	string	The source from the syslog header
eventTime	long	The time of the message as a UNIX timestamp
message	string	The syslog message without its header

Notes

Only Syslog in RFC 3164 format is properly supported right now

Documentation

Index

• Constants
• func NewFactory(md *trigger.Metadata) trigger.Factory
• type ServerTCP
  • func (s *ServerTCP) Start() error
  • func (s *ServerTCP) Stop() error
• type SyslogFactory
  • func (t *SyslogFactory) New(config *trigger.Config) trigger.Trigger
• type SyslogTrigger
  • func (t *SyslogTrigger) Initialize(ctx trigger.InitContext) error
  • func (t *SyslogTrigger) Metadata() *trigger.Metadata
  • func (t *SyslogTrigger) Start() error
  • func (t *SyslogTrigger) Stop() error

Constants

const DATE_FORMAT_SYSLOG_3164 = "Jan 02 15:04:05"

Functions

func NewFactory

func NewFactory(md *trigger.Metadata) trigger.Factory

NewFactory create a new Trigger factory

Types

type ServerTCP

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

func (*ServerTCP) Start

func (s *ServerTCP) Start() error

func (*ServerTCP) Stop

func (s *ServerTCP) Stop() error

type SyslogFactory

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

SyslogFactory Syslog Trigger factory

func (*SyslogFactory) New

func (t *SyslogFactory) New(config *trigger.Config) trigger.Trigger

New Creates a new trigger instance for a given id

type SyslogTrigger

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

func (*SyslogTrigger) Initialize

func (t *SyslogTrigger) Initialize(ctx trigger.InitContext) error

func (*SyslogTrigger) Metadata

func (t *SyslogTrigger) Metadata() *trigger.Metadata

Metadata implements trigger.Trigger.Metadata

func (*SyslogTrigger) Start

func (t *SyslogTrigger) Start() error

func (*SyslogTrigger) Stop

func (t *SyslogTrigger) Stop() error

Stop implements util.Managed.Stop