feat(amgi-pulsar): add Apache Pulsar support

[TomKimber]

Add Apache Pulsar support: #52.

[read-the-docs-community]

Documentation build overview

📚 AMGI | 🛠️ Build #35128150 | 📁 Comparing 9632eb2 against latest (7f72e38)

  🔍 Preview build  

4 files changed

± specifications.html
± specifications/bindings.html
± specifications/lifespan.html
± specifications/message.html

[Copilot]

Copilot review overview

🟡 Changes recommended

Address the four unresolved moderate issues in producer caching, partition-key handling, binding propagation, and None serialization.

Get a fresh assessment by requesting another Copilot review.

Review effort: Lite
Findings: 2

Open (2)

• Prevent concurrent duplicate producer creation per topic · New
• Avoid serializing optional None keys as "null" · New

What changed in this PR

Adds Apache Pulsar support to AMGI, including a new server package, bindings, tests, documentation, examples, and CI integration.

Changes:

• Adds asynchronous Pulsar message receiving, sending, acknowledgements, and redelivery.
• Adds PulsarKey, integration tests, and Docker example configuration.
• Updates dependencies, packaging, documentation, and CI.

Unresolved issues include a producer-cache race, incorrect empty partition-key handling, dropped bindings in the sending path, and serializing None as "null".

File	Summary
uv.lock	Locks the new package and Pulsar dependency.
tox.ini	Adds Pulsar test and import environments.
README.md	Documents Pulsar availability.
packages/​asyncfast/​tests_asyncfast/​test_message_object_bindings.py	Tests Pulsar key serialization.
packages/​asyncfast/​src/​asyncfast/​bindings.py	Adds PulsarKey binding support.
packages/​amgi-pulsar/​tests_amgi_pulsar/​test_pulsar_message.py	Tests sender initialization.
packages/​amgi-pulsar/​tests_amgi_pulsar/​test_pulsar_message_integration.py	Adds Pulsar integration coverage.
packages/​amgi-pulsar/​tests_amgi_pulsar/​__init__.py	Defines the test package.
packages/​amgi-pulsar/​src/​amgi_pulsar/​py.typed	Enables distributed type information.
packages/​amgi-pulsar/​src/​amgi_pulsar/​__init__.py	Implements the Pulsar server and sender.
packages/​amgi-pulsar/​README.md	Documents installation and usage.
packages/​amgi-pulsar/​pyproject.toml	Defines package metadata and dependencies.
packages/​amgi-pulsar/​LICENSE	Adds package licensing.
example/​README.md	Documents the Pulsar example.
example/​pyproject.toml	Adds the Pulsar example dependency.
example/​apache-pulsar/​docker-compose.yaml	Provides a local Pulsar service.
docs/​specifications/​bindings.rst	Documents Pulsar bindings.
.pre-commit-config.yaml	Adds Pulsar typing dependencies.
.github/​workflows/​tests.yml	Adds Pulsar to CI.

---

💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.

📢 Thoughts on this report? Let us know!

[Copilot]

🟡 Changes recommended

Handler cleanup, bounded shutdown, and message-consumption backpressure need resolution before production use.

4 open findings

• Handler tasks outlive closed lifespan and client resources · New
• Unbounded handler task creation can exhaust memory · New
• Shutdown waits indefinitely for stuck handler tasks · New
• Remove duplicated word in sentence · New

2 resolved since last review

• Avoid serializing optional None keys as "null"
• Prevent concurrent duplicate producer creation per topic

🧠 Review effort: Balanced

[read-the-docs-community]

Documentation build overview

📚 AsyncFast | 🛠️ Build #35128151 | 📁 Comparing 9632eb2 against latest (7f72e38)

  🔍 Preview build  

1 file changed

± message_payload.html