Trait AsyncIngestJobService 

pub trait AsyncIngestJobService<I: Stream<Item = Result<Bytes, Error>>> {
    // Required methods
    fn get_ingest_job(
        &self,
        auth_: &BearerToken,
        ingest_job_rid: &IngestJobRid,
    ) -> 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: &IngestJobRid, ) -> 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", so this trait is not object safe.

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,