gonx

Mar 18, 2021

Changes in this version

type Entry

+ func (entry *Entry) Fields() Fields

+ func (entry *Entry) GetFields() Fields

type Reader

+ func NewParserReader(logFile io.Reader, parser StringParser) *Reader

Dec 19, 2015

Changes in this version

+ type Datetime struct

+ End time.Time

+ Field string

+ Format string

+ Start time.Time

+ func (i *Datetime) Filter(entry *Entry) (validEntry *Entry)

+ func (i *Datetime) Reduce(input chan *Entry, output chan *Entry)

+ type Filter interface

+ Filter func(*Entry) *Entry

+ type StringParser interface

+ ParseString func(line string) (entry *Entry, err error)

Mar 30, 2014

Changes in this version

+ type Avg struct

+ Fields []string

+ func (r *Avg) Reduce(input chan *Entry, output chan *Entry)

+ type Chain struct

+ func NewChain(reducers ...Reducer) *Chain

+ func (r *Chain) Reduce(input chan *Entry, output chan *Entry)

+ type Count struct

+ func (r *Count) Reduce(input chan *Entry, output chan *Entry)

type Entry

+ func NewEmptyEntry() *Entry

+ func NewEntry(fields Fields) *Entry

+ func (entry *Entry) Field(name string) (value string, err error)

+ func (entry *Entry) FieldsHash(fields []string) string

+ func (entry *Entry) FloatField(name string) (value float64, err error)

+ func (entry *Entry) Partial(fields []string) *Entry

+ func (entry *Entry) SetField(name string, value string)

+ func (entry *Entry) SetFloatField(name string, value float64)

+ func (entry *Entry) SetUintField(name string, value uint64)

+ func (master *Entry) Merge(entry *Entry)

+ type Fields map[string]string

+ type GroupBy struct

+ Fields []string

+ func NewGroupBy(fields []string, reducers ...Reducer) *GroupBy

+ func (r *GroupBy) Reduce(input chan *Entry, output chan *Entry)

+ type Sum struct

+ Fields []string

+ func (r *Sum) Reduce(input chan *Entry, output chan *Entry)

Nov 20, 2013

Changes in this version

+ func MapReduce(file io.Reader, parser *Parser, reducer Reducer) interface

type Entry

+ func (entry *Entry) Get(name string) (value string, err error)

+ type Parser struct

+ func NewNginxParser(conf io.Reader, name string) (parser *Parser, err error)

+ func NewParser(format string) *Parser

+ func (parser *Parser) ParseString(line string) (entry Entry, err error)

+ type ReadAll struct

+ func (r *ReadAll) Reduce(input chan Entry, output chan interface{})

+ type Reducer interface

+ Reduce func(input chan Entry, output chan interface{})

Nov 11, 2013

Changes in this version

+ type Entry map[string]string

+ type Reader struct

+ func NewNginxReader(logFile io.Reader, nginxConf io.Reader, formatName string) (reader *Reader, err error)

+ func NewReader(logFile io.Reader, format string) *Reader

+ func (r *Reader) GetFormat() string

+ func (r *Reader) GetFormatRegexp() *regexp.Regexp

+ func (r *Reader) Read() (record Entry, err error)