Struct DatabaseActivity 

pub struct DatabaseActivity { /* private fields */ }

Database Activity - データベース操作を実行

Implementations

impl DatabaseActivity

pub fn new(name: &str, query: &str) -> Self

Trait Implementations

impl Activity for DatabaseActivity

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>

リトライポリシーを取得