Struct EncryptionPlugin 

pub struct EncryptionPlugin { /* private fields */ }

A plugin that provides end-to-end encryption for messages.

This plugin uses AES-256-GCM to encrypt message payloads before they are published and decrypt them after they are received, ensuring message confidentiality.

Implementations

impl EncryptionPlugin

pub fn new(key: [u8; 32]) -> Self

Creates a new EncryptionPlugin with the given encryption key.

Arguments

• key - A 32-byte array representing the AES-256 key.

Trait Implementations

impl Plugin for EncryptionPlugin

fn on_publish<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _topic: &'life1 str, payload: &'life2 mut Vec<u8>, headers: &'life3 mut HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Encrypts the message payload using AES-256-GCM before publishing.

It generates a random nonce for each message, encrypts the payload, and then adds X-Encryption: aes256-gcm and X-Nonce headers to the message.

fn on_message_received<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _topic: &'life1 str, payload: &'life2 mut Vec<u8>, headers: &'life3 HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Decrypts the message payload if it has the appropriate encryption headers.

It looks for the X-Encryption: aes256-gcm and X-Nonce headers to correctly decrypt the payload.

fn name(&self) -> &str

Returns the name of the plugin.

fn on_init<'life0, 'life1, 'async_trait>( &'life0 mut self, _broker: &'life1 Broker, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when the plugin is initialized.

fn on_before_recieved<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, topic: &'life1 str, _payload: &'life2 mut Vec<u8>, _headers: &'life3 mut HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called before a message is received by the broker.

fn on_subscribe<'life0, 'life1, 'async_trait>( &'life0 self, _topic: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a new subscription is made.