metafora:Go中分布式的长期运行的工作系统 源码

元论坛 Metafora是一个库,旨在在集群中运行长时间运行(分钟到永久)的任务。 IRC: #lytics/metafora上的 #lytics/metafora 特征 分布式-水平可扩展 弹性-通过自动重新平衡来调整在线群集的大小 无主-窃取工作,不分配工作,可插入平衡 容错-如果节点消失则重新分配任务 简单-状态少,无需检查点,无需配置管理 可扩展-定义明确的接口,用于实现平衡和协调 恰好一次-旨在强制每个提交的任务的一个实例正在运行 Metafora是用于构建分布式任务工作系统的库。 您负责为应用程序创建main()入口点,编写metafora.Handler和HandlerFunc以实际处理任务,然后启动Metafora的Consumer 。 Metafora的任务状态机被实现为Handler适配器。 简单地实现你的任务处理器作为功能,并创建一个metafora.Han