文件名称：curlyq:Go的高效可靠的后台处理
文件大小：39KB
文件格式：ZIP
更新时间：2024-04-10 04:21:53
go redis golang background-jobs background-worker
CurlyQ CurlyQ提供了一个简单易用的界面，用于在Go中执行后台处理。它开箱即用地支持计划的作业，重复数据删除和可配置的并发执行。 快速开始 package main import ( "context" "log" cq "github.com/mcmathja/curlyq" ) func main () { // Create a new producer producer := cq . NewProducer ( & cq. ProducerOpts { Address : "localhost:6379" , Queue : "testq" , }) // Use the producer to push a job to the queue producer . Perform (cq. Job { Data : [] byte ( "S
【文件预览】：
curlyq-master
----.travis.yml(170B)
----queue.go(1KB)
----job_test.go(2KB)
----errors_test.go(2KB)
----job.go(476B)
----consumer_test.go(55KB)
----curlyq_test.go(234B)
----scripts.go(583B)
----errors.go(2KB)
----scripts_test.go(747B)
----LICENSE(1KB)
----producer_test.go(14KB)
----logger.go(2KB)
----lua()
--------kill_job.lua(524B)
--------register_consumer.lua(234B)
--------reenqueue_orphaned_jobs.lua(1KB)
--------get_jobs.lua(995B)
--------enqueue_scheduled_jobs.lua(687B)
--------retry_job.lua(533B)
--------reenqueue_active_jobs.lua(535B)
--------schedule_job.lua(459B)
--------ack_job.lua(347B)
--------push_job.lua(542B)
----logger_test.go(4KB)
----pkged.go(8KB)
----producer.go(5KB)
----.gitignore(269B)
----Makefile(218B)
----consumer.go(23KB)
----go.sum(8KB)
----README.md(5KB)
----queue_test.go(896B)
----go.mod(319B)