Skip to content

StreamSync

Node API

cryptuon/streamsync

Node API¶

API for node operators and network management.

Base URL¶

http://localhost:8080/node

Health & Status¶

Health Check¶

GET /health

{
  "status": "healthy",
  "uptime": 86400,
  "version": "1.0.0"
}

Node Status¶

GET /status

{
  "nodeId": "node-001",
  "specialization": "speed-runner",
  "stake": 50000,
  "queriesServed": 125000,
  "winRate": 0.73,
  "avgLatency": 4.2,
  "pendingRewards": 125.5
}

Metrics¶

Prometheus Metrics¶

GET /metrics

# HELP streamsync_queries_total Total queries served
# TYPE streamsync_queries_total counter
streamsync_queries_total{result="success"} 125000
streamsync_queries_total{result="error"} 50

# HELP streamsync_query_latency_ms Query latency
# TYPE streamsync_query_latency_ms histogram
streamsync_query_latency_ms_bucket{le="1"} 50000
streamsync_query_latency_ms_bucket{le="5"} 100000
streamsync_query_latency_ms_bucket{le="10"} 120000

Peer Management¶

List Peers¶

GET /peers

Add Peer¶

POST /peers
Content-Type: application/json

{
  "address": "192.168.1.100:7878"
}

Administration¶

Graceful Shutdown¶

POST /admin/shutdown

Reload Configuration¶

POST /admin/reload

WebSocket¶

const ws = new WebSocket('ws://localhost:8080/ws');

ws.send(JSON.stringify({
  type: 'subscribe',
  events: ['query', 'reward', 'peer']
}));

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log(data.type, data.payload);
};