文件名称:gocelery:go语言的分布式计算系统(python中的Celery go实现)
文件大小:49KB
文件格式:ZIP
更新时间:2024-03-31 13:31:13
系统开源
芹菜 go语言的分布式计算系统(python中的Celery go实现) 项目介绍 项目结构 ├──a-test| #接口测试文件 ├── backends # 数据结构处理代码段 ├── brokers # 消息任务队列 ├── common # 公共部分 ├── config # 项目配置代码单 ├── log # 日志 ├── retry # 任务重发处理 ├── tasks # 消息任务处理 ├── tracing # ├── server.go # 消费者 ├── worker.go # 生产者 项目简介 简介:Gocelery是分布式的初始任务类别,远程调度任务的。 实现方式:Gocelery主要是通过中间人来实现远程调度的,中间Redis服务支持远程访问,生产者将任务redis消息任务,
【文件预览】:
gocelery-master
----.gitignore(7B)
----go.mod(426B)
----tracing()
--------tracing.go(3KB)
----worker.go(8KB)
----retry()
--------fibonacci.go(234B)
--------retry.go(397B)
----server.go(5KB)
----log()
--------log.go(12B)
----a-test()
--------redis_test.go(909B)
--------grpc_test.go(441B)
----go.sum(36KB)
----README.md(3KB)
----brokers()
--------errs()
--------iface()
--------redis()
--------amqp()
--------eager()
----config()
--------env.go(15B)
--------file.go(15B)
--------config.go(3KB)
----backends()
--------iface()
--------memcache()
--------redis()
--------result()
--------mongo()
----factories.go(4KB)
----common()
--------redis.go(2KB)
--------backend.go(297B)
--------amqp.go(3KB)
--------broker.go(2KB)
----tasks()
--------reflect.go(8KB)
--------state.go(2KB)
--------signature.go(1KB)
--------result.go(856B)
--------task.go(2KB)
--------workflow.go(2KB)
--------errors.go(506B)
--------vilidate.go(625B)