pamoja-transports
Reaching the network when no single link always works, and testing all of it with nothing plugged in.
One install for the 9 capabilities of this domain. Each is also its own
distribution, and pamoja is the whole framework in one.
pip install pamoja-transports
from pamoja.transports import mqtt
| Capability | Module | What it covers |
|---|---|---|
| MQTT | pamoja.mqtt |
An MQTT client with the topic and wildcard rules, acknowledged delivery, retained messages, a last will, and TLS, as the core transport |
| CoAP | pamoja.coap |
A CoAP client and the server it reports to, over UDP, with confirmable delivery and observe |
| Loopback | pamoja.loopback |
An in-process transport with topic matching, a fault injector, and outages on demand, for testing with no broker |
| Store and forward | pamoja.sync |
Offline-first queues in memory or on disk, bounded or not, the on-disk one surviving power loss, and the drain that forwards them in order when a link returns |
| Transport ladder | pamoja.ladder |
Cheapest reachable link first, buffering to a store when every link is down |
| Event bus | pamoja.bus |
An in-memory typed publish and subscribe event bus, with publishers that never wait and subscribers that count what they miss |
| Engine surface | pamoja.core |
The transport every link shares (send, receive, subscribe, and a faulty wrapper for tests) and the runtime version |
| Your own link | pamoja.core |
A link pamoja does not ship, written in your language against the transport contract and composed like any other |
| Simulators | pamoja.sim |
Noisy and replay sensors, a recording actuator, a simulated robot that dead-reckons its pose, and a link that loses sends on a pattern |
The guides, with a worked Python example for each, are at https://pamoja.molex.cloud/docs.
License
MIT
1 maintainer
Release files for pamoja-transports 0.2.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| pamoja_transports-0.2.0.tar.gz | 2.9 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| pamoja_transports-0.2.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 6.5 kB
Release files / pamoja_transports-0.2.0.tar.gz
| Download URL | pamoja_transports-0.2.0.tar.gz |
|---|---|
| Size | 2.9 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
266a76bb1366605c0efd75cc27ada6aa8bdc3531c0241ca6411d8c2f01af4d9a
|
|
BLAKE2b-256 checksum How to use checksums |
fb7a468df3d2ac39bb2c47ce9cf8694ad6bfa58232001d9d81875e3510751850
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.13.15
|
Release files / pamoja_transports-0.2.0-py3-none-any.whl
| Download URL | pamoja_transports-0.2.0-py3-none-any.whl |
|---|---|
| Size | 3.6 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
2abf2474468160b8157eaa420537c6fe50b68ca625cdb8c2b14eba606a05db16
|
|
BLAKE2b-256 checksum How to use checksums |
524fe7fb0582652be035146b8f55ddcb0b4383dc54dccb9e1a2a5f3a7a7612f2
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.13.15
|
