Skip to content
This repository has been archived by the owner on Oct 17, 2023. It is now read-only.

Commit

Permalink
Merge pull request #94 from compose/92-jsonlog
Browse files Browse the repository at this point in the history
92 jsonlog
  • Loading branch information
nstott committed Jul 14, 2015
2 parents 5f4ec52 + 545ecb8 commit dfb4fba
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions pkg/events/emitter.go
Original file line number Diff line number Diff line change
Expand Up @@ -215,12 +215,10 @@ func NewJsonLogEmitter() *JsonLogEmitter {
}

// JsonLogEmitter constructs a LogEmitter to use with a transporter pipeline.
// A LogEmitter listens on the event channel and uses go's log package to emit the event,
// A JsonLogEmitter listens on the event channel and uses go's log package to emit the event,
// eg.
// 2014/11/28 16:56:58 boot map[source:mongo out:mongo]
// 2014/11/28 16:56:58 metrics source recordsIn: 0, recordsOut: 203
// 2014/11/28 16:56:58 exit
// 2014/11/28 16:56:58 metrics source/out recordsIn: 203, recordsOut: 0
// 2015/07/14 11:52:01 {"ts":1436889121,"name":"metrics","path":"source-development.jobs/dest-x.jobs","records":121}
// 2015/07/14 11:52:01 {"ts":1436889121,"name":"exit","version":"0.0.4","endpoints":{"dest-x.jobs":"mongo","source-development.jobs":"mongo"}}
type JsonLogEmitter struct {
chstop chan chan bool
ch chan Event
Expand Down

0 comments on commit dfb4fba

Please sign in to comment.