Trait AsyncIngestJobService 

pub trait AsyncIngestJobService<I: Stream<Item = Result<Bytes, Error>>> {
    // Required methods
    fn get_ingest_job(
        &self,
        auth_: &BearerToken,
        ingest_job_rid: &ResourceIdentifier,
    ) -> impl Future<Output = Result<IngestJob, Error>> + Send;
    fn search_ingest_jobs(
        &self,
        auth_: &BearerToken,
        request: &SearchIngestJobsRequest,
    ) -> impl Future<Output = Result<SearchIngestJobsResponse, Error>> + Send;
}

Public API for querying ingest jobs.

Required Methods

fn get_ingest_job( &self, auth_: &BearerToken, ingest_job_rid: &ResourceIdentifier, ) -> impl Future<Output = Result<IngestJob, Error>> + Send

Returns a single ingest job by RID. Does not include the full ingest request details.

fn search_ingest_jobs( &self, auth_: &BearerToken, request: &SearchIngestJobsRequest, ) -> impl Future<Output = Result<SearchIngestJobsResponse, Error>> + Send

Returns a paginated list of ingest jobs, optionally filtered by dataset.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<I: Stream<Item = Result<Bytes, Error>>, __C> AsyncIngestJobService<I> for AsyncIngestJobServiceClient<__C>

where __C: AsyncClient<ResponseBody = I> + Sync + Send, __C::ResponseBody: 'static + Send,