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§
- Secure
Message Builder - Message builder with security features
Enums§
- Extension
Error - Error type for message extension operations
Traits§
- Message
Ext - Extension trait for Message with additional utilities