Struct IngestServiceClient 

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

Trait Implementations

impl<C: Clone> Clone for IngestServiceClient<C>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for IngestServiceClient<C>

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

Formats the value using the given formatter.

impl<I: Iterator<Item = Result<Bytes, Error>>, __C> IngestService<I> for IngestServiceClient<__C>

where __C: Client<ResponseBody = I>,

fn ingest( &self, auth_: &BearerToken, trigger_ingest: &IngestRequest, ) -> Result<IngestResponse, Error>

Triggers an ingest job, allowing either creating a new dataset or uploading to an existing one. This endpoint is meant to supersede all other ingestion endpoints as their functionality gets migrated to this one.

fn rerun_ingest( &self, auth_: &BearerToken, request: &RerunIngestRequest, ) -> Result<IngestResponse, Error>

Triggers an ingest job using an existing ingest job RID. Returns the same response format as the /ingest endpoint.

fn ingest_run( &self, auth_: &BearerToken, request: &IngestRunRequest, ) -> Result<IngestRunResponse, Error>

Creates a run and ingests data sources to be added to the run.

fn ingest_video( &self, auth_: &BearerToken, ingest_video: &IngestVideoRequest, ) -> Result<IngestVideoResponse, Error>

Ingests video data from a S3 Nominal upload bucket.

fn reingest_from_datasets( &self, auth_: &BearerToken, request: &ReingestDatasetsRequest, ) -> Result<ReingestDatasetsResponse, Error>

Re-ingests data from provided source datasets into either an existing target dataset, or a new one. Only supported for CSV and Parquet dataset files. Will only reingest dataset files and will drop streaming data from datasets.

fn delete_file( &self, auth_: &BearerToken, dataset_rid: &DatasetRid, file_id: Uuid, ) -> Result<(), Error>

This is a best effort deletion of the file’s data based on the ingestedAt timestamp. This is an unreversible action. Only v2 dataset file deletion is supported. !!!WARNING!!! It’s possible that the file has overwritten points, in which case, those older points will not be recovered. Only use this endpoint if this is acceptable, the data across files are disjoint, or you’re willing to re-ingest files to manually recover older points.

impl<C> Service<C> for IngestServiceClient<C>

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

Creates a new service wrapping an HTTP client.