Struct AgentConfig 

pub struct AgentConfig {

    pub id: String,
    pub agent_type: AgentType,
    pub transport: AgentTransport,
    pub events: Vec<AgentEvent>,
    pub pool: Option<AgentPoolConfig>,
    pub timeout_ms: u64,
    pub failure_mode: FailureMode,
    pub circuit_breaker: Option<CircuitBreakerConfig>,
    pub max_request_body_bytes: Option<usize>,
    pub max_response_body_bytes: Option<usize>,
    pub request_body_mode: BodyStreamingMode,
    pub response_body_mode: BodyStreamingMode,
    pub chunk_timeout_ms: u64,
    pub config: Option<Value>,
    pub max_concurrent_calls: usize,
}

Agent configuration

Fields

id: String

Unique agent identifier

agent_type: AgentType

Agent type

transport: AgentTransport

Transport configuration

events: Vec<AgentEvent>

Events this agent handles

pool: Option<AgentPoolConfig>

Pool configuration

timeout_ms: u64

Timeout for agent calls

failure_mode: FailureMode

Failure mode when agent is unavailable

circuit_breaker: Option<CircuitBreakerConfig>

Circuit breaker configuration

max_request_body_bytes: Option<usize>

Maximum request body to send

max_response_body_bytes: Option<usize>

Maximum response body to send

request_body_mode: BodyStreamingMode

Request body streaming mode

Controls how request bodies are sent to this agent:

• buffer: Collect entire body before sending (default)
• stream: Send chunks as they arrive
• hybrid: Buffer small bodies, stream large ones

response_body_mode: BodyStreamingMode

Response body streaming mode

Controls how response bodies are sent to this agent. Same options as request_body_mode.

chunk_timeout_ms: u64

Timeout per body chunk when streaming (milliseconds)

Only applies when using stream or hybrid mode. Default: 5000ms (5 seconds)

config: Option<Value>

Agent-specific configuration

This configuration is passed to the agent via the Configure event when the agent connects. The structure depends on the agent type.

max_concurrent_calls: usize

Maximum concurrent calls to this agent

Limits the number of simultaneous requests that can be processed by this agent. This provides per-agent queue isolation to prevent a slow agent from affecting other agents (noisy neighbor problem).

Default: 100 concurrent calls per agent

Trait Implementations

impl Clone for AgentConfig

fn clone(&self) -> AgentConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for AgentConfig

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for AgentConfig

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>