文件名称：go-streams:Go的轻量级流处理库
文件大小：116KB
文件格式：ZIP
更新时间：2024-05-25 23:01:01
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)