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. 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.

It ALWAYS serves. The staged cutover it was gated behind is over — the standalone nats StatefulSet and the pubsub App are retired, so this is the ONE in-cluster messaging plane and a cloud that did not serve it would simply have no messaging. WHERE it listens stays configurable (CLOUD_PUBSUB_PORT, CLOUD_PUBSUB_HOST); a port collision is answered by moving the port, never by running without the plane.

Open fails CLOSED: a bind/start error aborts boot rather than serving a phantom messaging plane.