Struct WebhookDispatcher 

pub struct WebhookDispatcher { /* private fields */ }

Implementations

impl WebhookDispatcher

pub fn builder() -> WebhookDispatcherBuilder

pub fn register_rule<T: 'static>( &mut self, rule: impl Fn(&T) -> &'static str + Send + Sync + 'static, )

Register a matcher rule for type T. When send is called with a T, this closure decides which template name to use.

pub fn register_template( &self, name: &str, template: &str, ) -> Result<(), WebhookError>

Register a new template at runtime.

pub fn update_template( &self, name: &str, template: &str, ) -> Result<(), WebhookError>

Overwrite an existing template at runtime without restarting the dispatcher.

pub fn remove_template(&self, name: &str)

Remove a template at runtime.

pub async fn send<T: Serialize + 'static>( &self, event: &T, ) -> Result<(), WebhookError>

Send using the internal matcher to resolve the template name.

pub async fn send_with_hints<T: Serialize + 'static>( &self, event: &T, hints: WithHints, ) -> Result<(), WebhookError>

Send using the internal matcher, with platform hints (color, title, etc).

pub async fn send_with_template<T: Serialize>( &self, template_name: &str, event: &T, ) -> Result<(), WebhookError>

Send to an explicit template, bypassing the matcher entirely.

pub async fn send_with_template_and_hints<T: Serialize>( &self, template_name: &str, event: &T, hints: WithHints, ) -> Result<(), WebhookError>

Send to an explicit template with platform hints.

pub async fn flush(&self) -> Result<(), WebhookError>

Waits for all currently queued jobs to finish processing before returning. Use this between phases where template mutations depend on prior sends completing.

pub async fn shutdown(self)

Closes the send side of the channel, drains all queued jobs, then resolves. Call this during graceful shutdown to ensure no messages are lost.