casper:基于流的编程框架

时间:2024-07-08 09:40:28
【文件属性】:

文件名称:casper:基于流的编程框架

文件大小:26KB

文件格式:ZIP

更新时间:2024-07-08 09:40:28

Go

casper Obsoleted project, please move the new porject: github.com/gogap/spirit 该项目已废弃,请移步到 github.com/gogap/spirit A FBP framwoker 一个组件,可以实现一个业务功能, 也可以实现多个。 一条消息,可以流经任意多个组件。 组件加工消息并传递, 同时跟据消息触发业务逻辑。 每个组件,可以配置成一个一般业务组件, 也可以配置成为一个服务。 服务本身也是一个组件。 服务相对一般组件所增加的功能, 就是:可以接收外部请求。 服务可以向外提供很多不同的具体"服务". 每个具体服务对应一条具体的消息格式, 和, 一串业务组件调用链. "graph"定义此链。 现在实现的zmq的消息方式, HTTP和zmq的服务.


【文件预览】:
casper-master
----example()
--------com.go(839B)
--------handler_rotator.conf.example(94B)
--------app.go(174B)
--------example.go(141B)
--------syncZmqClient.go(355B)
--------casper.conf.example(2KB)
--------syncZmqServer.go(380B)
--------handler_rotator.go(868B)
--------.gitignore(4B)
--------component.conf.example(562B)
----entrance.go(805B)
----message_bridge.go(4KB)
----mq.go(1KB)
----single_instance.go(726B)
----mq_zmq.go(2KB)
----LICENSE(11KB)
----entrance_martini.go(9KB)
----entrance_factory.go(1KB)
----handler_rotator.go(2KB)
----.gitignore(266B)
----errorcode()
--------errors.go(3KB)
----component_message.go(10KB)
----component.go(7KB)
----entrance_zmq.go(4KB)
----README.md(821B)
----utils()
--------utils.go(557B)
----casper.go(3KB)

网友评论