Struct BufferedResponse 

pub struct BufferedResponse {

    pub id: String,
    pub action: String,
    pub job_id: String,
    pub round: u32,
    pub reply_subject: String,
    pub payload: Vec<u8>,
    pub created_at: Instant,
    pub release_at: Instant,
    pub ack_handle: Box<dyn AckHandle>,
    pub msg_id: String,
    pub annotations: Vec<OperatorAnnotation>,
    pub edited: bool,
    pub stopped: bool,
}

A completed agent response held in the buffer before NATS publication.

Fields

id: String

Unique ID for this buffer entry (UUID).

action: String

Action type: "propose" or "evaluate".

job_id: String

Session / job ID.

round: u32

Deliberation round number.

reply_subject: String

NATS subject to publish to when released.

payload: Vec<u8>

Serialized payload bytes.

created_at: Instant

When the response was completed by the LLM.

release_at: Instant

When the response should auto-release (created_at + hold_duration).

ack_handle: Box<dyn AckHandle>

Handle to ack the original NATS message when the entry is released.

msg_id: String

Dedup key for idempotency.

annotations: Vec<OperatorAnnotation>

Operator annotations accumulated during HITL review.

edited: bool

Whether the payload was edited by an operator.

stopped: bool

Whether the operator has stopped (reversibly rejected) this entry.

Stopped entries remain in the buffer but are skipped by ResponseBuffer::drain_ready — they won’t be published to NATS until un-stopped. This allows the operator to undo a rejection and continue editing.