syslog

Documentation

Index

• Constants
• func NewSyslogWriter(in queue.QueueReader, logToFileEnabled, esEnabled bool, directory string, ...) *syslogWriter
• type DailyRotateWriter
  • func NewRotateWriter(filename string) *DailyRotateWriter
  • func (w *DailyRotateWriter) Close() error
  • func (w *DailyRotateWriter) Flush() error
  • func (w *DailyRotateWriter) Write(p []byte) (n int, err error)
• type ESLog
• type ESLogger
  • func NewESLogger(addresses []string, username, password string) *ESLogger
  • func (l *ESLogger) Flush()
  • func (l *ESLogger) Log(esLog *ESLog)

Constants

const (
	ES_APP  = "observatrace_system_log__0_"
	ES_TYPE = "events"

	BULK_SIZE = 8192

	RECONNECT_INTERVAL = time.Minute
)

const (
	LOG_TYPE   = "daemon"
	LOG_MODULE = "trident"
)

const (
	BUFSIZE = 4096
)

const (
	QUEUE_BATCH_SIZE = 1024
)

Functions

func NewSyslogWriter

func NewSyslogWriter(in queue.QueueReader, logToFileEnabled, esEnabled bool, directory string, esAddresses []string, esUsername, esPassword string) *syslogWriter

Types

type DailyRotateWriter

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

func NewRotateWriter

func NewRotateWriter(filename string) *DailyRotateWriter

func (*DailyRotateWriter) Close

func (w *DailyRotateWriter) Close() error

func (*DailyRotateWriter) Flush

func (w *DailyRotateWriter) Flush() error

func (*DailyRotateWriter) Write

func (w *DailyRotateWriter) Write(p []byte) (n int, err error)

type ESLog

type ESLog struct {
	Timestamp uint32 `json:"timestamp"`
	Type      string `json:"type"`
	Host      string `json:"host"`
	Module    string `json:"module"`
	Severity  string `json:"severity"`
	SyslogTag string `json:"syslogtag"`
	Message   string `json:"message"`
}

type ESLogger

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

func NewESLogger

func NewESLogger(addresses []string, username, password string) *ESLogger

func (*ESLogger) Flush

func (l *ESLogger) Flush()

func (*ESLogger) Log

func (l *ESLogger) Log(esLog *ESLog)