Skip to main content

list_pending_for_targets

objectiveai_cli::db::message_queue

Function list_pending_for_targets 

Source 
pub async fn list_pending_for_targets(
    pool: &Pool,
    targets: &[ResolvedTarget],
    after_id: Option<i64>,
    limit: Option<i64>,
) -> Result<Vec<ResponseItem>, Error>
Expand description

Stream every active = TRUE message_queue row for any of targets, JOINed against message_queue_contents for parts. Grouped per-parent so parts reflects the relational content shape, not a JSON shadow. Pagination is by message_queue_contents.id (the --after-id / --limit scope is on parts, not rows — but the row boundary stays stable per parent).