Registry / messaging / go-admin-team-redisqueue-v2

go-admin-team-redisqueue-v2

JSON →
library2.0.0gogounverified

Provides a producer and consumer for a queue using Redis streams.

go get github.com/go-admin-team/redisqueue/v2
INSTALL
IMPORT
SIG · GO-ADMIN-TEAM-REDI
G
go-admin-team-redisqueue-v2
messaginggov2.0.0
harness data pending
Install & Compatibility
Where this runs

No compatibility data collected yet for this library.

Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

redisqueue
github.com/go-admin-team/redisqueue/v2

Create a producer and enqueue a message

package main import ( "context" "github.com/go-admin-team/redisqueue/v2" "github.com/go-redis/redis/v8" ) func main() { client := redis.NewClient(&redis.Options{Addr: "localhost:6379"}) producer, _ := redisqueue.NewProducerWithOptions(&redisqueue.ProducerOptions{ RedisClient: client, }) _ = producer.Enqueue(context.Background(), &redisqueue.Message{ Stream: "mystream", Values: map[string]interface{}{"key": "value"}, }) }
Debug
Known issues

No known issues recorded.

Upgrade
Version history
2.0.0latest on pkg.go.dev
Audit
Dependencies

No dependency data recorded yet.

Agent activity
13 hits · last 30 days
node
12
OpenAI (training)
1
Resources
go-admin-team-redisqueue-v2 — go get go-admin-team-redisqueue-v2 · libregistry