Implement gcp pubsub broker

.github/labeler.yml

@@ -44,6 +44,12 @@ Redis:
       - faststream/redis/**
       - docs/docs/en/redis/**
 
+GCP:
+  - changed-files:
+    - any-glob-to-any-file:
+      - faststream/gcp/**
+      - docs/docs/en/gcp/**
+
 Observability:
   - changed-files:
     - any-glob-to-any-file:

docker-compose.yaml

@@ -40,10 +40,26 @@ services:
     security_opt:
       - no-new-privileges:true
 
+  gcp:
+    image: messagebird/gcloud-pubsub-emulator:latest
+    ports:
+      - 8681:8681
+    security_opt:
+      - no-new-privileges:true
+    healthcheck:
+      test: ["CMD", "curl", "-f", "http://localhost:8681/v1/projects"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+      start_period: 10s
+
+
   faststream:
     build: .
     volumes:
       - ./:/src
       - /src/.venv/
     network_mode: "host"
+    environment:
+      PUBSUB_EMULATOR_HOST: "localhost:8681"
     tty: true

docs/docs/en/faststream.md

@@ -83,7 +83,7 @@ parsing, networking and documentation generation automatically.
 
 Making streaming microservices has never been easier. Designed with junior developers in mind, **FastStream** simplifies your work while keeping the door open for more advanced use cases. Here's a look at the core features that make **FastStream** a go-to framework for modern, data-centric microservices.
 
-- **Multiple Brokers**: **FastStream** provides a unified API to work across multiple message brokers ([**Kafka**](https://kafka.apache.org/){target="_blank"} [using [**AIOKafka**](https://github.com/aio-libs/aiokafka){target="_blank"} & [**Confluent**](https://github.com/confluentinc/confluent-kafka-python){target="_blank"}], [**RabbitMQ**](https://www.rabbitmq.com/){target="_blank"}, [**NATS**](https://nats.io/){target="_blank"}, [**Redis**](https://redis.io/){.external-link target="_blank"} support)
+- **Multiple Brokers**: **FastStream** provides a unified API to work across multiple message brokers ([**Kafka**](https://kafka.apache.org/){target="_blank"} [using [**AIOKafka**](https://github.com/aio-libs/aiokafka){target="_blank"} & [**Confluent**](https://github.com/confluentinc/confluent-kafka-python){target="_blank"}], [**RabbitMQ**](https://www.rabbitmq.com/){target="_blank"}, [**NATS**](https://nats.io/){target="_blank"}, [**Redis**](https://redis.io/){.external-link target="_blank"} support), [**GCP Pub/Sub**](https://cloud.google.com/pubsub){.external-link target="_blank"} support)
 
 - [**Pydantic Validation**](#writing-app-code): Leverage [**Pydantic's**](https://docs.pydantic.dev/){.external-link target="_blank"} validation capabilities to serialize and validates incoming messages
 
@@ -139,6 +139,11 @@ You can install it with `pip` as usual:
     pip install 'faststream[redis]'
     ```
 
+=== "GCP"
+    ```sh
+    pip install 'faststream[gcp]'
+    ```
+
 
 !!! tip ""
     By default **FastStream** uses **PydanticV2** written in **Rust**, but you can downgrade it manually, if your platform has no **Rust** support - **FastStream** will work correctly with **PydanticV1** as well.