feat: decode in stream

[json2008]

• [x] PgSource 模块，加入 stream start/stop 相关状态逻辑。
• [x] 实现对 steam events 的正确解码
• [x] 排除虑嵌套事务的极端情形
• [x] 相关流状态情形下的解码测试

[json2008]

@fahchen

已经按 review 意见，做出了修改和调整。空时，请再次 review