syslog

package
v0.0.0-...-433f197 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 5, 2016 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LainProcInfo

type LainProcInfo struct {
	AppName     string `json:"app"`
	ProcName    string `json:"proc"`
	NodeName    string `json:"nodename"`
	NodeIP      string `json:"nodeip"`
	ContainerIP string `json:"ip"`
	Port        int    `json:"port"`
	InstanceNo  int    `json:"instanceNo"`
}

type ProcLogItem

type ProcLogItem struct {
	Priority    int       `json:"priority"`
	Hostname    string    `json:"hostname"`
	Message     string    `json:"message"`
	Pid         int       `json:"pid"`
	Timestamp   time.Time `json:"timestamp"`
	ContainerId string    `json:"container_id"`
	LogFile     string    `json:"log_file"`
	ProcName    string    `json:"proc_name"`
	ProcAppName string    `json:"app_name"`
	ContainerIP string    `json:"container_ip"`
	InstanceNo  int       `json:"instance_no"`
}

type SyslogLainEncoder

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

func (*SyslogLainEncoder) Encode

func (enc *SyslogLainEncoder) Encode(pack *pipeline.PipelinePack) ([]byte, error)

func (*SyslogLainEncoder) Init

func (enc *SyslogLainEncoder) Init(config interface{}) error

func (*SyslogLainEncoder) ReportMsg

func (enc *SyslogLainEncoder) ReportMsg(msg *message.Message) error

type SyslogLainFilter

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

func (*SyslogLainFilter) CleanUp

func (f *SyslogLainFilter) CleanUp()

func (*SyslogLainFilter) ConfigStruct

func (f *SyslogLainFilter) ConfigStruct() interface{}

func (*SyslogLainFilter) Init

func (f *SyslogLainFilter) Init(config interface{}) error

func (*SyslogLainFilter) Prepare

func (*SyslogLainFilter) ProcessMessage

func (f *SyslogLainFilter) ProcessMessage(pack *pipeline.PipelinePack) error

func (*SyslogLainFilter) ReportMsg

func (f *SyslogLainFilter) ReportMsg(msg *message.Message) error

type SyslogLainFilterConfig

type SyslogLainFilterConfig struct {
	MsgType        string `toml:"message_type"`
	LainletAddress string `toml:"lainlet_address"`
	NodeName       string `toml:"nodename"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL