Enum SopDispatch 

pub enum SopDispatch {
    AgentLoop,
    Sop,
    SopAndAgentLoop,
}

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. Where a fan-in delivery is routed once consumed. Used by AMQP, which carries this field to choose between the agent loop, the SOP engine, or both. Agent-loop channels (Telegram, Discord, Slack, …) do not carry a dispatch field: their fan-in is trigger-driven, opting in via a SOP channel trigger while the normal agent turn always runs. The mode is source-agnostic.

Variants

AgentLoop

Drive a normal agent turn: the delivery becomes a ChannelMessage. This is the default and preserves each channel’s original behavior.

Sop

Dispatch the delivery to the SOP engine as a SopEvent (topic = source identifier, payload = body), matching SOPs whose trigger for this source matches. No agent turn is started.

SopAndAgentLoop

Do both: dispatch to the SOP engine and drive an agent turn from the same delivery.

Trait Implementations

impl Clone for SopDispatch

fn clone(&self) -> SopDispatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SopDispatch

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

Formats the value using the given formatter.

impl Default for SopDispatch

fn default() -> SopDispatch

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SopDispatch

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl HasPropKind for SopDispatch

const PROP_KIND: PropKind = crate::config::PropKind::Enum

const ALIAS_SOURCE: Option<AliasSource> = None

fn display_secret_terminals() -> Vec<&'static str>

Terminal field names whose values must be redacted when this type is displayed as an object/object-array prop. Most prop kinds have no nested secret surface; Configurable object-array element types can override this by delegating to their generated secret_field_terminals.

impl JsonSchema for SopDispatch

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 PartialEq for SopDispatch

fn eq(&self, other: &SopDispatch) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SopDispatch

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.

impl Copy for SopDispatch

impl Eq for SopDispatch

impl StructuralPartialEq for SopDispatch