Versions in this module Expand all Collapse all v0 v0.1.0 Feb 23, 2026 Changes in this version + func CleanupKeys(ctx context.Context, client *redis.Client, namespace string) error + func NewRedisClient() *redis.Client + func PendingCount(ctx context.Context, client *redis.Client, stream, group string) (int64, error) + func UniqueNamespace(t *testing.T, client *redis.Client) string + func WaitFor(t *testing.T, condition func() bool, timeout time.Duration)
Go to main page