common

Documentation

Index

• Constants
• Variables
• func InitFlags()
• func Start(name string, logHandler LogHandler)
• func Track(t appinsights.Telemetry)
• func UnescapeCommon(esc string, buf *bytes.Buffer) bool
• type LogControlMessage
• type LogEventMessage
• type LogHandler
• type LogReader
  • func MakeLogReader(infile string) (*LogReader, error)
  • func (logReader *LogReader) Close()
  • func (logReader *LogReader) Events() chan LogEventMessage
  • func (logReader *LogReader) Reset()
• type LogWriter
  • func NewLogWriter(outfile string) (*LogWriter, error)
  • func NewNilLogWriter() *LogWriter
  • func (logWriter *LogWriter) Close()
  • func (logWriter *LogWriter) Reset()
  • func (logWriter *LogWriter) Write(msg string)
• type LogWriterControl
• type LogWriterEvent
• type Parser
  • func NewParser(format string, options *ParserOptions) (*Parser, error)
  • func (parser *Parser) Parse(line string, output ParserResultStorage) error
  • func (parser *Parser) ParseToMap(line string) (map[string]string, error)
• type ParserOptions
• type ParserResultStorage

Constants

const (
	BUF_MAX  = 8192
	CHAN_BUF = 1
)

const UnescapeCommonPattern = `\\([nftbrv\"\\]|[0-7]{1,3}|x[0-9a-fA-F]{2}|u[0-9a-fA-F]{4}|U[0-9a-fA-F]{8})`

Variables

var NO_MATCH error = errors.New("Match not found")

Functions

func InitFlags

func InitFlags()

func Start

func Start(name string, logHandler LogHandler)

func Track

func Track(t appinsights.Telemetry)

func UnescapeCommon

func UnescapeCommon(esc string, buf *bytes.Buffer) bool

Types

type LogControlMessage

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

type LogEventMessage

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

type LogHandler

type LogHandler interface {
	Initialize(*log.Logger) error
	Receive(string) error
}

type LogReader

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

func MakeLogReader

func MakeLogReader(infile string) (*LogReader, error)

func (*LogReader) Close

func (logReader *LogReader) Close()

func (*LogReader) Events

func (logReader *LogReader) Events() chan LogEventMessage

func (*LogReader) Reset

func (logReader *LogReader) Reset()

type LogWriter

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

func NewLogWriter

func NewLogWriter(outfile string) (*LogWriter, error)

func NewNilLogWriter

func NewNilLogWriter() *LogWriter

func (*LogWriter) Close

func (logWriter *LogWriter) Close()

func (*LogWriter) Reset

func (logWriter *LogWriter) Reset()

func (*LogWriter) Write

func (logWriter *LogWriter) Write(msg string)

type LogWriterControl

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

type LogWriterEvent

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

type Parser

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

func NewParser

func NewParser(format string, options *ParserOptions) (*Parser, error)

func (*Parser) Parse

func (parser *Parser) Parse(line string, output ParserResultStorage) error

func (*Parser) ParseToMap

func (parser *Parser) ParseToMap(line string) (map[string]string, error)

type ParserOptions

type ParserOptions struct {
	VariableRegex  string
	EscapeRegex    string
	Unescape       unescapeCallback
	UnwrapVariable unwrapCallback
}

type ParserResultStorage

type ParserResultStorage interface {
	Store(key, value string)
}