nats-events

Document NATS messaging, JetStream persistence, and SAAP event implementation.

9|2|Updated Nov 29, 2024
One-click install
npx skills add https://github.com/bbvch-ai/aihub-core --skill nats-events
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: nats-events
Source: https://github.com/bbvch-ai/aihub-core/tree/main/.claude/skills/nats-events
Command: npx skills add https://github.com/bbvch-ai/aihub-core --skill nats-events

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This skill eliminates the need for developers to manually search scattered documentation when implementing NATS-based event-driven workflows, pub/sub patterns, RPC calls, and Swiss AI Agent Protocol (SAAP) event hierarchies for AI agent systems.

Core Features & Use Cases

  • NATS & JetStream Implementation Guide: Covers core vs durable messaging, subject formatting, stream configuration, and publisher/subscriber patterns for both NATS Core and JetStream.
  • SAAP Event Reference: Full event classification rules, complete event hierarchy, semantic event mappings for OpenInference observability, and guidance on selecting the correct base event for different workflow use cases.
  • Use Case: For example, a developer building a RAG agent can use this skill to quickly look up the correct subject format for publishing a RetrieverEvent, configure a JetStream consumer for durable control event processing, and implement RPC for fetching agent configuration without referencing internal codebases.

Quick Start

Use the nats-events skill to look up the correct NATS subject format for publishing a StartEvent to a RAG agent thread, or to find the configuration steps for a JetStream durable subscriber for control event processing.

Frequently Asked Questions about nats-events

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I format NATS subjects for publishing SAAP events to an AI agent thread?

To configure a JetStream durable consumer for control event processing, you must define stream persistence settings and subscriber policies. This skill provides the configuration steps for implementing durable event storage in AI agent platforms.

What is the correct SAAP event classification for OpenInference observability?

The SAAP event classification system maps semantic events to OpenInference observability standards using a defined hierarchy. This reference outlines the rules for selecting the correct base event for workflow orchestration and observability integration.

How do I implement RPC calls for fetching AI agent configuration over NATS?

Implementing RPC calls over NATS involves setting up request-reply messaging patterns to fetch agent configuration dynamically. This skill provides reference patterns for integrating RPC into event-driven AI agent workflows.

Does JetStream work with NATS Core pub/sub for durable event storage?

JetStream extends NATS Core pub/sub messaging by adding persistence layers for durable event storage. This reference details how to transition between core messaging and durable streams for AI agent communication.