mongodb

Documentation

Index

• type MongodbProfile
  • func (p *MongodbProfile) HandleOutput(records <-chan interface{}, dryRun bool) <-chan error
  • func (p *MongodbProfile) Init() error
  • func (p *MongodbProfile) Name() string
  • func (p *MongodbProfile) ProcessRecord(line string) (interface{}, error)

Types

type MongodbProfile

type MongodbProfile struct {
	Logger *log.Logger
}

MongodbProfile is the profile used to parse mongodb logs. Output is JSON

func (*MongodbProfile) HandleOutput

func (p *MongodbProfile) HandleOutput(records <-chan interface{}, dryRun bool) <-chan error

HandleOutput satisfies part of the profile.Profile interface, converting lines to JSON and printing to stdout

func (*MongodbProfile) Init

func (p *MongodbProfile) Init() error

Init performs startup steps for the MongodbProfile

func (*MongodbProfile) Name

func (p *MongodbProfile) Name() string

Name returns the name of the profile and must be unique amongst registered. profiles

func (*MongodbProfile) ProcessRecord

func (p *MongodbProfile) ProcessRecord(line string) (interface{}, error)

ProcessRecord is invoked for every input log line. It returns a transformed. line or an error