apunkt/plano
1
0
Fork 0
mirror of https://github.com/katanemo/plano.git synced 2026-06-17 15:25:17 +02:00
Code Issues Projects Releases Packages Wiki Activity

remove dead code

Browse source 
Signed-off-by: Adil Hafeez <adil.hafeez@gmail.com>
This commit is contained in:
Adil Hafeez 2024-11-18 16:37:55 -08:00
parent 97d1729a5d
commit 6638c97cf3
1 changed files with 0 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

15
crates/llm_gateway/src/filter_context.rs
View file

@ -58,31 +58,16 @@ pub struct FilterContext {
// callouts stores token_id to request mapping that we use during #on_http_call_response to match the response to the request.
callouts: RefCell<HashMap<u32, CallContext>>,
llm_providers: Option<Rc<LlmProviders>>,
// traces: Rc<RefCell<VecDeque<TraceData>>>,
traces_queue: Arc<Mutex<VecDeque<TraceData>>>,
// trace_sender: Rc<Sender<TraceData>>,
// receiver: Receiver<TraceData>,
}
impl FilterContext {
pub fn new() -> FilterContext {
// let (sender, receiver) = channel::<TraceData>();
// thread::spawn(move || {
// while let Ok(trace) = receiver.recv() {
// debug!("received trace: {:?}", trace);
// }
// });
// let queue: Arc<Mutex<Vec<String>>> = Arc::new(Mutex::new(Vec::new()));
// queue.lock().unwrap().push("foo".to_string());
FilterContext {
callouts: RefCell::new(HashMap::new()),
metrics: Rc::new(WasmMetrics::new()),
llm_providers: None,
// traces: Rc::new(RefCell::new(VecDeque::new())),
traces_queue: Arc::new(Mutex::new(VecDeque::new())),
// trace_sender: Rc::new(sender),
// receiver,
}
}
}