redis

package

v1.0.8 Latest Latest Go to latest Published: Jan 19, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewQueue(client *redis.Client, key string) *RedisQueue

func (q *RedisQueue) Close() error

func (q *RedisQueue) Dequeue(ctx context.Context, timeout time.Duration) (*queue.Event, error)

func (q *RedisQueue) Enqueue(ctx context.Context, event queue.Event) error

func (q *RedisQueue) Size(ctx context.Context) (int64, error)