batch-mode-batch-client 0.2.4

This crate provides a client for interacting with OpenAI's batch processing API, allowing you to manage and download batch files asynchronously. It offers functionality for managing batch statuses, uploading files, and retrieving results after batch processing.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

// ---------------- [ File: batch-mode-batch-client/src/impl_language_model_client_interface_for_arc_dyn.rs ]
crate::ix!();

//-----------------------------------------[impl for dyn]
#[async_trait]
impl<E: Debug> LanguageModelClientInterface<E>
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{ }

#[async_trait]
impl<E: Debug> RetrieveBatchById
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{
    type Error = E;
    async fn retrieve_batch(&self, batch_id: &str) -> Result<Batch, Self::Error> {
        self.as_ref().retrieve_batch(batch_id).await
    }
}

#[async_trait]
impl<E: Debug> GetBatchFileContent
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{
    type Error = E;

    async fn file_content(&self, file_id: &str) -> Result<Bytes, Self::Error> {
        self.as_ref().file_content(file_id).await
    }
}

#[async_trait]
impl<E: Debug> UploadBatchFileCore
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{
    type Error = E;

    // and so on, forwarding each trait method:
    async fn upload_batch_file_path(
        &self,
        file_path: &std::path::Path
    ) -> Result<OpenAIFile, Self::Error> {
        self.as_ref().upload_batch_file_path(file_path).await
    }
}

#[async_trait]
impl<E: Debug> CreateBatch
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{
    type Error = E;

    async fn create_batch(
        &self,
        input_file_id: &str,
    ) -> Result<Batch, Self::Error> {
        self.as_ref().create_batch(input_file_id).await
    }
}

#[async_trait]
impl<E: Debug> WaitForBatchCompletion
    for std::sync::Arc<dyn LanguageModelClientInterface<E>>
{
    type Error = E;

    async fn wait_for_batch_completion(
        &self,
        batch_id: &str,
    ) -> Result<Batch, Self::Error> {
        self.as_ref().wait_for_batch_completion(batch_id).await
    }
}