【文件属性】：
文件名称：go-streams:Go的轻量级流处理库
文件大小：116KB
文件格式：ZIP
更新时间：2021-05-06 05:14:21
redis kafka pipeline etl websocket
流媒体
Go的轻量级流处理库。 go-streams提供了一个简单而简洁的DSL来构建数据管道。
在计算中，管线（也称为数据管线）是一组串联连接的数据处理元素，其中一个元素的输出是下一个元素的输入。 流水线的元素通常以并行或按时间分割的方式执行。 通常在元素之间插入一定数量的缓冲区存储。
概述
建筑模块：
源-源是一组具有一个开放输出的流处理步骤。
流-流是一组具有一个打开的输入和一个打开的输出的流处理步骤。
接收器-接收器是一组具有一个开放输入的流处理步骤。 可以用作订阅服务器。
流功能（包）：
地图
平面图
筛选
直通
分裂
扇出
合并
节流阀
滑动窗口
翻滚窗口
支持的连接器：
前往频道
文件系统
网络（TCP，UDP）
WebSocket
例子
使用示例可在examples目录中找到。
执照
根据MIT许可获得许可。
【文件预览】：
go-streams-master
----pulsar()
--------doc.go(73B)
--------go.sum(24KB)
--------pulsar.go(3KB)
--------go.mod(143B)
----.travis.yml(194B)
----ws()
--------doc.go(61B)
--------web_socket.go(3KB)
--------go.sum(348B)
--------go.mod(133B)
----docs()
--------images()
----doc.go(81B)
----aerospike()
--------doc.go(84B)
--------aerospike.go(6KB)
--------go.sum(7KB)
--------go.mod(394B)
----.github()
--------PULL_REQUEST_TEMPLATE.md(113B)
----flow()
--------queue.go(2KB)
--------flow_test.go(3KB)
--------doc.go(68B)
--------map.go(2KB)
--------pass_through.go(1KB)
--------tumbling_window.go(2KB)
--------flat_map.go(2KB)
--------filter.go(2KB)
--------sliding_window.go(4KB)
--------throttler.go(3KB)
--------util.go(2KB)
----LICENSE(1KB)
----extension()
--------doc.go(81B)
--------net.go(4KB)
--------chan.go(922B)
--------fs.go(2KB)
--------std.go(1005B)
----CONTRIBUTING.md(1KB)
----examples()
--------pulsar()
--------ws()
--------std()
--------aerospike()
--------net()
--------fs()
--------kafka()
--------redis()
--------go.sum(39KB)
--------nats()
--------go.mod(948B)
----kafka()
--------doc.go(70B)
--------go.sum(8KB)
--------kafka_sarama.go(4KB)
--------go.mod(134B)
----.gitignore(24B)
----streams.go(711B)
----redis()
--------doc.go(71B)
--------redis.go(2KB)
--------go.sum(7KB)
--------go.mod(235B)
----go.sum(0B)
----README.md(2KB)
----util()
--------doc.go(57B)
--------ospkg()
--------util.go(349B)
----nats()
--------doc.go(70B)
--------nats_stan.go(3KB)
--------go.sum(16KB)
--------go.mod(290B)
----go.mod(44B)