redisjobqueue

package

v1.0.3 Latest Latest Go to latest Published: Jul 7, 2026 License: MIT Imports: 6 Imported by: 0

Details

Package redisjobqueue provides a Redis Stream backed engine.AsyncJobQueue.

It is an optional driver kept out of the engine core so that local/in-memory embedding does not pull in the go-redis dependency.

This section is empty.

This section is empty.

This section is empty.

type RedisStreamJobQueue struct {
	// contains filtered or unexported fields
}

RedisStreamJobQueue implements engine.AsyncJobQueue over a Redis Stream.

func New(rdb *redis.Client, stream string, group string) *RedisStreamJobQueue

New creates a Redis Stream backed async job queue and ensures the group.

func (q *RedisStreamJobQueue) Ack(ctx context.Context, id string) error

func (q *RedisStreamJobQueue) Consume(
	ctx context.Context,
	group string,
	consumer string,
) (*engine.AsyncJob, string, error)

func (q *RedisStreamJobQueue) Publish(ctx context.Context, job engine.AsyncJob) error