mod cluster;
mod quickwit;
mod quickwit_ingest_api;
pub mod ingest_api {
pub use crate::quickwit_ingest_api::*;
}
#[macro_use]
extern crate serde;
use std::fmt;
pub use cluster::*;
pub use quickwit::*;
pub use tonic;
impl From<SearchStreamRequest> for SearchRequest {
fn from(item: SearchStreamRequest) -> Self {
Self {
index_id: item.index_id,
query: item.query,
search_fields: item.search_fields,
start_timestamp: item.start_timestamp,
end_timestamp: item.end_timestamp,
max_hits: 0,
start_offset: 0,
sort_by_field: None,
sort_order: None,
aggregation_request: None,
}
}
}
impl fmt::Display for SplitSearchError {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "({}, split_id: {})", self.error, self.split_id)
}
}