Technical Glossary

// Canonical node identity derivation (src/security.rs)
pub fn derive_node_id(pubkey: &[u8; 32]) -> String {
    format!("knc-{}", hex::encode(pubkey))
}

// Verification gate:
if claim_node_id != derive_node_id(&peer_pubkey) {
    return Err(RpcError::unauthorized("Claimed node_id does not match Ed25519 pubkey"));
}

{
  "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
}

// Sliding window & nonce check (src/mesh.rs)
let now = current_unix_timestamp_secs();
if (now - req.req_timestamp).abs() > 60 {
    return Err(RpcError::unauthorized("Request outside +/- 60s sliding window"));
}
if !nonce_cache.insert_if_absent(req.sender_node_id, req.req_nonce) {
    return Err(RpcError::unauthorized("Replay detected: Nonce already consumed"));
}

// Strict namespace partition check (src/security.rs)
if auth_type == AuthType::LegacyHmac && sender.starts_with("knc-") {
    return Err(RpcError::unauthorized("Legacy HMAC cannot claim knc-* namespace"));
}

// Hot revocation check
if is_key_revoked(&peer_pubkey) {
    terminate_session(session_id);
    return Err(RpcError::unauthorized("Public key explicitly revoked"));
}

// Rust CRDT Entry representation
pub struct CrdtRegister<T> {
    pub value: T,
    pub timestamp_micros: u64,
    pub writer_node_id: String,
}

// RPC Request to check state fingerprint
{"jsonrpc": "2.0", "method": "knc_store_digest", "params": {"shard": "agent_world_model"}, "id": 12}
// Returns: {"result": {"digest": "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"}}

// Querying differences since logical clock
{"jsonrpc": "2.0", "method": "knc_store_diff", "params": {"since_ts": 1787219500000}, "id": 13}
// Returns only keys updated after that timestamp

// Conflict resolution logic (src/store/crdt.rs)
if incoming.timestamp > local.timestamp || 
   (incoming.timestamp == local.timestamp && incoming.node_id > local.node_id) {
    *local = incoming; // Adopt winning update
}

// Gossip message propagation with TTL limit
if msg.ttl > 0 {
    let mut forwarded = msg.clone();
    forwarded.ttl -= 1;
    peer_pool.random_fanout(3, &forwarded);
}

// Fail-closed enforcement
if !has_quorum_majority(active_nodes, total_nodes) {
    set_node_role(Role::Observer);
    return Err(RpcError::internal_error("Quorum lost: Node demoted to read-only observer"));
}

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

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

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

// Bytecode instruction stream
[OpCode::PushInt(42), OpCode::PushInt(58), OpCode::Add, OpCode::Ret]
// Stack evaluation: [42] -> [42, 58] -> [100] -> Return 100

// Evaluating logic inside isolated environment
{"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,           // e.g. 1_000_000 cycles
    pub max_memory_bytes: usize, // e.g. 64 * 1024 * 1024 (64 MB)
    pub max_call_frames: usize,  // 512
}

// Hot-reload request updating agent logic
{"jsonrpc": "2.0", "method": "knc_isolate_reload", "params": {"isolate_id": "iso-491", "new_ast": {...}}, "id": 22}
// Returns: {"result": {"status": "reloaded", "preserved_slots": 14}}

// Idle node steals pending tasks from peer
{"jsonrpc": "2.0", "method": "knc_task_steal", "params": {"max_tasks": 2, "target_node_id": "knc-3e1b..."}, "id": 31}

// Teleport agent to another node in the cluster
{
  "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
}