loggie icon indicating copy to clipboard operation
loggie copied to clipboard

打算新添加一个发送序列号

Open LeiZhang-Hunter opened this issue 3 years ago • 1 comments

功能描述: 每次发送的时候header里会有一个seq序列号,从0 开始逐步累加,不会收到多行等影响,都会加1,切分维度用watchUid

实现: 1、设计一个map,key为watchUid,value为auto计数器 2、在watcher.go里加入回调函数,每次新建文件createOrRename ,则将watchUid加入到对应map中 3、每次删除完成job的时候调用finalizeJob 时候处罚提前埋入的hook,清除掉map上的watchUid 4、hook掉source的productFunc,提前执行埋入的hookFunc再执行后续的productFunc 5、由于map是每个pipeline一分,但是协程时序问题依旧会存在,所以会加锁,加锁会保持最小临界区的原则 6、加入配置开关,可以自由关闭

LeiZhang-Hunter avatar Jul 26 '22 02:07 LeiZhang-Hunter

这个sqe序列号看起来就是lineNumber。貌似就是多行的lineNumber不符合你的需求?

mmaxiaolei avatar Dec 26 '22 06:12 mmaxiaolei