Skip to content

Commit

Permalink
One file slipped
Browse files Browse the repository at this point in the history
  • Loading branch information
EmilyMatt committed Jun 13, 2024
1 parent 3a27607 commit c3c6b58
Showing 1 changed file with 10 additions and 11 deletions.
21 changes: 10 additions & 11 deletions src/graph/blocking.rs
Original file line number Diff line number Diff line change
Expand Up @@ -130,11 +130,11 @@ impl SyncGraph {
/// * `query_string`: The query to run
///
/// # Returns
/// A [`QueryBuilder`] object, which when performed will return a [`FalkorResponse<FalkorResultSet>`]
/// A [`QueryBuilder`] object, which when performed will return a [`QueryResult<FalkorResultSet>`]
pub fn query<T: Display>(
&mut self,
query_string: T,
) -> QueryBuilder<FalkorResponse<LazyResultSet>, T> {
) -> QueryBuilder<QueryResult<LazyResultSet>, T> {
QueryBuilder::new(self, "GRAPH.QUERY", query_string)
}

Expand All @@ -150,7 +150,7 @@ impl SyncGraph {
pub fn ro_query<'a>(
&'a mut self,
query_string: &'a str,
) -> QueryBuilder<FalkorResponse<LazyResultSet>, &str> {
) -> QueryBuilder<QueryResult<LazyResultSet>, &str> {
QueryBuilder::new(self, "GRAPH.QUERY_RO", query_string)
}

Expand Down Expand Up @@ -194,8 +194,8 @@ impl SyncGraph {
feature = "tracing",
tracing::instrument(name = "List Graph Indices", skip_all, level = "info")
)]
pub fn list_indices(&mut self) -> FalkorResult<FalkorResponse<Vec<FalkorIndex>>> {
ProcedureQueryBuilder::<FalkorResponse<Vec<FalkorIndex>>>::new(self, "DB.INDEXES").execute()
pub fn list_indices(&mut self) -> FalkorResult<QueryResult<Vec<FalkorIndex>>> {
ProcedureQueryBuilder::<QueryResult<Vec<FalkorIndex>>>::new(self, "DB.INDEXES").execute()
}

/// Creates a new index in the graph, for the selected entity type(Node/Edge), selected label, and properties
Expand All @@ -220,7 +220,7 @@ impl SyncGraph {
label: &str,
properties: &[P],
options: Option<&HashMap<String, String>>,
) -> FalkorResult<FalkorResponse<LazyResultSet>> {
) -> FalkorResult<QueryResult<LazyResultSet>> {
// Create index from these properties
let properties_string = properties
.iter()
Expand Down Expand Up @@ -254,7 +254,7 @@ impl SyncGraph {
"CREATE {idx_type}INDEX FOR {pattern} ON ({}){}",
properties_string, options_string
);
QueryBuilder::<FalkorResponse<LazyResultSet>, String>::new(self, "GRAPH.QUERY", query_str)
QueryBuilder::<QueryResult<LazyResultSet>, String>::new(self, "GRAPH.QUERY", query_str)
.execute()
}

Expand All @@ -272,7 +272,7 @@ impl SyncGraph {
entity_type: EntityType,
label: L,
properties: &[P],
) -> FalkorResult<FalkorResponse<LazyResultSet>> {
) -> FalkorResult<QueryResult<LazyResultSet>> {
let properties_string = properties
.iter()
.map(|element| format!("e.{}", element.to_string()))
Expand Down Expand Up @@ -306,9 +306,8 @@ impl SyncGraph {
feature = "tracing",
tracing::instrument(name = "List Graph Constraints", skip_all, level = "info")
)]
pub fn list_constraints(&mut self) -> FalkorResult<FalkorResponse<Vec<Constraint>>> {
ProcedureQueryBuilder::<FalkorResponse<Vec<Constraint>>>::new(self, "DB.CONSTRAINTS")
.execute()
pub fn list_constraints(&mut self) -> FalkorResult<QueryResult<Vec<Constraint>>> {
ProcedureQueryBuilder::<QueryResult<Vec<Constraint>>>::new(self, "DB.CONSTRAINTS").execute()
}

/// Creates a new constraint for this graph, making the provided properties mandatory
Expand Down

0 comments on commit c3c6b58

Please sign in to comment.