Tsai KD

Thinking about this kind of filter: 1. when receive the new event first time, keep in memory, no output now. 2. when receive the next event, check the key exist...

There are only one input channel `chInFilter` and one output channel `chFilterOut` in a process, and all filters are running in one go-routine, so I think it's ok to be...

In your `Filter 2: aggregate`, it's the decision maker for discarding or not. So I think the better solution is making the filter to discard events (do not dispatch the...

Is your input file huge for each line?

Unfortunately, I cannot reproduce your state with your input file. ``` ➜ gogstash git:(master) ✗ uname -mprsv Darwin 21.6.0 Darwin Kernel Version 21.6.0: Mon Aug 22 20:19:52 PDT 2022; root:xnu-8020.140.49~2/RELEASE_ARM64_T6000...

thx, please check 32f2b15 commit work or not

How about 0253f9f ? I add one more checking before `filepath.EvalSymlinks(fpath)`.

OK, I use a wrap function for all `filepath.EvalSymlinks(fpath)` in 8360d5a .

At the beginning, it's designed to process logs one by one. If you want to handle M inputs and N outputs, M and N are unsigned integers, some interfaces need...

What's you input module? In general case, all input log will be stored in [`message`](https://github.com/tsaikd/gogstash/blob/master/config/logevent/logevent.go#L16) as a TEXT field.