文件名称：Go-amazonriver是一个将postgresql的实时数据同步到es或kafka的服务
文件大小：296KB
文件格式：ZIP
更新时间：2022-09-02 21:11:13
Go开发-消息系统
amazonriver 利用pg内部的逻辑复制功能,通过在pg创建逻辑复制槽,接收数据库的逻辑变更,通过解析test_decoding特定格式的消息,得到逻辑数据
【文件预览】：
hellobike-amazonriver-0d49706
----.circleci()
--------config.yml(1KB)
----.gitignore(3KB)
----main.go(1KB)
----monitor()
--------prometheus.go(2KB)
----README.md(2KB)
----conf()
--------conf.go(3KB)
----log()
--------log.go(807B)
----LICENSE(11KB)
----model()
--------decode_test.go(3KB)
--------wal_test.go(2KB)
--------wal.go(1KB)
--------decode.go(2KB)
--------consts.go(1KB)
----glide.lock(3KB)
----glide.yaml(722B)
----dump()
--------parser.go(3KB)
--------parser_test.go(2KB)
--------dump.go(2KB)
----handler()
--------output()
--------handlerWrapper.go(3KB)
--------handler.go(1KB)
----doc()
--------test.md(2KB)
--------prometheus.md(1KB)
--------pg.md(466B)
--------grafana.png(192KB)
--------arch.png(136KB)
--------kafka.md(1KB)
--------es.md(2KB)
----README_EN.md(1KB)
----river()
--------stream.go(6KB)
--------amazon.go(2KB)
----util()
--------wildcard.go(2KB)
--------retry.go(935B)
--------hack_test.go(2KB)
--------retry_test.go(1KB)
--------wildcard_test.go(13KB)
--------hack.go(977B)