OpenMesh

Open Communication Mesh for AI

OpenMesh is an open, protocol native decentralized communication mesh for large-scale, open multi-agent systems (MAS) such as the Internet of Agents (IoA) and the Society of Agents (SoA).

Github Github Vision Paper Vision Paper Technical Documentation Technical Documentation Pervasive.link Pervasive.link
OpenMesh
Discovery, Topology, and Federation Management
Element Description
Topology Mapping Engine Continuously builds a live graph of nodes, links, capacities, and health. Collects active and passive measurements to infer link quality and cost. Exports topology snapshots for routing, planning, and audits.
Mesh Discovery Finds peers via DHT, multicast, introducers, and cached hints. Validates identities before exposure to the control plane. Backs off and rate limits to avoid discovery storms.
Federation Handshake Performs mutual authentication and capability exchange. Negotiates trust, policy, and resource budgets per federation. Records attestations for audit and later renegotiation.
Validator Service Checks conformance of submitted specs or messages against schema. Returns structured error reports for debugging.
Topology Optimizer Computes overlays that minimize latency and cost while preserving resilience. Evaluates multi-criteria objectives using real-time telemetry.
Service Metadata Publishes signed descriptors of roles, APIs, versions, and SLAs. Supports filtering by capabilities, geography, and policy domains.
Communication Models and Patterns
Element Description
Publish-Subscribe Engine Implements topic, pattern, and content-based subscriptions. Offers delivery tiers from at-most-once to exactly-once. Supports backpressure and bounded queues per subscriber.
Event Signaling Bus Low-latency signals for control, coordination, and alerts. Out-of-band from bulk data to avoid head-of-line blocking. Supports fanout, prioritization, and deduplication.
Inbox and Mailbox Durable per-entity queues with identity-bound access. Handles offline delivery and retries with exponential backoff. Supports message threading and idempotent processing.
Social Graph Overlay Routes using relationship graphs like trust, teams, and projects. Enables scoped broadcasts and affinity-based fanout. Respects privacy rules for edge visibility and traversal.
Request–Reply Synchronous or timed async RPC over unreliable paths. Correlation IDs and retries ensure robust semantics. Supports circuit breakers and adaptive timeouts.
Gossip and Epidemic Dissemination Probabilistic spreading with tunable fanout and TTL. Anti-entropy sync for eventual consistency under churn. Resistant to partitions and partial failures.
Shared State Boards CRDT-backed boards for collaborative state across nodes. Support fine-grained conflict resolution without locks. Offer snapshotting and time-travel reads.
Schema, Semantics, and Protocol Management
Element Description
Distributed Schema Registry Versioned schemas replicated with quorum consistency. Supports deprecation and compatibility contracts. Secured by signatures and access policies.
Self-Describing Messages Embed schema fingerprints and feature flags in headers. Enable dynamic decoding and forward compatibility. Fail closed on critical mismatches, warn on soft ones.
Protocol Definition Engine Declarative specs for message, transport, and session behaviors. Generates code, validators, and test harnesses. Supports conformance suites and differential fuzzing.
Protocol Negotiation Engine Selects encodings, ciphers, and transports per peer pair. Considers policy, capability, and current network state. Caches outcomes and supports fast renegotiation.
Translator & Protocol Bridge Transforms messages between heterogeneous stacks. Maintains semantics through mapping and enrichment. Monitors lossiness and flags incompatible fields.
Schema & Protocol Validation Per-hop and end-to-end validation of structure and rules. Rejects malformed traffic early to protect resources. Emits rich diagnostics for rapid remediation.
Semantic Security Enforces meaning-level constraints beyond syntax. Guards against injection, confusion, and ontology drift. Uses signed vocabularies and context-aware checks.
Coordination and Control Systems
Element Description
Directory Nodes Authoritative references for identities, roles, and endpoints. Support sharding and read replicas for scale. Expose signed, cacheable records with TTLs.
Membership Management Service Admits, suspends, and evicts nodes with audit trails. Tracks liveness, quorum, and partition statuses. Implements rolling credentials and key rotation.
Signalling Layer Lightweight control channels for session setup and changes. Isolates control traffic from data-plane congestion. Prioritizes reliability and ordering guarantees.
Session Management Creates, resumes, and tears down streams and flows. Negotiates lifetimes, keepalives, and flow control. Persists minimal state for fast recovery.
Routing Layer Computes policies, trust weights, and preferred paths. Distributes route updates with dampening to avoid flaps. Validates conformance to governance and compliance rules.
Networking and Transport Layer
Element Description
Federated Mesh Nodes Self-contained peers with compute, storage, and policy. Run pluggable modules for transport, routing, and security.
Multi-Protocol Transport Engine Speaks multiple transports concurrently per flow.
Overlay Routing Network Abstracts physical networks into virtual topologies. Supports segment routing and label switching.
Gossip Synchronization Service Maintains shared views through periodic anti-entropy. Detects divergence and repairs state incrementally.
Routing Layer
Element Description
Direct Routing Shortest viable path using current link metrics. Prefers low-latency, high-trust connections. Falls back gracefully when links degrade.
Relay Based Routing Uses intermediaries to bridge NATs and partitions. Chooses relays by proximity, trust, and load. Encrypts end-to-end to keep relays blind.
Multi-Path Routing Splits flows across diverse paths for resilience. Performs per-packet or per-chunk scheduling. Heals quickly by reassigning traffic on failure.
Trust Weighted Routing Incorporates reputation and attestations in path choice. Avoids low-trust segments even if faster. Continuously updates weights from observations.
Policy Constrained Routing Enforces geography, cost, and compliance constraints. Uses deny and prefer lists with proofs of adherence. Auditable decisions for regulatory review.
Integration and Extensibility
Element Description
Protocol Adapters Wrap legacy systems like MQTT, AMQP, and XMPP. Normalize semantics to OpenMesh conventions. Expose mapping rules as code and config.
Event Automation Hooks Trigger serverless actions on message patterns. Support filters, transforms, and enrichments.
Cross-Network Gateways Bridge independent meshes without collapsing trust. Translate identities, policies, and namespaces.
Persistence and Delivery Guarantees
Element Description
Store-and-Forward Buffers Persist messages for intermittent or mobile nodes. Bound storage with eviction, pinning, and priorities. Offer receipt proofs and replay windows.
TTL and Expiry Management Attach lifetimes and enforce at every hop. Prevent stale, looping, or poisoned traffic. Expose metrics on expiries and near-expiries.
Audit and Replay Logs Immutable logs for lineage and forensic analysis. Support selective redaction under policy. Enable deterministic replay for debugging.
Scaling and Optimization
Element Description
Dynamic QoS Management Allocates bandwidth and priority by workload and trust. Learns traffic patterns to prevent congestion.
Topic Sharding and Load Balancing Distributes hot topics across shards and regions. Uses consistent hashing and adaptive rebalancing.
Edge Relay Nodes Place relays near producers and consumers. Terminate heavy protocols and compress payloads. Act as caches to reduce round trips.
Monitoring and Diagnostics
Element Description
Telemetry Aggregator Collects metrics, logs, and events with sampling. Normalizes across versions and vendors. Feeds SLO dashboards and capacity planning.
Distributed Tracing Propagates trace IDs across protocols and hops. Captures spans for queueing, transit, and processing. Highlights critical path and tail latency.
Anomaly Detection and Alerts Learns baselines and flags deviations early. Correlates symptoms to likely root causes. Integrates with paging and runbooks for response.
Security, Trust, and Privacy Integrations
Element Description
End-to-End Encryption Engine Supports multi-party E2EE, forward secrecy, and post-quantum ciphers.
Identity and Key Management Decentralized PKI, DID integration, key rotation, and revocation mechanisms.
Trust & Reputation System Trust scoring based on message history, reliability, and behavioral metrics.
Access Control Role-, attribute-, and context-based access management.
Policy Enforcement All communication, routing, and interactions follow the rules set by the network or federation, automatically, at every step.