Function NewRedisRefreshTokenStore

store/redis.go:64–105

NewRedisRefreshTokenStore creates a new Redis-based refresh token store with client-side caching

(config *RedisConfig)

// NewRedisRefreshTokenStore creates a new Redis-based refresh token store with client-side caching
func NewRedisRefreshTokenStore(config *RedisConfig) (*RedisRefreshTokenStore, error) {
	if config == nil {
		config = DefaultRedisConfig()
	}

	// Build Redis client options
	clientOpt := rueidis.ClientOption{
		InitAddress: []string{config.Addr},
		Password:    config.Password,
		SelectDB:    config.DB,

		// TLS configuration
		TLSConfig: config.TLSConfig,

		// Connection configuration
		ConnWriteTimeout: 10 * time.Second,

		// Client-side cache configuration
		CacheSizeEachConn: config.CacheSize,
		DisableCache:      false,
	}

	// Create Redis client with client-side caching enabled
	client, err := rueidis.NewClient(clientOpt)
	if err != nil {
		return nil, fmt.Errorf("failed to create Redis client: %w", err)
	}

	// Test connection
	ctx := context.Background()
	if err := client.Do(ctx, client.B().Ping().Build()).Error(); err != nil {
		client.Close()
		return nil, fmt.Errorf("failed to connect to Redis: %w", err)
	}

	return &RedisRefreshTokenStore{
		client:   client,
		prefix:   config.KeyPrefix,
		ctx:      ctx,
		cacheTTL: config.CacheTTL,
	}, nil
}

// Close closes the Redis client connection
func (s *RedisRefreshTokenStore) Close() error {