Struct ContractNetManager 

pub struct ContractNetManager { /* private fields */ }

Contract-Net Protocol manager

Implementations

impl ContractNetManager

pub fn new() -> Self

Create a new contract-net manager

pub fn with_strategy(strategy: BidEvaluationStrategy) -> Self

Create with a specific evaluation strategy

pub fn subscribe(&self) -> Receiver<ContractMessage>

Get a receiver for protocol messages

pub async fn generate_task_id(&self) -> String

Generate a unique task ID

pub async fn announce_task(&self, announcement: TaskAnnouncement) -> String

Announce a task for bidding

pub async fn receive_bid(&self, bid: TaskBid) -> Result<(), String>

Process a bid from an agent

pub async fn award_task(&self, task_id: &str) -> Option<String>

Evaluate bids and award task to winner

pub async fn accept_award( &self, task_id: &str, agent_id: &str, ) -> Result<(), String>

Record acceptance of an award

pub async fn decline_award( &self, task_id: &str, agent_id: &str, reason: &str, ) -> Result<(), String>

Record decline of an award

pub async fn complete_task( &self, task_id: &str, agent_id: &str, success: bool, result: Option<String>, ) -> Result<(), String>

Record task completion

pub async fn get_task_status(&self, task_id: &str) -> Option<TaskStatus>

Get task status

pub async fn get_pending_tasks(&self) -> Vec<TaskAnnouncement>

Get all pending tasks

pub async fn get_bids(&self, task_id: &str) -> Vec<TaskBid>

Get bids for a task

Trait Implementations

impl Default for ContractNetManager

fn default() -> Self

Returns the “default value” for a type.