htjson

Documentation

Overview

Package htjson (honeytail-json, renamed to not conflict with the json module) parses logs that are one json blob per line.

Index

• type JSONLineParser
  • func (j *JSONLineParser) ParseLine(line string) (map[string]interface{}, error)
• type Options
• type Parser
  • func (p *Parser) Init(options interface{}) error
  • func (p *Parser) ProcessLines(lines <-chan string, send chan<- event.Event, prefixRegex *parsers.ExtRegexp)

Types

type JSONLineParser

type JSONLineParser struct {
}

func (*JSONLineParser) ParseLine

func (j *JSONLineParser) ParseLine(line string) (map[string]interface{}, error)

ParseLine will unmarshal the thing it read in to detect errors in the JSON (by failing to parse) and give us an object that can be mutated by the various filters honeytail might apply.

type Options

type Options struct {
	TimeFieldName   string `long:"timefield" description:"Name of the field that contains a timestamp" yaml:"timefield,omitempty"`
	TimeFieldFormat string `` /* 138-byte string literal not displayed */

	NumParsers int `hidden:"true" description:"number of htjson parsers to spin up" yaml:"-"`
}

type Parser

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

func (*Parser) Init

func (p *Parser) Init(options interface{}) error

func (*Parser) ProcessLines

func (p *Parser) ProcessLines(lines <-chan string, send chan<- event.Event, prefixRegex *parsers.ExtRegexp)