Ecosyste.ms: Packages
An open API service providing package, version and dependency metadata of many open source software ecosystems and registries.
Top 1.6% forks on proxy.golang.org
proxy.golang.org : github.com/vmihailenco/taskq/example/redisexample
This package contains an example usage of redis-backed taskq. It includes two programs: 1. api that sends messages on the queue 2. worker that receives messages They share common definitions for the queue `MainQueue` with a single task defined on it `CountTask`. api runs in a loop submitting messages to the queue, for each message it submits it increments a process-local counter. worker starts a consumer that executes the `CountTask` for each message receives - the task handler also implements a process local counter. If you run each program in a separate terminal with: Then api will periodically print the messages sent to the terminal and worker will print the message received. If you spawn further workers they will share consumption of the messages produced by api.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/vmihailenco/taskq/example/redisexample
Keywords: go, golang, ironmq, ironmq-backend, message-queue, queue, redis, sqs, task-queue, taskqueue
License: BSD-2-Clause
Latest release: over 1 year ago
First release: almost 2 years ago
Namespace: github.com/vmihailenco/taskq/example
Stars: 1,048 on GitHub
Forks: 98 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 16 days ago