golang-queue / queue Goto Github PK

View Code? Open in Web Editor NEW

403.0 403.0 38.0 2.3 MB

Queue is a Golang library for spawning and managing a Goroutine pool

License: MIT License

Go 75.98% D2 24.02%

queue's People

Contributors

Stargazers

Watchers

queue's Issues

[API] Update worker count dynamically.

Support request timeout setting.

Support Retry and Retry delay config.

Stop retry task when shutdown the service or timeout.

Check worker count before start request task.

	// define the queue
	q := queue.NewPool(
		0,
		queue.WithWorker(w),
	)

Wait local channel queue empty before restarting the queue service.

We create the local queue using a buffer channel by default, the queues should be clear before restarting the service.

Support NSQ Platform

Support Nats (Connective Technology for Adaptive Edge & Distributed Systems) platform

RabbitMQ support

Handle all jobs with graceful shutdown

Support Retry with exponential backoff time duration.

Support task function

Provide the following solution only for the simple queues.

type TaskFunc func(context.Context) error

Durable state using coroutines

hey @appleboy

this looks like its highly relevant https://github.com/stealthrocket/coroutine/

It can rehydrate state between processes too !

"go get" (install) on this repository is throwing build error on "!errors.Is(...)" - is it my go version?

Hi,

Doing a "go get" (install) on this repository is throwing build errors on "!errors.Is(...)" - is it my go version?

I've got an older version of Go: go.1.12.1 (win/amd64) - is "errors.Is()" more recent?

I'm relatively new to Go, so please point me in the right direction if I'm being silly...

Thanks.

EDIT: Oh my... I just found out that go1.13 added error.Is() LOL!!!

Any sage advice on a workaround? I'm stuck with 1.12 for now. I'll try to edit the local source in the meantime.

Add default timeout in Request

Handle All Job Before Shutdown Consumer In Queue

Support Job Timeout.

Simple Queue. #17
NSQ #25
NATS #26

Feature: Add SuccessTasks, FailureTasks and SubmittedTasks number in Metrics.

Pass stop channel to Runtime func

notice runner that queue has been shut down.

Kafka support

redis stream as backend example not found

github.com/golang-queue/redisdb. 中好像只有看到 pub sub 相關的 function , 請問要如何使用 redis streams as backend , 謝謝.

data race since v0.2.0

WARNING: DATA RACE
Read at 0x00c000218c70 by goroutine 1770:
  github.com/golang-queue/queue.(*Ring).Request()
      /home/github-runner/actions-runner/_work/vendor/github.com/golang-queue/queue/ring.go:78 +0xa4
  github.com/golang-queue/queue.(*Queue).start.func1()
      /home/github-runner/actions-runner/_work/vendor/github.com/golang-queue/queue/queue.go:301 +0x77
  github.com/golang-queue/queue.(*routineGroup).Run.func1()
      /home/github-runner/actions-runner/_work/vendor/github.com/golang-queue/queue/thread.go:18 +0x73

previous v0.1.3 didn't