Struct AgentResponse 

pub struct AgentResponse {
    pub version: u32,
    pub decision: Decision,
    pub request_headers: Vec<HeaderOp>,
    pub response_headers: Vec<HeaderOp>,
    pub routing_metadata: HashMap<String, String>,
    pub audit: AuditMetadata,
    pub needs_more: bool,
    pub request_body_mutation: Option<BodyMutation>,
    pub response_body_mutation: Option<BodyMutation>,
    pub websocket_decision: Option<WebSocketDecision>,
}

Agent response message

Fields

version: u32

Protocol version

decision: Decision

Decision

request_headers: Vec<HeaderOp>

Header modifications for request

response_headers: Vec<HeaderOp>

Header modifications for response

routing_metadata: HashMap<String, String>

Routing metadata modifications

audit: AuditMetadata

Audit metadata

needs_more: bool

Agent needs more data to make a final decision

When true, the current decision is provisional and may change after processing more body chunks. The proxy should continue streaming body data to this agent.

When false (default), the decision is final.

request_body_mutation: Option<BodyMutation>

Request body mutation (for streaming mode)

If present, applies the mutation to the current request body chunk. Only valid for RequestBodyChunk events.

response_body_mutation: Option<BodyMutation>

Response body mutation (for streaming mode)

If present, applies the mutation to the current response body chunk. Only valid for ResponseBodyChunk events.

websocket_decision: Option<WebSocketDecision>

WebSocket frame decision

Only valid for WebSocketFrame events. If not set, defaults to Allow.

Implementations

impl AgentResponse

pub fn default_allow() -> Self

Create a default allow response

pub fn block(status: u16, body: Option<String>) -> Self

Create a block response

pub fn redirect(url: String, status: u16) -> Self

Create a redirect response

pub fn needs_more_data() -> Self

Create a streaming response indicating more data is needed

pub fn websocket_allow() -> Self

Create a WebSocket allow response

pub fn websocket_drop() -> Self

Create a WebSocket drop response (drop the frame, don’t forward)

pub fn websocket_close(code: u16, reason: String) -> Self

Create a WebSocket close response (close the connection)

pub fn with_websocket_decision(self, decision: WebSocketDecision) -> Self

Set WebSocket decision

pub fn with_request_body_mutation(self, mutation: BodyMutation) -> Self

Create a streaming response with body mutation

pub fn with_response_body_mutation(self, mutation: BodyMutation) -> Self

Create a streaming response with response body mutation

pub fn set_needs_more(self, needs_more: bool) -> Self

Set needs_more flag

pub fn add_request_header(self, op: HeaderOp) -> Self

Add a request header modification

pub fn add_response_header(self, op: HeaderOp) -> Self

Add a response header modification

pub fn with_audit(self, audit: AuditMetadata) -> Self

Add audit metadata

Trait Implementations

impl Clone for AgentResponse

fn clone(&self) -> AgentResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentResponse

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentResponse

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentResponse

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

where __S: Serializer,

Serialize this value into the given Serde serializer.