parser

Documentation

Index

• Variables
• func IsValidParser(parserType string) bool
• type JsonParser
  • func NewJsonParser(config JsonParserConfig) (*JsonParser, error)
  • func (p *JsonParser) Parse(log *types.Log) error
• type JsonParserConfig
• type Parser
  • func NewParsers(parserTypes []string, source string) []Parser
• type ParserConfig
• type ParserType

Variables

var (
	ErrNotString = errors.New("no string in log body")
	ErrNotJson   = errors.New("no json object in log body")
)

Functions

func IsValidParser

func IsValidParser(parserType string) bool

Types

type JsonParser

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

func NewJsonParser

func NewJsonParser(config JsonParserConfig) (*JsonParser, error)

func (*JsonParser) Parse

func (p *JsonParser) Parse(log *types.Log) error

Attempts to parse the message as JSON and adds the parsed fields to the log body. Not safe for concurrent use.

type JsonParserConfig

type JsonParserConfig struct {
}

type Parser

type Parser interface {
	Parse(*types.Log) error
}

Parser is the interface for parsing log messages.

func NewParsers

func NewParsers(parserTypes []string, source string) []Parser

NewParsers creates a list of valid parser instances. Invalid parsers or those that cannot be created will be skipped with warning logs including the source string.

type ParserConfig

type ParserConfig struct {
	Type ParserType
}

ParserConfig is a structure used in configs for creating parsers instances.

type ParserType

type ParserType string

const ParserTypeJson ParserType = "json"