Crate noesis_ship 

noesis-ship

Rust NATS communication platform for multi-agent AI systems.

Provides five core primitives over NATS:

• PubSub — Fire-and-forget publish/subscribe (NATS Core)
• EventBus — Durable event streaming (JetStream)
• Channels — Point-to-point messaging with history (JetStream)
• KV Store — Key-value state management (NATS KV)
• Object Store — Large blob storage (NATS Object Store)
• JobQueue — Generic job lifecycle (queued → running → complete/failed)

Plus NatsServiceBuilder — a framework for building NATS request-reply services in ~20 lines of glue code.

Quick Start

use noesis_ship::types::NatsConfig;

let config = NatsConfig::new("nats://localhost:4222");
assert_eq!(config.url, "nats://localhost:4222");

Modules

channels

Point-to-point JetStream messaging with history.

connection

NATS connection management.

event_bus

JetStream event publishing and subscription.

job_queue

Generic job queue with lifecycle management.

kv

Key-value state management over NATS KV.

object_store

Large blob storage over NATS Object Store.

pubsub

Raw NATS publish/subscribe.

service

Generic NATS service framework.

types

Shared types, configuration, and error handling for noesis-ship.