pubsub

Overview ¶

Package pubsub embeds the Hanzo PubSub core data plane (NATS + JetStream) as an in-process cloud subsystem (HIP-0106) — the same fold pattern as iam/kms/tasks. When enabled it binds the NATS client port (default :4222) and serves JetStream over the cloud data dir; the embedded Kafka adaptor (clients/kafka) and any in-cluster NATS/Kafka client talk to it. It is a single embedded node running JetStream over the local file store — there is NO ZooKeeper, raft, or etcd in the path (Lux consensus only; the optional Quasar PQ control plane is a follow-up, see github.com/hanzoai/pubsub/embed).

It mounts NO HTTP routes of its own: it is a background TCP server. Cloud's generic per-subsystem liveness route answers /v1/pubsub/health, and the K8s Service TCP-probes :4222 directly.

ACTIVATION is opt-in via CLOUD_PUBSUB_ENABLED (a staged cutover from the standalone `pubsub` Deployment). Unset ⇒ the subsystem is a no-op and binds nothing, so every existing deployment is unaffected. Enabled ⇒ Open fails CLOSED: a bind/start error aborts boot rather than serving a phantom messaging plane.