Struct Node 

pub struct Node { /* private fields */ }

A bot’s peer side: Peers for delegating, a Channel per team for tasks it receives.

Implementations

impl Node

pub fn new( config: NodeConfig, store: Arc<dyn ConversationStore>, clock: Arc<dyn Clock>, ) -> Result<Self, Error>

A node for config; file manifests are read now.

pub async fn start(&self) -> Vec<String>

Fetches the manifests of URL teams, marks tasks left by a stop as failed, and returns problems worth a warning (this bot missing from a team, a manifest that cannot be read).

pub fn channels(&self) -> Vec<Arc<dyn Channel>>

One peer:<team> channel per team: it serves the team’s endpoint (tasks when the team’s accept allows them, relaying, refusals that say why) and the bot’s socket.

pub async fn check(&self) -> Vec<(String, bool, String)>

Checks each team without changing anything: its manifest (fetched for URL teams), this bot’s membership, and whether the members it may call are reachable. One line per finding, with true when it is fine.

pub fn teams(&self) -> Vec<String>

The team ids.

Trait Implementations

impl Clone for Node

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Node

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Peers for Node

fn directory<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerInfo>, PeerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Members this bot may delegate to (the manifest’s links from this bot).

fn delegate<'life0, 'async_trait>( &'life0 self, delegation: Delegation, ) -> Pin<Box<dyn Future<Output = Result<PeerTask, PeerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Hands work to a member and waits up to Delegation::wait for it to end.

fn status<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, team: &'life1 str, peer: &'life2 str, task: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<PeerTask, PeerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

The current state of a task this bot delegated.

fn cancel<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, team: &'life1 str, peer: &'life2 str, task: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<PeerTask, PeerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Asks the other bot to stop a task this bot delegated.

fn report_usage<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, conversation: &'life1 ConversationKey, task: Option<&'life2 str>, tokens: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

The tokens the turn answering the task of conversation (task, or the oldest) used, its own delegations included; reported with the task’s end.

fn progress( &self, conversation: &ConversationKey, task: Option<&str>, text: &str, )

What the turn answering the task of conversation (task, or the oldest) is doing now, shown to the caller while the task works. Called from the agent’s output reader: quick.

fn fail<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, conversation: &'life1 ConversationKey, task: Option<&'life2 str>, reason: &'life3 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

The runtime could not answer the task of conversation (task, or the oldest): it fails with reason instead of completing with a fixed reply.

fn answer<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, task: &'life1 PeerTask, prompt: &'life2 str, button: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<PeerTask, PeerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Answers the question of a task waiting for input (the origin person pressed button).

fn caller<'life0, 'life1, 'async_trait>( &'life0 self, conversation: &'life1 ConversationKey, ) -> Pin<Box<dyn Future<Output = Option<PeerCaller>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The authenticated sender of an inbound event of a peer channel; None for other events.

fn team_person(&self, account: &str) -> Option<String>

The team person whose accounts include account (platform:instance/user-id).

fn member_name(&self, team: &str) -> Option<String>

This bot’s member name in team.