Struct FileObjectStoreUploader 

pub struct FileObjectStoreUploader { /* private fields */ }

Implementations

impl FileObjectStoreUploader

pub fn new( upload_client: UploadServiceAsyncClient<PlatformVerifierClient>, ingest_client: IngestServiceAsyncClient<PlatformVerifierClient>, http_client: Client, handle: Handle, opts: UploaderOpts, ) -> Self

pub async fn initiate_upload( &self, token: &BearerToken, file_name: &str, workspace_rid: Option<WorkspaceRid>, ) -> Result<InitiateMultipartUploadResponse, UploaderError>

pub async fn upload_parts<R>( &self, token: &BearerToken, reader: R, key: &str, upload_id: &str, ) -> Result<CompleteMultipartUploadResponse, UploaderError>

where R: Read + Send + 'static,

pub async fn upload_small_file( &self, token: &BearerToken, file_name: &str, size_bytes: i64, workspace_rid: Option<WorkspaceRid>, file: File, ) -> Result<String, UploaderError>

pub async fn upload<R>( &self, token: &BearerToken, reader: R, file_name: impl Into<&str>, workspace_rid: Option<WorkspaceRid>, ) -> Result<String, UploaderError>

where R: Read + Send + 'static,

pub async fn ingest_avro( &self, token: &BearerToken, s3_path: &str, data_source_rid: ResourceIdentifier, ) -> Result<IngestResponse, UploaderError>

Trait Implementations

impl Clone for FileObjectStoreUploader

fn clone(&self) -> FileObjectStoreUploader

Returns a duplicate of the value.

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

Performs copy-assignment from source.