INNER CODE UNIT · Rust
claim_task
Symph0nia/CyberEdge · src/repository/mod.rs:182
async fn claim_task(
&self,
timestamp: prost_types::Timestamp,
) -> Result<Option<ClaimedTask>, RepositoryError>;
async fn complete_task(
&self,
task_id: &str,
records: Vec<DiscoveryRecord>,
timestamp: prost_types::Timestamp,
) -> Result<(), RepositoryError>;
async fn fail_task(
&self,
task_id: &str,
timestamp: prost_types::Timestamp,
) -> Result<(), RepositoryError>;