Struct AuditRegistry 

pub struct AuditRegistry { /* private fields */ }

Registry for managing audit targets

Implementations

impl AuditRegistry

pub fn new() -> Self

Creates a new AuditRegistry

pub fn supports_target_type(&self, target_type: &str) -> bool

pub async fn create_target( &self, target_type: &str, id: String, config: &KVS, ) -> Result<Box<dyn Target<AuditEntry> + Send + Sync>, TargetError>

Creates a target of the specified type with the given ID and configuration

Arguments

• target_type - The type of the target (e.g., “webhook”, “mqtt”).
• id - The identifier for the target instance.
• config - The configuration key-value store for the target.

Returns

• Result<Box<dyn Target<AuditEntry> + Send + Sync>, TargetError> - The created target or an error.

pub async fn create_audit_targets_from_config( &self, config: &Config, ) -> AuditResult<Vec<Box<dyn Target<AuditEntry> + Send + Sync>>>

Creates all targets from a configuration Create all notification targets from system configuration and environment variables. This method processes the creation of each target concurrently as follows:

1. Iterate through all registered target types (e.g. webhooks, mqtt).
2. For each type, resolve its configuration in the configuration file and environment variables.
3. Identify all target instance IDs that need to be created.
4. Combine the default configuration, file configuration, and environment variable configuration for each instance.
5. If the instance is enabled, create an asynchronous task for it to instantiate.
6. Concurrency executes all creation tasks and collects results.

pub fn add_target( &mut self, _id: String, target: Box<dyn Target<AuditEntry> + Send + Sync>, )

Adds a target to the registry

Arguments

• id - The identifier for the target.
• target - The target instance to be added.

pub fn add_shared_target( &mut self, _id: String, target: SharedTarget<AuditEntry>, )

pub async fn remove_target( &mut self, id: &str, ) -> Option<SharedTarget<AuditEntry>>

Removes a target from the registry

Arguments

• id - The identifier for the target to be removed.

Returns

• Option<SharedTarget<AuditEntry>> - The removed target if it existed.

pub fn get_target(&self, id: &str) -> Option<SharedTarget<AuditEntry>>

Gets a target from the registry

Arguments

• id - The identifier for the target to be retrieved.

Returns

• Option<SharedTarget<AuditEntry>> - The target if it exists.

pub fn list_target_values(&self) -> Vec<SharedTarget<AuditEntry>>

Lists cloned target values for runtime inspection without exposing mutable registry access.

pub fn runtime_manager(&self) -> &TargetRuntimeManager<AuditEntry>

pub fn runtime_manager_mut(&mut self) -> &mut TargetRuntimeManager<AuditEntry>

pub fn list_targets(&self) -> Vec<String>

Lists all target IDs

Returns

• Vec<String> - A vector of all target IDs in the registry.

pub async fn close_all(&mut self) -> AuditResult<()>

Closes all targets and clears the registry

Returns

• AuditResult<()> - Result indicating success or failure.

pub fn create_key(&self, target_type: &str, target_id: &str) -> String

Creates a unique key for a target based on its type and ID

Arguments

• target_type - The type of the target (e.g., “webhook”, “mqtt”).
• target_id - The identifier for the target instance.

Returns

• String - The unique key for the target.

pub fn enable_target( &self, target_type: &str, target_id: &str, ) -> AuditResult<()>

Enables a target (placeholder, assumes target exists)

Arguments

• target_type - The type of the target (e.g., “webhook”, “mqtt”).
• target_id - The identifier for the target instance.

Returns

• AuditResult<()> - Result indicating success or failure.

pub fn disable_target( &self, target_type: &str, target_id: &str, ) -> AuditResult<()>

Disables a target (placeholder, assumes target exists)

Arguments

• target_type - The type of the target (e.g., “webhook”, “mqtt”).
• target_id - The identifier for the target instance.

Returns

• AuditResult<()> - Result indicating success or failure.

pub fn upsert_target( &mut self, target_type: &str, target_id: &str, target: Box<dyn Target<AuditEntry> + Send + Sync>, ) -> AuditResult<()>

Upserts a target into the registry

Arguments

• target_type - The type of the target (e.g., “webhook”, “mqtt”).
• target_id - The identifier for the target instance.
• target - The target instance to be upserted.

Returns

• AuditResult<()> - Result indicating success or failure.

Trait Implementations

impl Default for AuditRegistry

fn default() -> Self

Returns the “default value” for a type.