API Reference Overview

ntl_core
├── ntl_core::node          // Node, NodeBuilder, Disposition
├── ntl_core::signal        // Signal, SignalBuilder, SignalId, NodeId, SignalType
├── ntl_core::synapse       // Synapse, SynapseId, SynapseState
├── ntl_core::propagation   // scopes, scoring, header clamping
├── ntl_core::activation    // the activation model and its functions
├── ntl_core::crypto        // the pluggable CryptoModule interface
├── ntl_core::delivery      // DeliveryClass, Receipt, RejectReason
├── ntl_core::adapter       // the Adapter trait
├── ntl_core::store         // NodeStore, MemoryStore, the conformance suite
├── ntl_core::learning      // reward, decay, exploration, influence caps
├── ntl_core::config        // NodeConfig and its sections
├── ntl_core::time          // the Clock trait
├── ntl_core::rng           // the Rng trait and SplitMix64
├── ntl_core::topology      // peer knowledge and provenance
└── ntl_core::testing       // deterministic Clock and Rng for tests

use std::sync::Arc;
use ntl_core::store::MemoryStore;
use ntl_core::Node;

let store = Arc::new(MemoryStore::new());
let node = Node::builder().with_store(store).build()?;

use ntl_core::Signal;

let signal = node.emit(
    Signal::data("user-created")
        .with_payload(serde_json::json!({ "user_id": "abc123" }))
        .with_weight(0.7)
        .with_tags(vec!["user", "event"]),
)?;

let disposition = node.receive_local(&signal)?;
if disposition.queued {
    // The activation gate holds it until the threshold is crossed.
}

use ntl_core::store::SynapseFilter;

for synapse in node.store().list_synapses(&SynapseFilter::eligible())? {
    println!("{}: weight={}, state={:?}", synapse.id, synapse.weight, synapse.state);
}