garoa:Go中可扩展的高度并发管道

时间:2024-05-29 02:49:30
【文件属性】:

文件名称:garoa:Go中可扩展的高度并发管道

文件大小:5KB

文件格式:ZIP

更新时间:2024-05-29 02:49:30

Go

加罗阿 garoa是一个库,它提供了一种可扩展的方式来将不同的功能插入多个步骤。 每个步骤都有其自己的并行度(又称工人数),并且通信是通过渠道在内部完成的。 这些功能唯一需要做的就是接受一个interface{} (也叫任何东西),并且还返回一个错误的interface{} 。 这可以封装更复杂的域操作。 Garoa用葡萄牙语意味小雨。 该软件的灵感来自Apache Storm(分布式计算框架)。 由Mendelics的Igor Correa和Vitor De Mario构思。 用法示例 convertJSON := func(i interface{}) (interface{}, error) { converted, err := json.Marshal(i) if err != nil { log.Println("json err", e


【文件预览】:
garoa-master
----builder.go(3KB)
----README.md(2KB)
----builder_test.go(10KB)
----signal.go(36B)
----.gitignore(6B)
----pipeline.go(2KB)

网友评论