Struct ActionDeliveryTask 

pub struct ActionDeliveryTask {
    pub tn_id: TnId,
    pub action_id: Box<str>,
    pub target_instance: Box<str>,
    pub target_id_tag: Box<str>,
    pub related_action_id: Option<Box<str>>,
}

Task for delivering federated actions Retry logic is handled by the scheduler with RetryPolicy

Fields

tn_id: TnId

action_id: Box<str>

target_instance: Box<str>

target_id_tag: Box<str>

related_action_id: Option<Box<str>>

Optional related action ID (e.g., for APRV, this is the subject action being approved) When set, the related action’s token is included in the related field of the inbox payload

Implementations

impl ActionDeliveryTask

pub fn new( tn_id: TnId, action_id: Box<str>, target_instance: Box<str>, target_id_tag: Box<str>, ) -> Arc<Self>

pub fn new_with_related( tn_id: TnId, action_id: Box<str>, target_instance: Box<str>, target_id_tag: Box<str>, related_action_id: Option<Box<str>>, ) -> Arc<Self>

Create a delivery task with a related action (used for APRV fan-out to include the approved action)

Trait Implementations

impl Clone for ActionDeliveryTask

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActionDeliveryTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ActionDeliveryTask

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ActionDeliveryTask

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Task<Arc<AppState>> for ActionDeliveryTask

fn kind() -> &'static str

fn kind_of(&self) -> &'static str

fn build(_id: TaskId, ctx: &str) -> ClResult<Arc<dyn Task<App>>>

fn serialize(&self) -> String

fn run<'life0, 'life1, 'async_trait>( &'life0 self, app: &'life1 App, ) -> Pin<Box<dyn Future<Output = ClResult<()>> + Send + 'async_trait>>

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