Senna

Senna is a background job processing library for Go, backed by Redis or Valkey. It provides reliable job queuing, scheduling, retries, rate limiting, and batch processing with a clean, middleware-based architecture.

• Redis 6.2+
• Valkey 7.2+

• Persistent job queues backed by Redis or Valkey
• Scheduled jobs (run at a specific time or after a delay)
• Automatic retries with configurable backoff
• Multiple queues with weighted or strict priority
• Sequential queues for ordered, one-at-a-time processing
• Distributed rate limiting (bucket, sliding window, leaky bucket, concurrent, points-based)
• Job batching with completion callbacks
• Iterable jobs for resumable large dataset processing
• Job argument encryption (AES-GCM)
• Unique jobs to prevent duplicates
• Graceful shutdown with in-flight job completion
• Middleware support for cross-cutting concerns
• Per-job concurrency limits

Senna requires Go 1.25 or later. This repo prefers Go 1.25.8 via the toolchain directive. If you need to stay on another Go 1.25.x toolchain, run with GOTOOLCHAIN=local. CI provisions Go 1.25.8 from go.mod for tests, linting, and govulncheck.

go get github.com/mgomes/senna

c, err := client.New(&client.Config{
    Redis:     senna.RedisConfig{Addr: "localhost:6379"},
    Namespace: "myapp",
})
if err != nil {
    log.Fatal(err)
}
defer c.Close()

// Enqueue immediately
c.Enqueue(ctx, "send_email", map[string]any{
    "to":      "user@example.com",
    "subject": "Welcome!",
})

// Enqueue with delay
c.EnqueueIn(ctx, 5*time.Minute, "send_reminder", map[string]any{"user_id": 123})

// Enqueue to specific queue
c.Enqueue(ctx, "process_payment", args, client.WithQueue("critical"))

w, err := worker.New(&worker.Config{
    Redis:     senna.RedisConfig{Addr: "localhost:6379"},
    Namespace: "myapp",
    Settings: senna.WorkerSettings{
        Concurrency: 10,
        Queues: []senna.QueueConfig{
            {Name: "critical", Priority: 10},
            {Name: "default", Priority: 5},
        },
    },
})
if err != nil {
    log.Fatal(err)
}

w.Register("send_email", func(ctx context.Context, job *senna.Job) error {
    to := job.Args["to"].(string)
    // Send email...
    return nil
})

w.Run(ctx) // Blocks until shutdown signal

For detailed documentation, see the Wiki:

• Getting Started - Installation and setup
• Enqueuing Jobs - Client API, scheduling, bulk enqueue
• Workers - Configuration, handlers, graceful shutdown
• Queues - Priority modes, sequential queues, dedicated workers
• Batches - Grouping jobs with callbacks
• Iterable Jobs - Resumable large dataset processing
• Rate Limiters - Distributed rate limiting algorithms
• Periodic Jobs - Cron-based scheduling
• Middleware - Built-in and custom middleware
• Error Handling - Retries, backoff, dead letter queue

MIT License. See LICENSE file for details.