(r baker.Record, next func(baker.Record))
| 102 | } |
| 103 | |
| 104 | func (h *Hash) Process(r baker.Record, next func(baker.Record)) { |
| 105 | hashed, err := h.hash(r.Get(h.src)) |
| 106 | if err != nil { |
| 107 | log.Errorf("can't process record, hashing failed: %v", err) |
| 108 | atomic.AddInt64(&h.numFilteredLines, 1) |
| 109 | return |
| 110 | } |
| 111 | |
| 112 | encoded, err := h.encode(hashed) |
| 113 | if err != nil { |
| 114 | log.Errorf("can't process record, encoding failed: %v", err) |
| 115 | atomic.AddInt64(&h.numFilteredLines, 1) |
| 116 | return |
| 117 | } |
| 118 | |
| 119 | r.Set(h.dst, encoded) |
| 120 | next(r) |
| 121 | } |