(r baker.Record, next func(baker.Record))
| 94 | } |
| 95 | |
| 96 | func (f *Crypt) Process(r baker.Record, next func(baker.Record)) { |
| 97 | newVal, err := f.transformFn(r.Get(f.src)) |
| 98 | if err != nil { |
| 99 | log.Errorf("can't process line: %v", err) |
| 100 | atomic.AddInt64(&f.numFilteredLines, 1) |
| 101 | return |
| 102 | } |
| 103 | |
| 104 | r.Set(f.dst, newVal) |
| 105 | next(r) |
| 106 | } |
| 107 | |
| 108 | type cryptFernet struct { |
| 109 | key *fernet.Key |