Struct AgentClient 

pub struct AgentClient { /* private fields */ }

Agent client for communicating with external agents

Implementations

impl AgentClient

pub async fn unix_socket( id: impl Into<String>, path: impl AsRef<Path>, timeout: Duration, ) -> Result<Self, AgentProtocolError>

Create a new Unix socket agent client

pub async fn grpc( id: impl Into<String>, address: impl Into<String>, timeout: Duration, ) -> Result<Self, AgentProtocolError>

Create a new gRPC agent client

Arguments

• id - Agent identifier
• address - gRPC server address (e.g., “http://localhost:50051”)
• timeout - Timeout for agent calls

pub fn id(&self) -> &str

Get the agent ID

pub async fn send_event( &mut self, event_type: EventType, payload: impl Serialize, ) -> Result<AgentResponse, AgentProtocolError>

Send an event to the agent and get a response

pub async fn close(self) -> Result<(), AgentProtocolError>

Close the agent connection