Struct QueryBuilder 

pub struct QueryBuilder { /* private fields */ }

Implementations

impl QueryBuilder

pub fn new(query: impl Into<String>, parser: Arc<dyn QueryParser>) -> Self

pub fn with_middleware_registry( self, middleware_registry: Arc<MiddlewareTypeRegistry>, ) -> Self

pub fn with_source_middleware( self, source_middleware: Arc<SourceMiddlewareConfig>, ) -> Self

pub fn with_source_pipeline( self, source: impl Into<String>, pipeline: &[String], ) -> Self

pub fn with_join(self, join: QueryJoin) -> Self

pub fn with_joins(self, joins: Vec<QueryJoin>) -> Self

pub fn with_function_registry( self, function_registry: Arc<FunctionRegistry>, ) -> Self

pub fn with_element_index(self, element_index: Arc<dyn ElementIndex>) -> Self

pub fn with_archive_index( self, archive_index: Arc<dyn ElementArchiveIndex>, ) -> Self

pub fn with_result_index( self, accumulator_result_index: Arc<dyn ResultIndex>, ) -> Self

pub fn with_future_queue(self, future_queue: Arc<dyn FutureQueue>) -> Self

pub fn with_session_control(self, sc: Arc<dyn SessionControl>) -> Self

pub fn get_joins(&self) -> &Vec<Arc<QueryJoin>>

pub async fn build(self) -> ContinuousQuery

pub async fn try_build(self) -> Result<ContinuousQuery, QueryBuilderError>