Technisches Glossar

// Kanonische Knoten-Identitätsableitung (src/security.rs)
pub fn derive_node_id(pubkey: &[u8; 32]) -> String {
    format!("knc-{}", hex::encode(pubkey))
}

// Verifikations-Gate:
if claim_node_id != derive_node_id(&peer_pubkey) {
    return Err(RpcError::unauthorized("Deklarierte node_id stimmt nicht mit Ed25519-Key überein"));
}

{
  "jsonrpc": "2.0",
  "method": "knc_task_submit",
  "params": {
    "task_id": "job-8419",
    "isolate_quota_gas": 500000,
    "sender_node_id": "knc-9f8a...c1",
    "req_timestamp": 1787220000,
    "req_nonce": 948172901847291,
    "signature": "3a0b4e..."
  },
  "id": 1
}

// Validierungslogik in src/mesh.rs
let now = current_unix_timestamp_secs();
if (now - req.req_timestamp).abs() > 60 {
    return Err(RpcError::unauthorized("Anfrage außerhalb des +/- 60s Zeitfensters"));
}
if !nonce_cache.insert_if_absent(req.sender_node_id, req.req_nonce) {
    return Err(RpcError::unauthorized("Replay erkannt: Nonce bereits verwendet"));
}

// Strikte Namespace-Trennung (src/security.rs)
if auth_type == AuthType::LegacyHmac && sender.starts_with("knc-") {
    return Err(RpcError::unauthorized("Legacy-HMAC darf knc-*-Namespace nicht beanspruchen"));
}

// Prüfung im laufenden Betrieb
if is_key_revoked(&peer_pubkey) {
    terminate_session(session_id);
    return Err(RpcError::unauthorized("Public Key explizit widerrufen"));
}

// CRDT-Register in Rust
pub struct CrdtRegister<T> {
    pub value: T,
    pub timestamp_micros: u64,
    pub writer_node_id: String,
}

// Abfrage des Zustands-Fingerabdrucks
{"jsonrpc": "2.0", "method": "knc_store_digest", "params": {"shard": "agent_world_model"}, "id": 12}
// Antwort: {"result": {"digest": "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"}}

// Abfrage geänderter Schlüssel seit Zeitstempel
{"jsonrpc": "2.0", "method": "knc_store_diff", "params": {"since_ts": 1787219500000}, "id": 13}
// Liefert nur die seither geänderten Einträge

// Konfliktauflösung in src/store/crdt.rs
if incoming.timestamp > local.timestamp || 
   (incoming.timestamp == local.timestamp && incoming.node_id > local.node_id) {
    *local = incoming; // Gewinner-Update übernehmen
}

// Weiterleitung mit TTL-Dekrement
if msg.ttl > 0 {
    let mut forwarded = msg.clone();
    forwarded.ttl -= 1;
    peer_pool.random_fanout(3, &forwarded);
}

// Fail-Closed Prüfung
if !has_quorum_majority(active_nodes, total_nodes) {
    set_node_role(Role::Observer);
    return Err(RpcError::internal_error("Quorum verloren: Knoten wird Beobachter"));
}

// Quorum-Berechnung (src/swarm/mod.rs)
pub fn quorum_threshold(active_node_count: usize) -> usize {
    (active_node_count / 2) + 1
}

// Rollenübergang
match node.health_status() {
    Health::Unsynced | Health::ClockDriftExceeded => {
        node.transition_to(Role::Observer);
    },
    Health::Synchronized => node.transition_to(Role::Follower),
}

// JSON-AST Additionsprogramm (.nod-Format)
{
  "jsonrpc": "2.0",
  "method": "knc_compile",
  "params": {
    "session_id": "agent-alpha-1",
    "ast": {
      "Add": [
        { "IntLiteral": 42 },
        { "IntLiteral": 58 }
      ]
    }
  },
  "id": 101
}

// Bytecode-Befehlsfolge
[OpCode::PushInt(42), OpCode::PushInt(58), OpCode::Add, OpCode::Ret]
// Stack-Auswertung: [42] -> [42, 58] -> [100] -> Return 100

// Auswertung in isolierter Umgebung
{"jsonrpc": "2.0", "method": "knc_eval_isolate", "params": {"isolate_id": "iso-491", "expression": "Math.sqrt(x)"}, "id": 5}

pub struct IsolateQuota {
    pub max_gas: u64,           // z. B. 1_000_000 Zyklen
    pub max_memory_bytes: usize, // z. B. 64 * 1024 * 1024 (64 MB)
    pub max_call_frames: usize,  // 512
}

// Hot-Reload-Anfrage für neue Agentenlogik
{"jsonrpc": "2.0", "method": "knc_isolate_reload", "params": {"isolate_id": "iso-491", "new_ast": {...}}, "id": 22}
// Antwort: {"result": {"status": "reloaded", "preserved_slots": 14}}

// Freier Knoten holt wartende Aufgaben von Peer ab
{"jsonrpc": "2.0", "method": "knc_task_steal", "params": {"max_tasks": 2, "target_node_id": "knc-3e1b..."}, "id": 31}

// Agenten an anderen Schwarmknoten migrieren
{
  "jsonrpc": "2.0",
  "method": "knc_agent_teleport",
  "params": {
    "agent_id": "agent-finance-04",
    "destination_node_id": "knc-84fa2...e1",
    "include_memory_heap": true
  },
  "id": 44
}