Method setup

benchmarks/otel_benchmark.py:461–501

Set up all Redis resources.

(self)

        return key

    async def setup(self) -> None:
        """Set up all Redis resources."""
        redis_mod = self._get_redis_module()
        Redis = redis_mod.asyncio.Redis

        # Main client for commands
        self.client = Redis(
            host=self.config.redis_host,
            port=self.config.redis_port,
            decode_responses=True
        )

        # PubSub publisher (separate connection)
        self.pubsub_publisher = Redis(
            host=self.config.redis_host,
            port=self.config.redis_port,
            decode_responses=True
        )

        # PubSub subscriber
        subscriber = Redis(
            host=self.config.redis_host,
            port=self.config.redis_port,
            decode_responses=True
        )
        self.pubsub = subscriber.pubsub()
        await self.pubsub.subscribe(self.pubsub_channel)
        # Consume subscription confirmation
        await self.pubsub.get_message(timeout=1.0)

        # Create stream and consumer group
        try:
            await self.client.xgroup_create(
                self.stream_name,
                self.consumer_group,
                id="0",
                mkstream=True
            )
        except Exception:
            # Group may already exist
            pass

    async def teardown(self) -> None:
        """Clean up all Redis resources."""