1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
use tokio::sync::oneshot::Sender;

use crate::{ast::SQLStatement, errors::RRDBError, executor::result::ExecuteResult};

#[derive(Debug)]
pub struct ChannelRequest {
    pub statement: SQLStatement,
    pub connection_id: String,
    pub response_sender: Sender<ChannelResponse>,
}

#[derive(Debug)]
pub struct ChannelResponse {
    pub result: Result<ExecuteResult, RRDBError>,
}