文件名称：substrate:Go的消息代理抽象
文件大小：74KB
文件格式：ZIP
更新时间：2024-06-09 04:02:03
Go
基质 底物是用于消息发布和使用的简单的薄抽象。 它提供了一个简单的API集，用于在多种后端消息代理类型上进行持久，最少一次的消息发布和订阅。 API尚未稳定。 当前的实现及其状态 执行 地位 阿帕奇·卡夫卡（Apache Kafka） 贝塔 Nats串流 贝塔 普罗西莫 α 冰箱 α 额外资源 -提供用于各种任务（例如，确认订单和检测）的包装材料和包装。
【文件预览】：
substrate-master
----go.mod(929B)
----suburl()
--------doc.go(1KB)
--------sink.go(1KB)
--------source.go(976B)
----sync_adapter_source.go(1KB)
----instrumented()
--------sink_test.go(6KB)
--------source_test.go(4KB)
--------sink.go(2KB)
--------source.go(2KB)
----go.sum(46KB)
----kafka()
--------url_test.go(4KB)
--------producer.go(4KB)
--------consumer.go(4KB)
--------doc.go(1KB)
--------integration_test.go(6KB)
--------url.go(2KB)
--------consumer_group_handler.go(5KB)
--------status.go(1KB)
----substrate.go(5KB)
----sync_adapter_sink.go(4KB)
----internal()
--------helper()
--------debug()
--------testshared()
--------unwrap()
----LICENSE(1KB)
----README.md(1KB)
----sync_adapter_source_test.go(3KB)
----freezer()
--------freezer_url.go(4KB)
--------freezer_url_test.go(4KB)
--------doc.go(974B)
--------freezer.go(5KB)
--------integration_test.go(1KB)
----sync_adapter_sink_test.go(2KB)
----proximo()
--------proximo_source.go(4KB)
--------proximo_sink.go(5KB)
--------proximo_url.go(3KB)
--------doc.go(1KB)
--------integration_test.go(2KB)
--------proximo_url_test.go(6KB)
--------proximo.go(3KB)
----natsstreaming()
--------nats_streaming_url.go(3KB)
--------doc.go(1KB)
--------nats_streaming.go(7KB)
--------integration_test.go(7KB)
--------nats_streaming_url_test.go(5KB)
--------status.go(515B)
----noop()
--------noop_url_test.go(726B)
--------noop_sink_test.go(747B)
--------noop_sink.go(973B)
--------noop_url.go(272B)