proxy.golang.org : github.com/vmihailenco/taskq/example/api_worker

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/api_worker
Keywords: go , golang , ironmq , ironmq-backend , message-queue , queue , redis , sqs , task-queue , taskqueue
License: BSD-2-Clause
Latest release: over 3 years ago
First release: over 3 years ago
Namespace: github.com/vmihailenco/taskq/example
Stars: 1,043 on GitHub
Forks: 97 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 9 days ago

• Versions 1
• Dependent Packages 0
• Related Packages 13
• Sort

  • Name
  • Versions
  • Latest Release
  • Oldest Release
  • Dependent packages
  • Dependent repositories
  • Downloads
  • Maintainers
  • Most Stars
  • Least Stars