文件名称：go-workers2:上班族
文件大小：55KB
文件格式：ZIP
更新时间：2024-05-26 08:36:26
Go
兼容背景工人 。 使用对所有队列进行可靠的排队 处理重试 支持自定义中间件 自定义每个队列的并发 响应Unix信号以安全地等待作业完成后再退出。 提供有关当前正在运行的作业的统计信息 Redis哨兵支持 经过良好测试 用法示例： package main import ( "fmt" workers "github.com/digitalocean/go-workers2" ) func myJob ( message * workers. Msg ) error { // do something with your message // message.Jid() // message.Args() is a wrapper around go-simplejson (http://godoc.org/github.com/bitly/go-simplejso
【文件预览】：
go-workers2-master
----fetcher_test.go(4KB)
----go.mod(896B)
----middleware_retry_test.go(7KB)
----signals_windows.go(408B)
----.github()
--------workflows()
----middleware_stats_test.go(2KB)
----go.sum(39KB)
----api_server.go(2KB)
----LICENSE.txt(1KB)
----worker_test.go(5KB)
----task_runner.go(1KB)
----middleware_logging.go(1KB)
----middleware.go(1KB)
----options.go(3KB)
----scheduled.go(1KB)
----manager.go(6KB)
----producer_test.go(6KB)
----producer.go(4KB)
----api_stats.go(1KB)
----middleware_retry.go(3KB)
----fetcher.go(3KB)
----README.md(4KB)
----middleware_test.go(2KB)
----Makefile(593B)
----middleware_stats.go(774B)
----msg_test.go(767B)
----task_runner_test.go(2KB)
----scheduled_test.go(1KB)
----api_stats_test.go(326B)
----signals_posix.go(433B)
----worker.go(2KB)
----.gitignore(24B)
----storage()
--------storage.go(2KB)
--------redis.go(5KB)
----options_test.go(4KB)
----cmd()
--------stats.go(715B)
--------gwctl()
--------root.go(1KB)
--------retries.go(747B)
----msg.go(2KB)
----api_retries.go(2KB)
----all_specs_test.go(1KB)
----api_retries_test.go(2KB)
----manager_test.go(8KB)