Hanzo PubSub - Event Streaming and Message Queue

docker run -d --name hanzo-pubsub \
  -p 4222:4222 \
  -p 8222:8222 \
  hanzoai/pubsub:latest

# compose.yml
services:
  pubsub:
    image: hanzoai/pubsub:latest
    ports:
      - "4222:4222"   # Client connections
      - "8222:8222"   # HTTP monitoring
      - "6222:6222"   # Cluster routing
    volumes:
      - pubsub-data:/data
    command: ["--jetstream", "--store_dir=/data"]

  # Optional: Kafka-compatible sidecar
  kafka:
    build: kafka/
    ports:
      - "9092:9092"   # Kafka protocol
      - "8081:8081"   # Schema registry
      - "8082:8082"   # HTTP proxy
      - "9644:9644"   # Admin API

volumes:
  pubsub-data:

git clone https://github.com/hanzoai/pubsub.git
cd pubsub
go build -o pubsub .
./pubsub --jetstream --store_dir /tmp/pubsub-data

┌──────────────────────────────────────────────────┐
│                    Cluster                        │
│  ┌─────────┐    ┌─────────┐    ┌─────────┐      │
│  │ Node 1  │<-->│ Node 2  │<-->│ Node 3  │      │
│  │ :4222   │    │ :4222   │    │ :4222   │      │
│  └─────────┘    └─────────┘    └─────────┘      │
│       │              │              │            │
│       └──────────────┼──────────────┘            │
│                      │                           │
│              ┌───────┴───────┐                   │
│              │  JetStream    │                   │
│              │  (Streams,    │                   │
│              │   KV, ObjStore)│                  │
│              └───────────────┘                   │
└──────────────────────────────────────────────────┘

       ┌───────────────────────┐
       │  Redpanda Sidecar     │
       │  (Kafka :9092)        │
       │  (Schema Reg :8081)   │
       └───────────────────────┘

# Client port
port: 4222

# HTTP monitoring
monitor_port: 8222

# Clustering
cluster {
  port: 6222
  authorization {
    user: ruser
    password: T0pS3cr3t
    timeout: 2
  }
  routes = []
}

pubsub/
  main.go              # Entry point (configures and runs server)
  server/              # Core server implementation
  conf/                # Configuration parser (lexer, parser)
  internal/
    antithesis/        # Deterministic testing
    fastrand/          # Fast random number generation
    ldap/              # LDAP authentication
    ocsp/              # OCSP stapling
    testhelper/        # Test utilities
  kafka/
    Dockerfile         # Redpanda (Kafka-compatible) sidecar
  logger/              # Logging
  docker/
    nats-server.conf   # Default server configuration
    Dockerfile.nightly # Nightly build
  test/                # Integration tests
  scripts/             # Build and CI scripts

nc, _ := nats.Connect("nats://localhost:4222")
defer nc.Close()

// Subscribe
nc.Subscribe("events.>", func(msg *nats.Msg) {
    fmt.Printf("Received: %s\n", string(msg.Data))
})

// Publish
nc.Publish("events.user.created", []byte(`{"user_id":"123"}`))

nc, _ := nats.Connect("nats://localhost:4222")
js, _ := nc.JetStream()

// Create stream
js.AddStream(&nats.StreamConfig{
    Name:     "ORDERS",
    Subjects: []string{"orders.*"},
})

// Publish
js.Publish("orders.new", []byte(`{"order_id":"abc123"}`))

// Durable consumer
sub, _ := js.PullSubscribe("orders.*", "processor")
msgs, _ := sub.Fetch(10)
for _, msg := range msgs {
    msg.Ack()
}