batch_mode_3p/
lib.rs

1// ---------------- [ File: src/lib.rs ]
2#![allow(unused_imports)]
3
4pub use structopt::{self,StructOpt};
5pub use tokio::runtime::Runtime as TokioRuntime;
6pub use std::borrow::Cow;
7pub use strum::{self,VariantNames,IntoEnumIterator};
8pub use strum_macros::{Display as StrumDisplay, EnumIter, EnumString, EnumVariantNames};
9pub use once_cell::unsync::OnceCell;
10pub use async_openai::{
11    self,
12    types::{
13        OpenAIFile,
14        Batch, 
15        BatchCompletionWindow, 
16        BatchEndpoint, 
17        BatchRequest, 
18        BatchRequestInput, 
19        BatchRequestInputMethod, 
20        BatchRequestOutput,
21        BatchStatus,
22        CreateFileRequest, 
23        FilePurpose,
24    },
25    Client,
26    config::OpenAIConfig,
27    error::{OpenAIError, ApiError as OpenAIApiError},
28};
29pub use serde::{de,Deserializer,Deserialize,Serialize,Serializer};
30pub use bytes::Bytes;
31
32pub use gpt_batch_scribe::{self,*};
33//pub use gpt_batch_executor::*;
34pub use export_magic::*;
35
36pub use error_tree::*;
37pub use std::path::{PathBuf,Path};
38pub use std::fmt::{Formatter,Display,Debug,Result as FmtResult};
39pub use std::str::FromStr;
40pub use tokio::sync::mpsc::{channel,error::TrySendError,Sender,Receiver};
41pub use tokio::{
42    task::JoinSet,
43    fs::{self,File},
44    io::{self, AsyncBufReadExt, AsyncWriteExt, BufReader},
45    self,
46    sync::{
47        RwLock as AsyncRwLock,
48        RwLockReadGuard as AsyncRwLockReadGuard,
49        RwLockWriteGuard as AsyncRwLockWriteGuard,
50        Mutex as AsyncMutex,mpsc, oneshot, Semaphore,OwnedSemaphorePermit},
51    task::JoinHandle,
52    time::{Instant,sleep,Duration},
53};
54pub use indoc::{formatdoc,indoc};
55pub use std::iter::Enumerate;
56pub use std::slice::Chunks;
57pub use inflector::cases::snakecase::to_snake_case;
58pub use delegate::delegate;
59pub use regex::{self,Regex,Captures};
60pub use std::collections::{VecDeque,HashSet};
61pub use traced_test::traced_test;
62pub use tracing_setup::*;
63pub use tracing::{trace,info,debug,error,warn};
64pub use std::cell::RefCell;
65pub use std::rc::Rc;
66pub use tempfile::{self,tempdir,TempDir};
67pub use std::cmp::Ordering;
68pub use uuid::{self,Uuid};
69pub use std::sync::{Arc};
70pub use std::ops::Deref;
71
72pub use futures::{self,future::join_all,executor::block_on};
73pub use serde_json::Value as JsonValue;
74pub use std::{
75    collections::HashMap,
76    io::{BufRead, BufWriter, Write},
77};
78
79pub use async_openai::types::{
80    BatchRequestOutputResponse,
81    ChatCompletionRequestMessageContentPartImage,
82    ChatCompletionRequestUserMessageContent,
83    ImageDetail,
84    ImageUrl,
85};
86
87pub use export_magic::*;
88
89pub use pbx::arc;
90pub use std::error::Error;
91pub use disable_macro::*;
92pub use async_trait::async_trait;
93pub use serde_json::{self,Value,json};
94pub use strsim;
95pub use std::str::Chars;
96pub use std::iter::Peekable;
97pub use json_repair::*;
98pub use getset::*;
99pub use derive_builder::{Builder};
100pub use rand;
101
102pub use ai_descriptor::*;
103pub use rand_construct::*;
104pub use structured_language_form::*;
105pub use named_item::*;
106pub use named_item_derive::NamedItem;
107pub use std::thread::{self,ScopedJoinHandle,Scope};
108pub use std::sync::atomic::{AtomicI32,AtomicUsize, Ordering as AtomicOrdering};
109pub use crossbeam;
110pub use std::marker::PhantomData;
111pub use lazy_static::*;
112pub use std::sync::Mutex as StdMutex;
113pub use std::panic::{AssertUnwindSafe,catch_unwind};
114pub use float_ord::FloatOrd;
115pub use num_traits::Zero;
batch_mode_3p/lib.rs

batch_mode_3p/
lib.rs
