Struct NodeAgent 

pub struct NodeAgent { /* private fields */ }

Implementations

impl NodeAgent

pub fn new( daemon: Arc<Daemon>, identity: impl Into<String>, model_name: impl Into<String>, ) -> NodeAgent

pub fn with_max_lanes(self, lanes: u32) -> NodeAgent

pub fn connection(&self) -> NodeAgent

pub fn with_timeouts(self, handshake: Duration, idle: Duration) -> NodeAgent

idle is how long the head may be silent before a connection is dropped; zero keeps every connection. Keep it well above the head’s heartbeat, 5 s.

pub fn with_tokenizer(self, digest: u64) -> NodeAgent

Tells each head the model’s tokenizer by digest (crate::fleet::tokenizer_digest), so one whose tokenizer differs places nothing here.

pub fn with_tokenizer_of(self, tok: Arc<dyn Tokenizer>) -> NodeAgent

Serves the model’s tokenizer to a head: its digest, all it says without encoding, and the text it encodes, so a head with no copy of the model tokenizes as this node does.

pub fn with_on_control_ask( self, dial: impl Fn() + Send + Sync + 'static, ) -> NodeAgent

For a node that dials its head: dial is called when the head asks for one connection more, which it keeps for short calls; it may be called more than once.

pub fn with_auth(self, auth: Vec<u8>) -> NodeAgent

pub fn serve(&mut self, endpoint: Endpoint) -> Result<(), DaemonError>