Struct AgentConfig 

pub struct AgentConfig {

    pub agent_id: String,
    pub agent_type: AgentType,
    pub capabilities: AgentCapabilities,
    pub registration_endpoint: String,
    pub sensory_endpoint: String,
    pub motor_endpoint: String,
    pub visualization_endpoint: String,
    pub control_endpoint: String,
    pub heartbeat_interval: f64,
    pub connection_timeout_ms: u64,
    pub registration_retries: u32,
    pub retry_backoff_ms: u64,
    pub sensory_send_hwm: i32,
    pub sensory_linger_ms: i32,
    pub sensory_immediate: bool,
}

Agent configuration builder

Fields

agent_id: String

Unique agent identifier

agent_type: AgentType

Agent type (sensory, motor, both, visualization, or infrastructure)

capabilities: AgentCapabilities

Agent capabilities

registration_endpoint: String

FEAGI registration endpoint (ZMQ REQ)

sensory_endpoint: String

FEAGI sensory input endpoint (ZMQ PUSH)

motor_endpoint: String

FEAGI motor output endpoint (ZMQ SUB)

visualization_endpoint: String

FEAGI visualization stream endpoint (ZMQ SUB)

control_endpoint: String

FEAGI control/API endpoint (ZMQ REQ - REST over ZMQ)

heartbeat_interval: f64

Heartbeat interval in seconds (0 = disabled)

connection_timeout_ms: u64

Connection timeout in milliseconds

registration_retries: u32

Registration retry attempts

retry_backoff_ms: u64

Retry backoff base in milliseconds

sensory_send_hwm: i32

ZMQ PUSH socket high-water-mark for sensory data

sensory_linger_ms: i32

ZMQ PUSH socket linger period when disconnecting

sensory_immediate: bool

Whether to enable ZMQ immediate mode on the sensory socket

Implementations

impl AgentConfig

pub fn new(agent_id: impl Into<String>, agent_type: AgentType) -> Self

Create a new agent configuration

Arguments

• agent_id - Unique identifier for this agent
• agent_type - Type of agent (Sensory, Motor, or Both)

Example

use feagi_agent::{AgentConfig, AgentType};

let config = AgentConfig::new("my_camera", AgentType::Sensory);

pub fn with_feagi_host(self, host: impl Into<String>) -> Self

👎Deprecated since 0.1.0: Use with_feagi_endpoints() instead to explicitly specify all ports

Set FEAGI host and ports to derive all endpoints

Note: This method requires explicit port numbers. NO DEFAULTS are provided. Ports must match those configured in FEAGI’s feagi_configuration.toml

Example

let config = AgentConfig::new("camera", AgentType::Sensory)
    .with_feagi_endpoints("192.168.1.100", 30001, 5558, 5564, 5562, 5563);

pub fn with_feagi_endpoints( self, host: impl Into<String>, registration_port: u16, sensory_port: u16, motor_port: u16, visualization_port: u16, control_port: u16, ) -> Self

Set FEAGI endpoints with explicit ports (RECOMMENDED)

All ports must be provided explicitly to match FEAGI’s configuration. No default values are used.

Example

let config = AgentConfig::new("camera", AgentType::Sensory)
    .with_feagi_endpoints(
        "192.168.1.100",
        30001,  // registration_port
        5558,   // sensory_port
        5564,   // motor_port
        5562,   // visualization_port
        5563    // control_port
    );

pub fn with_registration_endpoint(self, endpoint: impl Into<String>) -> Self

Set registration endpoint

pub fn with_sensory_endpoint(self, endpoint: impl Into<String>) -> Self

Set sensory input endpoint

pub fn with_motor_endpoint(self, endpoint: impl Into<String>) -> Self

Set motor output endpoint

pub fn with_visualization_endpoint(self, endpoint: impl Into<String>) -> Self

Set visualization stream endpoint

pub fn with_control_endpoint(self, endpoint: impl Into<String>) -> Self

Set control/API endpoint

pub fn with_heartbeat_interval(self, interval: f64) -> Self

Set heartbeat interval in seconds (0 to disable)

pub fn with_connection_timeout_ms(self, timeout_ms: u64) -> Self

Set connection timeout in milliseconds

pub fn with_registration_retries(self, retries: u32) -> Self

Set registration retry attempts

pub fn with_sensory_socket_config( self, send_hwm: i32, linger_ms: i32, immediate: bool, ) -> Self

Configure sensory socket behaviour (ZMQ PUSH)

pub fn with_vision_capability( self, modality: impl Into<String>, dimensions: (usize, usize), channels: usize, target_cortical_area: impl Into<String>, ) -> Self

Add vision capability

Example

let config = AgentConfig::new("camera", AgentType::Sensory)
    .with_vision_capability("camera", (640, 480), 3, "i_vision");

pub fn with_motor_capability( self, modality: impl Into<String>, output_count: usize, source_cortical_areas: Vec<String>, ) -> Self

Add motor capability

Example

let config = AgentConfig::new("arm", AgentType::Motor)
    .with_motor_capability("servo", 4, vec!["o_motor".to_string()]);

pub fn with_vision_unit( self, modality: impl Into<String>, dimensions: (usize, usize), channels: usize, unit: SensoryUnit, group: u8, ) -> Self

Add vision capability using semantic unit + group (Option B contract).

This avoids requiring SDK users to know FEAGI’s internal cortical ID encoding.

pub fn with_motor_unit( self, modality: impl Into<String>, output_count: usize, unit: MotorUnit, group: u8, ) -> Self

Add motor capability using semantic unit + group (Option B contract).

pub fn with_motor_units( self, modality: impl Into<String>, output_count: usize, source_units: Vec<MotorUnitSpec>, ) -> Self

Add multiple motor units using semantic unit + group pairs (Option B contract).

pub fn with_visualization_capability( self, visualization_type: impl Into<String>, resolution: Option<(usize, usize)>, refresh_rate: Option<f64>, bridge_proxy: bool, ) -> Self

Add visualization capability

Example

let config = AgentConfig::new("brain_viz", AgentType::Visualization)
    .with_visualization_capability("3d_brain", Some((1920, 1080)), Some(30.0), false);

pub fn with_sensory_capability( self, rate_hz: f64, shm_path: Option<String>, ) -> Self

Add sensory capability (generic)

This is used for non-vision sensory modalities (text, audio, etc.)

Device registrations are handled separately via ConnectorAgent and device_registrations in capabilities.

Arguments

• rate_hz - Sensory data rate in Hz
• shm_path - Optional shared memory path

Example

let config = AgentConfig::new("text_input", AgentType::Sensory)
    .with_sensory_capability(20.0, None);

pub fn with_custom_capability( self, key: impl Into<String>, value: Value, ) -> Self

Add custom capability

Example

use serde_json::json;

let config = AgentConfig::new("audio", AgentType::Sensory)
    .with_custom_capability("audio", json!({
        "sample_rate": 44100,
        "channels": 2
    }));

pub fn validate(&self) -> Result<()>

Validate configuration

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.