文件名称:taskq:具有Redis,SQS,IronMQ和内存后端的Golang异步taskjob队列
文件大小:85KB
文件格式:ZIP
更新时间:2024-02-25 08:01:30
go redis golang queue sqs
具有Redis,SQS,IronMQ和内存后端的Golang异步任务/作业队列 :red_heart: 安装 taskq支持2个最新的Go版本,并且需要具有支持的Go版本。 因此,请确保初始化Go模块: go mod init github.com/my/repo 然后安装taskq / v3(请注意导入中的v3 ;忽略它是一个普遍的错误): go get github.com/vmihailenco/taskq/v3 产品特点 Redis,SQS,IronMQ和内存后端。 自动缩放用于获取(fetcher)和处理消息(worker)的goroutine的数量。 全局速率限制。 全球工人限制。
【文件预览】:
taskq-3
----redisq()
--------queue.go(9KB)
--------factory.go(736B)
----memqueue()
--------queue.go(5KB)
--------memqueue_test.go(11KB)
--------bench_test.go(965B)
--------factory.go(738B)
----go.mod(879B)
----doc.go(109B)
----example_ratelimit_test.go(835B)
----Makefile(228B)
----azsqs_test.go(2KB)
----.travis.yml(341B)
----taskq.go(2KB)
----sysinfo_other.go(85B)
----consumer_test.go(14KB)
----LICENSE(1KB)
----sysinfo_linux.go(459B)
----queue.go(3KB)
----go.sum(19KB)
----handler.go(3KB)
----example_test.go(3KB)
----redisq_test.go(2KB)
----README.md(7KB)
----consumer.go(19KB)
----example()
--------api_worker()
--------sqs_api_worker()
----task.go(3KB)
----registry.go(2KB)
----bench_test.go(938B)
----ironmq_test.go(2KB)
----.golangci.yml(20B)
----extra()
--------taskqotel()
----ironmq()
--------queue.go(6KB)
--------factory.go(935B)
----azsqs()
--------queue.go(12KB)
--------factory.go(916B)
----message.go(5KB)
----consumer_config.go(6KB)
----.prettierrc(34B)
----internal()
--------msgutil()
--------unsafe.go(366B)
--------error.go(161B)
--------util.go(588B)
--------safe.go(156B)
--------log.go(60B)
--------base()