Struct FunctionActivity 

pub struct FunctionActivity { /* private fields */ }

Function Activity - Rust関数を実行

Implementations

impl FunctionActivity

pub fn new<F>(name: &str, function: F) -> Self

where F: Fn(HashMap<String, Value>) -> Result<HashMap<String, Value>, ActivityError> + Send + Sync + 'static,

pub fn with_timeout(self, timeout: Duration) -> Self

Trait Implementations

impl Activity for FunctionActivity

fn execute<'life0, 'async_trait>( &'life0 self, inputs: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Value>, ActivityError>> + Send + 'async_trait>>

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

Activityを実行

fn name(&self) -> &str

Activity名を取得

fn timeout(&self) -> Option<Duration>

タイムアウト設定を取得

fn retry_policy(&self) -> Option<RetryPolicy>

リトライポリシーを取得