clusdr 0.1.1

clusdr

A runtime for the cluster. An SDK for the app.

Application SDK for the local Clusdr daemon. This package does not join the cluster.

your process  ──►  clusdr on this host  ──►  the rest of the cluster

Not a database, queue, or Kubernetes. Wire API is v1alpha1. TLS is on by default.

Install

pip install clusdr

CPython 3.10+. Same version train as the daemon.

A running daemon on this host is required:

curl -fsSL https://clusdr.io/install.sh | sh

Linux amd64/arm64, or Docker Hub durguto/clusdr. Then clusdr init and clusdr start --bootstrap. Guide: first member.

Use

local() dials CLUSDR_GRPC_ADDR or 127.0.0.1:7947, waits on Health, then you own the connection.

from clusdr import local

with local() as c:
    members = c.members()
    leader = c.leader()

    c.publish("deployment", {"sha": "abc"})

    lk = c.lock("scheduler", ttl=15)
    try:
        _ = lk.token
    finally:
        c.unlock("scheduler")

    for event in c.watch():
        # member.join, leader.changed, custom.deployment, …
        ...

dial(addr) is for tests and operators. Apps use local().

ttl is seconds. Leaving with (or close()) stops Watch, unlocks, and revokes what this process still holds. Failures raise ClusdrError.

Full surface: Python SDK.

TLS

On unless insecure=True or CLUSDR_TLS=disabled. PEMs (ca.crt, node.crt, node.key) come from data_dir, CLUSDR_DATA_DIR, or ~/.clusdr. Missing files are an error; this client does not skip-verify.

Not in this package

• Join, promote, or configure the cluster (CLI)
• Watch topic filters
• Async / asyncio
• Talking to a remote node's Runtime API as the normal path — put a daemon on that host

Links

• Docs: clusdr.io · Python SDK · from your app
• Daemon: github.com/durguto/clusdr
• This repo: github.com/durguto/clusdr-python

Apache-2.0. Contributor checkout (editable + proto regen): CONTRIBUTING.md.