Struct BulkOperation 

pub struct BulkOperation {
    pub shop_url: Arc<String>,
    pub version: Arc<String>,
    pub access_token: Arc<String>,
    pub callbacks: Arc<RequestCallbacks>,
}

Fields

shop_url: Arc<String>

version: Arc<String>

access_token: Arc<String>

callbacks: Arc<RequestCallbacks>

Implementations

impl BulkOperation

pub fn new( shop_url: Arc<String>, version: Arc<String>, access_token: Arc<String>, callbacks: Arc<RequestCallbacks>, ) -> Self

pub async fn run_query( &self, query: &str, group_objects: Option<bool>, ) -> Result<RunQueryResp, APIError>

pub async fn run_mutation( &self, mutation: &str, staged_upload_path: &str, client_identifier: Option<&str>, ) -> Result<RunMutationResp, APIError>

pub async fn cancel(&self, id: &str) -> Result<CancelResp, APIError>

pub async fn get(&self, id: &str) -> Result<GetBulkOperationResp, APIError>

pub async fn list( &self, params: &ListBulkOperationsParams, ) -> Result<ListBulkOperationsResp, APIError>

pub async fn create_staged_upload( &self, input: &[StagedUploadInput], ) -> Result<StagedUploadsCreateResp, APIError>

pub async fn export_products( &self, params: Option<&ProductQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn export_orders( &self, params: Option<&OrderQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn export_collections( &self, params: Option<&CollectionQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn export_customers( &self, params: Option<&CustomerQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn export_inventory_items( &self, params: Option<&InventoryItemQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn export_draft_orders( &self, params: Option<&DraftOrderQueryParams>, ) -> Result<RunQueryResp, APIError>

pub async fn stream_jsonl<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<String>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_products<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<ProductExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_orders<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<OrderExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_collections<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<CollectionExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_customers<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<CustomerExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_inventory_items<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<InventoryItemExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,

pub async fn stream_draft_orders<F, Fut>( &self, url: &str, batch_size: usize, on_batch: F, ) -> Result<(), APIError>

where F: FnMut(Vec<DraftOrderExportLine>) -> Fut, Fut: Future<Output = Result<(), APIError>>,