Trait AsyncInternalIngestJobService 

pub trait AsyncInternalIngestJobService<I: Stream<Item = Result<Bytes, Error>>> {
    // Required methods
    fn create_ingest_job(
        &self,
        auth_: &BearerToken,
        create_ingest_job_request: &CreateIngestJobRequest,
    ) -> impl Future<Output = Result<ResourceIdentifier, Error>> + Send;
    fn get_ingest_job_internal(
        &self,
        auth_: &BearerToken,
        ingest_job_rid: &ResourceIdentifier,
    ) -> impl Future<Output = Result<InternalIngestJob, Error>> + Send;
    fn update_ingest_job_status(
        &self,
        auth_: &BearerToken,
        ingest_job_rid: &ResourceIdentifier,
        status: &IngestJobStatus,
    ) -> impl Future<Output = Result<IngestJobStatus, Error>> + Send;
}

Internal API for managing ingest jobs. This service is filtered out from public documentation.

Required Methods

fn create_ingest_job( &self, auth_: &BearerToken, create_ingest_job_request: &CreateIngestJobRequest, ) -> impl Future<Output = Result<ResourceIdentifier, Error>> + Send

Creates an ingest job, returning a RID for the job.

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

Returns a single ingest job by RID with full details including the ingest request.

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

Updates the status of an ingest job.

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> AsyncInternalIngestJobService<I> for AsyncInternalIngestJobServiceClient<__C>

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