Add Supercomputer category: 12 P2P resource-sharing modules (164 total)
Introduce a new production category for distributed system resource pooling over Hyperswarm — CPU, RAM, GPU, bandwidth, disk, jobs, cache, and egress. New modules (supercomputer/): - hyper-p2p-capacity-registry — gossip CPU/RAM/GPU/disk/bandwidth ads - hyper-p2p-cpu-share — CPU millisecond credit pool - hyper-p2p-ram-pool — RAM byte lend/claim/release - hyper-p2p-gpu-slot — GPU slot register/reserve - hyper-p2p-bandwidth-share — shared up/down Mbps - hyper-p2p-disk-stripe — striped block shards - hyper-p2p-job-dispatcher — submit/claim/complete jobs - hyper-p2p-thermal-guard — load/temperature throttle signals - hyper-p2p-cache-farm — distributed LRU cache - hyper-p2p-net-gateway — peer internet egress routing - hyper-p2p-cluster-affinity — hardware tag placement scoring - hyper-p2p-work-stealer — shard queues + work stealing Each package: index.js, tests, README, api/architecture docs, examples/basic.js. Shared layering guide: _shared/SUPERCOMPUTER_LAYERS.md. Registry, module-paths, MODULE_CATEGORIES, and workspace README updated to 164. Parent workspace also adds docs/supercomputer hub and demo-supercomputer-mesh (outside this repo). Co-authored-by: Cursor <[email protected]>
This commit is contained in:
@@ -0,0 +1,5 @@
|
||||
# Changelog
|
||||
|
||||
## 0.3.0
|
||||
|
||||
- Initial Supercomputer category release (work-stealer/v1).
|
||||
@@ -0,0 +1,30 @@
|
||||
# hyper-p2p-work-stealer
|
||||
|
||||
Production **Supercomputer** module: pool P2P system resources over Hyperswarm.
|
||||
|
||||
**Category:** Supercomputer · **Protocol:** `work-stealer/v1` · **Export:** `HyperP2PWorkStealer`
|
||||
|
||||
## When to use
|
||||
|
||||
Shard task queues with idle-peer work stealing.
|
||||
|
||||
## Quick start
|
||||
|
||||
```js
|
||||
const { HyperP2PWorkStealer } = require('hyper-p2p-work-stealer')
|
||||
const mod = new HyperP2PWorkStealer({ topic: 'my-super-mesh' })
|
||||
await mod.ready()
|
||||
// ...
|
||||
await mod.close()
|
||||
```
|
||||
|
||||
## Docs
|
||||
|
||||
- [docs/api.md](docs/api.md)
|
||||
- [docs/architecture.md](docs/architecture.md)
|
||||
|
||||
## Test
|
||||
|
||||
```bash
|
||||
npm install && npm test
|
||||
```
|
||||
@@ -0,0 +1,36 @@
|
||||
# API: hyper-p2p-work-stealer
|
||||
|
||||
**Protocol:** `work-stealer/v1` · **Export:** `HyperP2PWorkStealer`
|
||||
|
||||
## Overview
|
||||
|
||||
Shard task queues with idle-peer work stealing.
|
||||
|
||||
## Constructor
|
||||
|
||||
```js
|
||||
const mod = new HyperP2PWorkStealer(opts)
|
||||
```
|
||||
|
||||
| Option | Type | Default | Description |
|
||||
|--------|------|---------|-------------|
|
||||
| `topic` | Buffer \| string \| null | `null` | Hyperswarm topic |
|
||||
| `keyPair` | KeyPair | random | Discovery identity |
|
||||
|
||||
## Methods
|
||||
|
||||
See [`index.js`](../index.js) for the full method list. All modules implement `getStats()`, `async ready()`, and `async close()`.
|
||||
|
||||
## getStats()
|
||||
|
||||
Returns `{ ...stats, protocol: 'work-stealer/v1' }` plus module-specific counters.
|
||||
|
||||
## P2P
|
||||
|
||||
When `topic` is set, `ready()` joins Hyperswarm and opens Protomux `work-stealer/v1`.
|
||||
|
||||
## Testing
|
||||
|
||||
```bash
|
||||
npm install && npm test
|
||||
```
|
||||
@@ -0,0 +1,14 @@
|
||||
# Architecture: hyper-p2p-work-stealer
|
||||
|
||||
**Category:** Supercomputer · **Protocol:** `work-stealer/v1`
|
||||
|
||||
```mermaid
|
||||
flowchart LR
|
||||
App[Application] --> Mod[HyperP2PWorkStealer]
|
||||
Mod --> Mux[Protomux work-stealer/v1]
|
||||
Mux --> Swarm[Hyperswarm]
|
||||
```
|
||||
|
||||
## Composition
|
||||
|
||||
See [`../../_shared/SUPERCOMPUTER_LAYERS.md`](../../_shared/SUPERCOMPUTER_LAYERS.md) and [`../README.md`](../README.md).
|
||||
@@ -0,0 +1,10 @@
|
||||
require('bare-process/global')
|
||||
const { HyperP2PWorkStealer } = require('../index.js')
|
||||
|
||||
async function main () {
|
||||
const mod = new HyperP2PWorkStealer()
|
||||
console.log('stats', mod.getStats())
|
||||
await mod.close()
|
||||
console.log('done')
|
||||
}
|
||||
main().catch(console.error)
|
||||
@@ -0,0 +1,87 @@
|
||||
require('bare-process/global')
|
||||
const EventEmitter = require('bare-events')
|
||||
const b4a = require('b4a')
|
||||
const { initModuleSwarm, gossipSend } = require('../../_shared/p2p-bare.js')
|
||||
|
||||
const PROTOCOL = 'work-stealer/v1'
|
||||
|
||||
class HyperP2PWorkStealer extends EventEmitter {
|
||||
constructor (opts = {}) {
|
||||
super()
|
||||
this._stats = { pushed: 0, stolen: 0 }
|
||||
this.topic = opts.topic || null
|
||||
this.keyPair = opts.keyPair || require('hypercore-crypto').keyPair()
|
||||
this.peerId = b4a.toString(this.keyPair.publicKey, 'hex')
|
||||
this._queues = new Map()
|
||||
this.swarm = null
|
||||
this._peerMsgs = null
|
||||
}
|
||||
|
||||
_queue (shard) {
|
||||
const k = String(shard || 'default')
|
||||
if (!this._queues.has(k)) this._queues.set(k, [])
|
||||
return this._queues.get(k)
|
||||
}
|
||||
|
||||
push (shard, task) {
|
||||
if (task == null) throw new Error('task required')
|
||||
const id = b4a.toString(require('hypercore-crypto').hash(b4a.from(JSON.stringify(task) + Date.now())), 'hex').slice(0, 12)
|
||||
const entry = { id, task, shard: String(shard || 'default'), at: Date.now() }
|
||||
this._queue(shard).push(entry)
|
||||
this._stats.pushed++
|
||||
if (this._peerMsgs) gossipSend(this, { type: 'push', entry })
|
||||
this.emit('push', entry)
|
||||
return entry
|
||||
}
|
||||
|
||||
steal (workerId = null, shard = 'default') {
|
||||
const q = this._queue(shard)
|
||||
if (!q.length) return null
|
||||
const entry = q.shift()
|
||||
entry.worker = workerId || this.peerId
|
||||
entry.stolenAt = Date.now()
|
||||
this._stats.stolen++
|
||||
if (this._peerMsgs) gossipSend(this, { type: 'steal', entry })
|
||||
this.emit('steal', entry)
|
||||
return entry
|
||||
}
|
||||
|
||||
peek (shard = 'default') {
|
||||
const q = this._queue(shard)
|
||||
return q.length ? { ...q[0] } : null
|
||||
}
|
||||
|
||||
depth (shard = 'default') { return this._queue(shard).length }
|
||||
|
||||
listShards () { return [...this._queues.keys()] }
|
||||
|
||||
async ready () {
|
||||
if (this.swarm || !this.topic) return this
|
||||
await initModuleSwarm(this, {
|
||||
keyPair: this.keyPair, topic: this.topic, protocol: PROTOCOL,
|
||||
onmessage: (data) => {
|
||||
if (data?.type === 'push' && data.entry) this._queue(data.entry.shard).push(data.entry)
|
||||
else if (data?.type === 'steal' && data.entry) {
|
||||
const q = this._queue(data.entry.shard)
|
||||
const i = q.findIndex((e) => e.id === data.entry.id)
|
||||
if (i >= 0) q.splice(i, 1)
|
||||
}
|
||||
}
|
||||
})
|
||||
return this
|
||||
}
|
||||
|
||||
getStats () {
|
||||
const pending = [...this._queues.values()].reduce((n, q) => n + q.length, 0)
|
||||
return { ...this._stats, shards: this._queues.size, pending, protocol: PROTOCOL }
|
||||
}
|
||||
|
||||
async close () {
|
||||
if (this.swarm) await this.swarm.destroy().catch(() => {})
|
||||
this.swarm = null
|
||||
this._queues.clear()
|
||||
this.emit('closed')
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = { HyperP2PWorkStealer, PROTOCOL }
|
||||
+1774
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,23 @@
|
||||
{
|
||||
"name": "hyper-p2p-work-stealer",
|
||||
"version": "0.3.0",
|
||||
"description": "Idle-peer work stealing queues for Bare/Pear P2P supercomputer mesh.",
|
||||
"main": "index.js",
|
||||
"type": "commonjs",
|
||||
"license": "Apache-2.0",
|
||||
"scripts": { "test": "brittle-bare test/test.js" },
|
||||
"dependencies": {
|
||||
"bare-events": "^2.8.0",
|
||||
"bare-process": "^4.4.0",
|
||||
"b4a": "^1.6.7",
|
||||
"hypercore-crypto": "^3.0.0",
|
||||
"protomux": "^3.0.0",
|
||||
"compact-encoding": "^2.0.0"
|
||||
},
|
||||
"peerDependencies": { "hyperswarm": "^4.0.0", "bare": ">=1.0.0" },
|
||||
"devDependencies": { "brittle": "^3.0.0" },
|
||||
"imports": {
|
||||
"process": { "bare": "bare-process", "default": "process" },
|
||||
"events": { "bare": "bare-events", "default": "events" }
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,23 @@
|
||||
require('bare-process/global')
|
||||
const test = require('brittle')
|
||||
const { HyperP2PWorkStealer } = require('../index.js')
|
||||
|
||||
test('work-stealer: push steal', async (t) => {
|
||||
const w = new HyperP2PWorkStealer()
|
||||
w.push('shard-a', { op: 'compute' })
|
||||
const task = w.steal('worker-1', 'shard-a')
|
||||
t.ok(task)
|
||||
t.is(w.depth('shard-a'), 0)
|
||||
await w.close()
|
||||
})
|
||||
|
||||
test('work-stealer: validation', async (t) => {
|
||||
const w = new HyperP2PWorkStealer()
|
||||
try {
|
||||
w.push('s', null)
|
||||
t.fail('expected throw')
|
||||
} catch (e) {
|
||||
t.ok(e instanceof Error)
|
||||
}
|
||||
await w.close()
|
||||
})
|
||||
Reference in New Issue
Block a user