#1 pond
Minimalistic and High-performance goroutine worker pool written in Go.
Health score 44/100, confidence 75/100.
| Latest version | v0.2.1 |
| Imported by | 29 packages |
| Stars | 0 |
| Forks | 0 |
| Last activity | 5 years ago |
| Latest release | Unknown |
| License | Unknown |
| Known vuln records | 0 |
| Symbol | Kind | Synopsis |
|---|---|---|
| AfterRequestFunc | Type | type AfterRequestFunc func() |
| GetContextAfterRequestFuncs | Function | func GetContextAfterRequestFuncs(ctx context.Context) []AfterRequestFunc |
| Bokchoy | Type | type Bokchoy struct{ ... } |
| Bokchoy.Empty | Method | func (b *Bokchoy) Empty(ctx context.Context) error |
| Bokchoy.Flush | Method | func (b *Bokchoy) Flush() error |
| Bokchoy.Handle | Method | func (b *Bokchoy) Handle(queueName string, sub Handler, options ...Option) |
| Bokchoy.HandleFunc | Method | func (b *Bokchoy) HandleFunc(queueName string, f HandlerFunc, options ...Option) |
| Bokchoy.Logger | Field | Logger logging.Logger |
| Bokchoy.Publish | Method | func (b *Bokchoy) Publish(ctx context.Context, queueName string, payload interface{}, options ...Option) (*Task, error) |
| Bokchoy.Queue | Method | func (b *Bokchoy) Queue(name string) *Queue |
| Bokchoy.QueueNames | Method | func (b *Bokchoy) QueueNames() []string |
| Bokchoy.Run | Method | func (b *Bokchoy) Run(ctx context.Context, options ...Option) error |
Minimalistic and High-performance goroutine worker pool written in Go.
Package asynq provides a framework for Redis based distrubted task queue.
Package queue provides multiple thread-safe generic queue implementations.
Package gocelery is Celery Distributed Task Queue in Go Celery distributed tasks are used heavily in many python web applications and this library allows you to implement celery workers in Go as well as being able to submit celery tasks in Go.
Package deheap provides a doubly-ended heap (min-max heap).
Minimalistic and High-performance goroutine worker pool written in Go.
Package asynq provides a framework for Redis based distrubted task queue.
Package queue provides multiple thread-safe generic queue implementations.
Package gocelery is Celery Distributed Task Queue in Go Celery distributed tasks are used heavily in many python web applications and this library allows you to implement celery workers in Go as well as being able to submit celery tasks in Go.
Package deheap provides a doubly-ended heap (min-max heap).