Struct AmqpConfig 

pub struct AmqpConfig {

    pub enabled: bool,
    pub amqp_url: String,
    pub exchange: String,
    pub routing_keys: Vec<String>,
    pub queue: Option<String>,
    pub ca_cert: Option<PathBuf>,
    pub client_cert: Option<PathBuf>,
    pub client_key: Option<PathBuf>,
    pub sender_label: String,
    pub content_template: String,
    pub thread_id_field: String,
    pub durable_ack: bool,
    pub excluded_tools: Vec<String>,
}

Generic AMQP 0-9-1 channel configuration (RabbitMQ, Fedora Messaging, etc.).

Subscribes to an exchange via routing keys and lifts each delivery into an inbound ChannelMessage. The mapping from a JSON delivery body to message fields is config-driven (content_template, thread_id_field) so a new source — Anitya, an internal bus, anything publishing JSON — is onboarded by configuration rather than code.

Fields

enabled: bool

Whether this channel is active. The runtime only loads channels whose enabled = true. Default: false so an operator who pastes a partial [channels.<type>.<alias>] block doesn’t accidentally bring a channel live before the rest of its config is filled in.

amqp_url: String

AMQP broker URL. Use amqp:// for plain or amqps:// for TLS (e.g. amqps://fedora:@rabbitmq.fedoraproject.org/%2Fpublic_pubsub).

exchange: String

Exchange to bind the consumer queue to (e.g. amq.topic).

routing_keys: Vec<String>

Routing keys to bind. Scope these to the topics of interest; binding # consumes the entire exchange and is almost never what you want.

queue: Option<String>

Queue name. Leave unset for a server-generated, transient, auto-deleted, exclusive queue. Set a stable name (UUID recommended) only when durable delivery across reconnects is required.

ca_cert: Option<PathBuf>

Path to the CA certificate bundle for amqps:// connections.

client_cert: Option<PathBuf>

Path to the client certificate for broker mutual-TLS auth (Fedora Messaging requires a client cert).

client_key: Option<PathBuf>

Path to the client private key matching client_cert.

sender_label: String

Value placed in ChannelMessage.sender for every delivery from this source (e.g. anitya). Lets the orchestrator’s self-loop guard and per-channel routing identify the origin.

content_template: String

Template for the inbound message content. {field} placeholders are interpolated from the JSON delivery body’s top-level keys. When empty, the raw delivery body is used verbatim.

thread_id_field: String

Dotted path into the JSON delivery body whose value becomes the message thread_ts, correlating replies to the originating event (e.g. message.project.name). Empty disables threading.

durable_ack: bool

Acknowledgement mode. When true (default), deliveries are acked only after the message is durably handed to the agent loop, giving at-least-once semantics: a crash before hand-off redelivers the event. Set false for at-most-once (broker acks on dispatch), which silently drops in-flight events on crash and is only appropriate for non-side-effecting, drop-on-overload consumers.

excluded_tools: Vec<String>

Tools excluded from this channel’s tool spec. When set, these tools are not exposed to the model when responding via this channel.

Implementations

impl AmqpConfig

pub fn configurable_prefix() -> &'static str

Returns the #[prefix] value for this Configurable struct.

pub fn secret_fields(&self) -> Vec<SecretFieldInfo>

Returns metadata about all #[secret] fields on this struct and nested children.

pub fn secret_field_terminals() -> Vec<&'static str>

Static enumeration of every #[secret] field’s terminal name (snake_case, matching the on-disk TOML key) reachable from this type via #[nested] traversal. Unlike secret_fields(), this requires no instance — the per-struct codegen literals are joined at call time with recursive calls into the inner types’ own secret_field_terminals().

Used by the migration crate’s raw-TOML encrypt walker as the secret-key allowlist. prop_fields()-derived allowlists skip compound (non-Vec) #[secret] fields, so this method is the authoritative source.

pub fn encrypt_secrets(&mut self, store: &SecretStore) -> Result<(), Error>

Encrypt all secret fields in place using the provided store.

pub fn decrypt_secrets(&mut self, store: &SecretStore) -> Result<(), Error>

Decrypt all secret fields in place using the provided store.

pub fn set_secret(&mut self, name: &str, value: String) -> Result<(), Error>

Set a secret field by its full dotted name, dispatching to nested children.

pub fn prop_fields(&self) -> Vec<PropFieldInfo>

Returns metadata about all property fields on this struct and nested children.

pub fn get_prop(&self, name: &str) -> Result<String, Error>

Get a property value by its full dotted name, returning it as a display string.

pub fn set_prop(&mut self, name: &str, value_str: &str) -> Result<(), Error>

Set a property value by its full dotted name, parsing from string.

pub fn prop_is_secret(name: &str) -> bool

Check if a property name refers to a secret field (static, no instance needed).

pub fn init_defaults(&mut self, prefix: Option<&str>) -> Vec<&'static str>

Instantiate None nested sections whose prefix matches. Returns the prefixes that were initialized.

pub fn map_key_sections() -> Vec<MapKeySection>

Enumerate every map-keyed (HashMap<String, T>) and list-shaped (Vec<T>) section discoverable from this Configurable’s tree. The dashboard / CLI consume this to surface “+ Add” affordances without hardcoding the section list.

pub fn nested_section_help(name: &str) -> Option<&'static str>

Help blurb for a #[nested] field on this struct, sourced from the field-level /// docstring. Returns None for unknown names so callers can fall through to a different lookup.

pub fn get_map_keys(&self, section_path: &str) -> Option<Vec<String>>

Return the current alias keys at section_path, or None if the path doesn’t resolve to a map-keyed section in this tree.

pub fn nested_option_entries(&self) -> Vec<NestedOptionEntry>

Snapshot of every #[nested] Option<T> field on this struct as (field_name, is_some) tuples, in declaration order.

field_name is the raw Rust ident (snake_case) — consumers can map to display names via their own table. The schema is the single source of truth: adding a new pub foo: Option<FooConfig> field with #[nested] surfaces here without touching any caller.

pub fn create_map_key( &mut self, section_path: &str, map_key: &str, ) -> Result<bool, String>

Insert a default-valued entry under a map-keyed section, or append to a list-shaped one, with map_key as the new entry’s natural identifier (HashMap key for Map sections; identifier field for List sections).

Returns Ok(true) if a new entry was created, Ok(false) if the entry already existed (idempotent), or Err(reason) if the section path doesn’t resolve to a Map/List in this tree.

pub fn delete_map_key( &mut self, section_path: &str, map_key: &str, ) -> Result<bool, String>

Remove the entry identified by map_key from the map-keyed section at section_path.

Returns Ok(true) if the entry existed and was removed, Ok(false) if it didn’t exist, or Err(reason) if the section path doesn’t resolve.

pub fn rename_map_key( &mut self, section_path: &str, map_key: &str, new_key: &str, ) -> Result<bool, String>

Rename map_key to new_key within the map-keyed section at section_path, preserving the entry’s value.

Returns Ok(true) if renamed, Ok(false) if map_key didn’t exist, or Err(reason) if new_key already exists or the section path doesn’t resolve.

impl AmqpConfig

pub fn validate(&self) -> Result<(), Error>

Validate the AMQP configuration.

Checks:

• amqp_url uses a valid scheme (amqp:// or amqps://)
• amqps:// connections carry a CA certificate
• client_cert and client_key are supplied together (mutual TLS)
• the exchange is non-empty
• at least one routing key is bound

Trait Implementations

impl ChannelConfig for AmqpConfig

fn name() -> &'static str

human-readable name

fn desc() -> &'static str

short description

impl Clone for AmqpConfig

fn clone(&self) -> AmqpConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AmqpConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for AmqpConfig

fn default() -> AmqpConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AmqpConfig

fn deserialize<__D>( __deserializer: __D, ) -> Result<AmqpConfig, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for AmqpConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl MaskSecrets for AmqpConfig

fn mask_secrets(&mut self)

fn restore_secrets_from(&mut self, current: &AmqpConfig)

impl Serialize for AmqpConfig

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.