文件名称：stream-replicator:NATS 流主题复制器
文件大小：221KB
文件格式：ZIP
更新时间：2024-06-19 23:29:39
Go
NATS 流主题复制器 这是一个在 NATS Streaming 服务器中消耗 1 个主题并将其复制到另一个 NATS Streaming 服务器的工具。 特征 保留单个工作线程主题复制的顺序 用于无序复制的垂直和水平可扩展的工作池 过滤掉类似数据的高频更新，以减少多站点中的流量，为单个全球商店场景提供服务。 可以选择以 Prometheus 格式公开有关性能和吞吐量的指标 当未排队设置中只有 1 个工作人员时，这将使用生成的名称或您配置的名称在源 NATS 流中创建持久订阅。 当有许多工作人员或它被指定属于一个队列组时，将使用生成的名称或您指定的名称创建持久队列组。 第一次连接时，它会尝试复制所有消息，因为订阅是 Durable 的，它将从那时起从停止的地方继续。 地位 这是一个相当新的项目，正在生产中使用，但由于它是新项目，因此请谨慎使用。 我希望您能获得任何反馈——尤其是关于多
【文件预览】：
stream-replicator-master
----dashboard.json(13KB)
----backoff()
--------backoff.go(1KB)
----config()
--------testdata()
--------tlsconf.go(1KB)
--------topicconf.go(1KB)
--------config_test.go(1KB)
--------config.go(2KB)
----cmd()
--------advisory-watch()
--------cmd.go(4KB)
----puppet()
--------manifests()
--------templates()
--------data()
--------hiera.yaml(273B)
--------metadata.json(1KB)
--------types()
--------README.md(3KB)
----limiter()
--------limiter.go(1KB)
--------memory()
----Rakefile(1KB)
----advisor()
--------advisor.go(7KB)
--------advisor_test.go(4KB)
--------stats.go(1KB)
----LICENSE(11KB)
----packager()
--------templates()
--------buildspec.yaml(886B)
----main.go(94B)
----stream-replicator.png(158KB)
----.gitignore(121B)
----CHANGELOG.md(6KB)
----.circleci()
--------config.yml(4KB)
----go.sum(44KB)
----README.md(17KB)
----connector()
--------connector.go(6KB)
--------subscription.go(583B)
--------test()
--------connector_test.go(2KB)
--------stats.go(1KB)
----replicator()
--------worker.go(3KB)
--------replicator.go(3KB)
--------stats.go(2KB)
----go.mod(576B)