Function initializeTLSCluster

main_test.go:453–487

initializeTLSCluster initializes the TLS cluster for testing

(ctx context.Context)

// initializeTLSCluster initializes the TLS cluster for testing
func initializeTLSCluster(ctx context.Context) error {
	// Load TLS config
	certDir := "dockers/osscluster-tls/tls"
	_, err := loadClusterTLSConfig(certDir)
	if err != nil {
		return fmt.Errorf("failed to load TLS config: %w", err)
	}

	// The TLS cluster is auto-created by the container (REDIS_CLUSTER=yes)
	// Just verify it's ready by checking cluster info
	client := redis.NewClient(&redis.Options{
		Addr: net.JoinHostPort("127.0.0.1", tlsCluster.ports[0]),
		TLSConfig: &tls.Config{
			InsecureSkipVerify: true,
		},
	})
	defer client.Close()

	// Wait for cluster to be ready
	err = eventually(func() error {
		info, err := client.ClusterInfo(ctx).Result()
		if err != nil {
			return fmt.Errorf("failed to get cluster info: %w", err)
		}
		if !strings.Contains(info, "cluster_state:ok") {
			return fmt.Errorf("cluster not ready: %s", info)
		}
		return nil
	}, 30*time.Second)
	if err != nil {
		return fmt.Errorf("TLS cluster not ready: %w", err)
	}

	return nil
}

// cleanupTLSCluster cleans up TLS cluster resources
func cleanupTLSCluster() {