没有合适的资源?快使用搜索试试~ 我知道了~
dagger:动态分散式实时流处理框架
共56个文件
go:45个
md:2个
makefile:2个
需积分: 9 0 下载量 117 浏览量
2021-05-10
15:59:27
上传
评论
收藏 72KB ZIP 举报
温馨提示
Dagger是基于发布和订阅数据流的动态实时流处理框架。 如果有人真正订阅并使用该计算,则仅对一个或多个数据流执行计算。 例如,将数据流持久保存到DB的过程订阅了节点的CPU利用率流(平均每分钟1分钟)。 这意味着只要该进程在运行,平均每分钟CPU使用率的计算就会运行。 当管理员打开一个仪表板以显示5秒钟内平均CPU利用率的实时图表时,第二次计算将启动,这将提供5秒钟内的平均CPU利用率。 当管理员关闭仪表板时,计算将关闭,因为不再有人对其数据感兴趣。 这样,仅在必要时才进行网络上的计算和数据传输,从而节省了计算周期并减少了网络流量。 该软件是正在制作的原型。 它是为我的而开发。 特性 多语言插件 可以使用任何语言编写用于流处理的插件,并通过JSON-RPC进行接口。 恰好一次交货 确保使用重试和有效的重复数据删除。 时间戳排序的处理 即使在处理来自不同流的记录时,Dagger也
资源推荐
资源详情
资源评论
收起资源包目录
dagger-master.zip (56个子文件)
dagger-master
client
client.go 2KB
computations
computation-count
count.go 3KB
computation-foo
foo.go 1KB
computation-sum
sum.go 3KB
computation-alarm
parser.go 42KB
parser_test.go 2KB
parser.peg 2KB
tree.go 2KB
Makefile 48B
alarm.go 5KB
computation-max
max.go 3KB
computation.go 2KB
computation-bar
bar.go 964B
computation-avg
avg.go 3KB
computation-min
min.go 3KB
time_buckets.go 3KB
contributors.txt 10B
command
worker.go 2KB
config.go 4KB
subscriber.go 3KB
producer.go 2KB
signal.go 494B
httpapi.go 1KB
producers
producer-test
test.go 646B
producer.go 894B
dagger
http_api.go 6KB
lwm_tracker.go 2KB
mocks.go 12KB
receiver.go 5KB
persister_test.go 351B
deduplicator.go 1KB
tasks.go 6KB
deduplicator_test.go 1KB
shared_structs.go 2KB
coordinator.go 4KB
match.go 3KB
dispatcher.go 10KB
config.go 396B
consul_test.go 6KB
tuple_processor.go 1KB
computations.go 8KB
tasks_test.go 2KB
consul.go 18KB
match_test.go 2KB
linearizer.go 3KB
persister.go 9KB
coordinator_test.go 5KB
Dockerfile 277B
Dockerfile.scratch 59B
main.go 346B
docker-compose.yml 356B
LICENSE.md 1KB
.gitignore 7B
run_consul_dev.sh 152B
Makefile 503B
README.md 8KB
共 56 条
- 1
资源评论
活宝spring
- 粉丝: 28
- 资源: 4686
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功