intrabus


Nameintrabus JSON
Version 0.1.0 PyPI version JSON
download
home_pageNone
SummaryLightweight ZeroMQ pub/sub + req/rep message bus for single‑host threaded / multi‑process Python apps
upload_time2025-07-26 14:18:41
maintainerNone
docs_urlNone
authorBuilderCrafter
requires_python<4.0,>=3.9
licenseMIT
keywords zeromq pubsub rpc message-bus threading
VCS
bugtrack_url
requirements No requirements were recorded.
Travis-CI No Travis.
coveralls test coverage No coveralls.
            # intrabus

**intrabus** is a tiny ZeroMQ‑powered message bus that brings **pub/sub events** and **request‑reply RPC** to any multi‑threaded or multi‑process Python application — with **zero external infrastructure**.

## Quick Start

Install from TestPyPI while the project is in pre‑release:

```bash
pip install --index-url https://test.pypi.org/simple/ intrabus

```python
from intrabus import BusInterface, run_topic_broker, run_central_broker

# start background brokers (for dev/testing)
run_topic_broker()
run_central_broker()

# create two modules
alice = BusInterface("Alice")
bob = BusInterface("Bob")

bob.subscribe("greetings", lambda t, m: print("Bob got:", m))

alice.publish("greetings", {"msg": "Hi Bob!"})
print(bob.send_request("Alice", {"question": "ping?"}))

            

Raw data

            {
    "_id": null,
    "home_page": null,
    "name": "intrabus",
    "maintainer": null,
    "docs_url": null,
    "requires_python": "<4.0,>=3.9",
    "maintainer_email": null,
    "keywords": "zeromq, pubsub, rpc, message-bus, threading",
    "author": "BuilderCrafter",
    "author_email": null,
    "download_url": "https://files.pythonhosted.org/packages/12/59/0eac71a33382d247ca5ce1da6681da5f632ce68d27dbe1345561f625e6fd/intrabus-0.1.0.tar.gz",
    "platform": null,
    "description": "# intrabus\n\n**intrabus** is a tiny ZeroMQ\u2011powered message bus that brings **pub/sub events** and **request\u2011reply RPC** to any multi\u2011threaded or multi\u2011process Python application \u2014 with **zero external infrastructure**.\n\n## Quick\u00a0Start\n\nInstall from TestPyPI while the project is in pre\u2011release:\n\n```bash\npip install --index-url https://test.pypi.org/simple/ intrabus\n\n```python\nfrom intrabus import BusInterface, run_topic_broker, run_central_broker\n\n# start background brokers (for dev/testing)\nrun_topic_broker()\nrun_central_broker()\n\n# create two modules\nalice = BusInterface(\"Alice\")\nbob = BusInterface(\"Bob\")\n\nbob.subscribe(\"greetings\", lambda t, m: print(\"Bob got:\", m))\n\nalice.publish(\"greetings\", {\"msg\": \"Hi Bob!\"})\nprint(bob.send_request(\"Alice\", {\"question\": \"ping?\"}))\n",
    "bugtrack_url": null,
    "license": "MIT",
    "summary": "Lightweight ZeroMQ pub/sub + req/rep message bus for single\u2011host threaded / multi\u2011process Python apps",
    "version": "0.1.0",
    "project_urls": {
        "Repository": "https://github.com/BuilderCrafter/intrabus"
    },
    "split_keywords": [
        "zeromq",
        " pubsub",
        " rpc",
        " message-bus",
        " threading"
    ],
    "urls": [
        {
            "comment_text": null,
            "digests": {
                "blake2b_256": "fb4d3ecd6742d055075896044bc5a2c8df16ae89fddd7dcbe29a1af3a745c701",
                "md5": "a23cd7af89797cfc51a7a55a198a004f",
                "sha256": "fd6f0df23b105f984bd0729947aca465630c1a00c7f2aa9cb7d3b24045f16ee6"
            },
            "downloads": -1,
            "filename": "intrabus-0.1.0-py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "a23cd7af89797cfc51a7a55a198a004f",
            "packagetype": "bdist_wheel",
            "python_version": "py3",
            "requires_python": "<4.0,>=3.9",
            "size": 6896,
            "upload_time": "2025-07-26T14:18:40",
            "upload_time_iso_8601": "2025-07-26T14:18:40.641511Z",
            "url": "https://files.pythonhosted.org/packages/fb/4d/3ecd6742d055075896044bc5a2c8df16ae89fddd7dcbe29a1af3a745c701/intrabus-0.1.0-py3-none-any.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": null,
            "digests": {
                "blake2b_256": "12590eac71a33382d247ca5ce1da6681da5f632ce68d27dbe1345561f625e6fd",
                "md5": "064db467075b1f76ed2ebcfec15a6166",
                "sha256": "5b4c9b7a3697d7009e2b9bed571d624f49ca53a82cfb45fe791343ba186174cc"
            },
            "downloads": -1,
            "filename": "intrabus-0.1.0.tar.gz",
            "has_sig": false,
            "md5_digest": "064db467075b1f76ed2ebcfec15a6166",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": "<4.0,>=3.9",
            "size": 5322,
            "upload_time": "2025-07-26T14:18:41",
            "upload_time_iso_8601": "2025-07-26T14:18:41.980605Z",
            "url": "https://files.pythonhosted.org/packages/12/59/0eac71a33382d247ca5ce1da6681da5f632ce68d27dbe1345561f625e6fd/intrabus-0.1.0.tar.gz",
            "yanked": false,
            "yanked_reason": null
        }
    ],
    "upload_time": "2025-07-26 14:18:41",
    "github": true,
    "gitlab": false,
    "bitbucket": false,
    "codeberg": false,
    "github_user": "BuilderCrafter",
    "github_project": "intrabus",
    "travis_ci": false,
    "coveralls": false,
    "github_actions": true,
    "lcname": "intrabus"
}
        
Elapsed time: 1.16893s