Struct IngestJobServiceClient 

pub struct IngestJobServiceClient<C> { /* private fields */ }

Trait Implementations

impl<C> Clone for IngestJobServiceClient<C>

where C: Clone,

fn clone(&self) -> IngestJobServiceClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Debug for IngestJobServiceClient<C>

where C: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<I, __C> IngestJobService<I> for IngestJobServiceClient<__C>

where I: Iterator<Item = Result<Bytes, Error>>, __C: Client<ResponseBody = I>,

fn get_ingest_job( &self, auth_: &BearerToken, ingest_job_rid: &ResourceIdentifier, ) -> Result<IngestJob, Error>

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

fn get_ingest_transform( &self, auth_: &BearerToken, ingest_transform_rid: &ResourceIdentifier, ) -> Result<IngestTransform, Error>

Returns a single ingest transform by RID. The caller must be authorized to read the dataset produced by the transform’s parent ingest job; a transform whose parent job is not visible to the caller is reported as IngestTransformNotFound rather than leaking its existence.

fn search_ingest_transforms( &self, auth_: &BearerToken, request: &SearchIngestTransformsRequest, ) -> Result<SearchIngestTransformsResponse, Error>

Returns a paginated list of the transforms belonging to a single ingest job, oldest-first and optionally filtered by status. The caller must be authorized to read the parent job’s dataset; a job that is not visible to the caller is reported as IngestJobNotFound.

fn search_ingest_jobs( &self, auth_: &BearerToken, request: &SearchIngestJobsRequest, ) -> Result<SearchIngestJobsResponse, Error>

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

fn cancel_ingest_job( &self, auth_: &BearerToken, ingest_job_rid: &ResourceIdentifier, ) -> Result<IngestJob, Error>

Cancels an ingest job. Jobs that have not yet started running (SUBMITTED, QUEUED) are transitioned directly to CANCELLED. Jobs that are IN_PROGRESS have their underlying Temporal workflow cancelled; the workflow is responsible for transitioning the job to CANCELLED and tearing down in-flight work. Cancelling a job that is already in a terminal state (COMPLETED, FAILED, CANCELLED) throws IngestJobNotCancellable.

fn batch_cancel_ingest_jobs( &self, auth_: &BearerToken, request: &BatchCancelIngestJobsRequest, ) -> Result<BatchCancelIngestJobsResponse, Error>

Cancels multiple ingest jobs in a single call. Each job is processed independently and best-effort: a job that cannot be cancelled (already terminal, missing, or not authorized for the caller) yields a failed result rather than aborting the batch. Per-job cancellation semantics match cancelIngestJob. At most 100 jobs may be requested per call.

impl<C> Service<C> for IngestJobServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> IngestJobServiceClient<C>

Creates a new service wrapping an HTTP client.