Struct WebhookQueue 

pub struct WebhookQueue { /* private fields */ }

Pending webhook messages that the gateway loop should pick up.

Implementations

impl WebhookQueue

pub fn new() -> Self

pub fn enqueue_wake( &mut self, reason: Option<String>, session_id: Option<String>, )

Enqueue a wake event.

pub fn enqueue_agent_message( &mut self, message: String, agent_id: Option<String>, metadata: Option<Value>, )

Enqueue an agent message.

pub fn drain(&mut self) -> Vec<PendingWebhook>

Drain all pending webhooks.

pub fn is_empty(&self) -> bool

Check if there are pending webhooks.

Trait Implementations

impl Default for WebhookQueue

fn default() -> Self

Returns the “default value” for a type.