Module extensions

Module extensions 

Source
Expand description

Message extensions and utilities

This module provides helper functions and extensions for working with Celery protocol messages, including signing, encryption, and validation.

§Example

use celers_protocol::extensions::MessageExt;
use celers_protocol::{Message, TaskArgs};
use uuid::Uuid;

let task_id = Uuid::new_v4();
let body = serde_json::to_vec(&TaskArgs::new()).unwrap();
let msg = Message::new("tasks.add".to_string(), task_id, body);

// Validate the message
assert!(msg.validate_basic().is_ok());

Structs§

SecureMessageBuilder
Message builder with security features

Enums§

ExtensionError
Error type for message extension operations

Traits§

MessageExt
Extension trait for Message with additional utilities