Struct DmsClient 

pub struct DmsClient { /* private fields */ }

Minimal DMS HTTP client using rustls with sensitive Authorization header.

Implementations

impl DmsClient

pub fn new( base: Url, timeout: Duration, auth: Arc<dyn TokenProvider>, ) -> Result<Self>

Create client with base URL, timeout, and a token provider for Authorization.

pub async fn lease_by_capability( &self, _capability: &str, ) -> Result<Option<LeaseResponse>>

Lease a task: GET /tasks

capability is accepted for optional filter but not implemented yet.

pub async fn complete( &self, task_id: Uuid, body: &CompleteTaskRequest, ) -> Result<()>

Complete task: POST /tasks/{id}/complete

pub async fn fail(&self, task_id: Uuid, body: &FailTaskRequest) -> Result<()>

Fail task: POST /tasks/{id}/fail

pub async fn heartbeat( &self, task_id: Uuid, body: &HeartbeatRequest, ) -> Result<HeartbeatResponse>

Heartbeat: POST /tasks/{id}/heartbeat with progress payload. Returns potential new access token for storage.

Trait Implementations

impl Clone for DmsClient

fn clone(&self) -> DmsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HeartbeatTransport for DmsClient

fn post_heartbeat<'life0, 'life1, 'async_trait>( &'life0 self, task_id: Uuid, body: &'life1 HeartbeatRequest, ) -> Pin<Box<dyn Future<Output = Result<HeartbeatResponse>> + Send + 'async_trait>>

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