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

Commit

Permalink
change the example
Browse files Browse the repository at this point in the history
  • Loading branch information
nstott committed Jul 14, 2015
1 parent 7240629 commit 545ecb8
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions pkg/events/emitter.go
Original file line number Diff line number Diff line change
Expand Up @@ -217,10 +217,8 @@ func NewJsonLogEmitter() *JsonLogEmitter {
// JsonLogEmitter constructs a LogEmitter to use with a transporter pipeline.
// 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 545ecb8

Please sign in to comment.