@ruvector/edge Net

@ruvector/edge-net

Distributed compute intelligence network with WASM-powered cryptographic security, enabling peer-to-peer coordination of edge AI nodes for collaborative workloads across browsers and edge runtimes.

Quick Command Reference

Installation

Hub install (recommended): npx ruvector@latest includes this package. Standalone: npx @ruvector/edge-net@latest See Installation Guide for the full ecosystem.

Core API

EdgeNetwork Constructor

import { EdgeNetwork } from '@ruvector/edge-net';

const net = new EdgeNetwork({
  peers: ['wss://node-1.example.com', 'wss://node-2.example.com'],
  nodeId: 'my-node',
  encryption: 'aes-256-gcm',
  topology: 'mesh',
  maxPeers: 50,
  heartbeatInterval: 5000,
});

Constructor Options:

Network Operations

await net.join();                                    // Join the network
await net.leave();                                   // Leave gracefully
await net.discover();                                // Discover new peers
await net.broadcast(message);                        // Broadcast to all
await net.sendTo(peerId, data);                      // Send to specific peer
const topology = net.topology();                     // Get network topology
const stats = net.stats();                           // Network statistics

Workload Distribution

// Submit workload to the network
const result = await net.submit({
  type: 'map-reduce',
  data: largeDataset,
  mapFn: (chunk) => process(chunk),
  reduceFn: (results) => aggregate(results),
  timeout: 30000,
});

// Stream results as they arrive
for await (const partial of net.submitStream(workload)) {
  console.log('Partial result:', partial);
}

Secure Communication

// All messages are encrypted by default (AES-256-GCM)
await net.sendTo(peerId, sensitiveData);

// Verify peer identity
const verified = await net.verifyPeer(peerId);

Common Patterns

Distributed Vector Search Across Nodes

const net = new EdgeNetwork({ peers: bootstrapNodes });
await net.join();
const result = await net.submit({
  type: 'distributed-search',
  query: queryVector,
  topK: 20,
  mergeStrategy: 'score',
});

Map-Reduce Data Processing

const result = await net.submit({
  type: 'map-reduce',
  data: documents,
  mapFn: (doc) => embedDocument(doc),
  reduceFn: (embeddings) => buildIndex(embeddings),
});

Real-Time Peer Monitoring

net.on('peer:join', (peerId) => console.log(`${peerId} joined`));
net.on('peer:leave', (peerId) => console.log(`${peerId} left`));
net.on('health', (report) => console.log(`Network health: ${report.healthy}/${report.total}`));

Key Options

RAN DDD Context

Bounded Context: Edge/WASM Runtime

References

• API reference: See references/commands.md
• Full README
• npm