Rescoot Redis IPC Library

Redis-based IPC library implementing pub/sub messaging, queue processing, and atomic transactions. This is a clean-room reimplementation of the IPC functionality from unu's usk library.

Core Architecture

Single-client Redis multiplexer handling three IPC patterns:

1. Pub/Sub Messaging: Topic-based message distribution via Redis PUBLISH/SUBSCRIBE
2. Request Processing: Blocking queue consumers using BRPOP/LPUSH
3. Atomic Transactions: Pipelined command groups with MULTI/EXEC semantics

Usage Example

// Initialize with connection params
client := redis_ipc.New(redis_ipc.Config{
    Address: "localhost",
    Port:    6379,
})

// Subscribe to messages
sg := client.Subscribe("group")
sg.Handle("channel", func(msg []byte) error {
    log.Printf("Received: %s", msg)
    return nil
})

// Process queue items
client.HandleRequests("queue", func(data []byte) error {
    log.Printf("Processing: %s", data)
    return nil
})

// Execute atomic transactions
txg := client.NewTxGroup("tx")
txg.Add("SET", "key", "value")
txg.Add("PUBLISH", "channel", "msg")
txg.Exec()

Concurrency Model

• Multiplexed Redis connections (single pool)
• Message routing via concurrent maps
• Lock-free handler dispatch
• Thread-safe transaction pipelining

Dependencies

• Redis server
• go-redis

Installation

go get github.com/rescoot/redis-ipc

License

AGPL-3.0, see LICENSE for details