#1 pond
Minimalistic and High-performance goroutine worker pool written in Go.
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.
Health score 71/100, confidence 95/100.
| Latest version | v0.0.0-20201111034804-825d89059344 |
| Imported by | 97 packages |
| Stars | 2.5K |
| Forks | 250 |
| Last activity | 2 years ago |
| Latest release | v1.0 (7 years ago) |
| License | MIT |
| Known vuln records | 0 |
| Symbol | Kind | Synopsis |
|---|---|---|
| AMQPCeleryBackend | Type | type AMQPCeleryBackend struct{ ... } |
| AMQPCeleryBackend.Connection | Field | Connection *amqp.Connection |
| AMQPCeleryBackend.GetResult | Method | func (b *AMQPCeleryBackend) GetResult(taskID string) (*ResultMessage, error) |
| AMQPCeleryBackend.Host | Field | Host string |
| AMQPCeleryBackend.Reconnect | Method | func (b *AMQPCeleryBackend) Reconnect() |
| AMQPCeleryBackend.SetResult | Method | func (b *AMQPCeleryBackend) SetResult(taskID string, result *ResultMessage) error |
| NewAMQPCeleryBackend | Function | func NewAMQPCeleryBackend(host string) *AMQPCeleryBackend |
| NewAMQPCeleryBackendByConnAndChannel | Function | func NewAMQPCeleryBackendByConnAndChannel(conn *amqp.Connection, channel *amqp.Channel) *AMQPCeleryBackend |
| AMQPCeleryBroker | Type | type AMQPCeleryBroker struct{ ... } |
| AMQPCeleryBroker.Connection | Field | Connection *amqp.Connection |
| AMQPCeleryBroker.CreateExchange | Method | func (b *AMQPCeleryBroker) CreateExchange() error |
| AMQPCeleryBroker.CreateQueue | Method | func (b *AMQPCeleryBroker) CreateQueue() 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.
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 deheap provides a doubly-ended heap (min-max heap).
Package worker accepts Jobs and places them in a queue to be executed N at a time.