Struct AgentsResource 

pub struct AgentsResource<'c> { /* private fields */ }

Implementations

impl AgentsResource<'_>

pub async fn list(&self) -> Result<Vec<Value>, PulseError>

GET /api/pulse/agents — every deployed agent in the current org.

pub async fn get(&self, agent_id: &str) -> Result<Value, PulseError>

GET /api/pulse/agents/{id} — one agent by id.

pub async fn update( &self, agent_id: &str, config: &Value, ) -> Result<Value, PulseError>

B-115 Phase 1 — PUT /api/pulse/agents/{id}: replace the agent’s config.

config is the FULL agent config (not a partial merge) — at minimum name. Optional fields (engineType, inputTopic, outputTopic, description, instances, monthlyBudget, config) fall back to safe defaults when omitted. See the UpdateAgentRequest schema in openapi.yaml.

Today this triggers a full stop + persist + start cycle on the engine side — the agent is briefly unavailable while the swap happens. Existing state in the agent’s keyed store is preserved. Phase 2 (B-115-engine) will add atomic event-boundary swap so hot-reloadable changes apply with no downtime.

Returns the post-update agent snapshot (same shape as get).

Errors

• PulseError::Validation on a bad config (self-loop, invalid streaming operators)
• PulseError::NotFound if the agent doesn’t exist

pub async fn delete(&self, agent_id: &str) -> Result<(), PulseError>

DELETE /api/pulse/agents/{id} — stop the agent + remove its config row.

The agent’s keyed state store is also dropped. Requires the AGENT_DELETE permission.

Trait Implementations

impl<'c> Debug for AgentsResource<'c>

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

Formats the value using the given formatter.