Struct GraphServiceImpl 

pub struct GraphServiceImpl { /* private fields */ }

Implementations

impl GraphServiceImpl

pub fn new(state: Arc<RwLock<GraphState>>, bus: Arc<EventBus>) -> Self

pub fn add_node(&self, node: GraphNode)

pub fn add_edge(&self, edge: GraphEdge)

Trait Implementations

impl GraphService for GraphServiceImpl

type WatchGraphStream = Pin<Box<dyn Stream<Item = Result<GraphEvent, Status>> + Send>>

Server streaming response type for the WatchGraph method.

fn get_graph<'life0, 'async_trait>( &'life0 self, _req: Request<GetGraphRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetGraphResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_node<'life0, 'async_trait>( &'life0 self, req: Request<GetNodeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNodeResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn search_nodes<'life0, 'async_trait>( &'life0 self, req: Request<SearchNodesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SearchNodesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn shortest_path<'life0, 'async_trait>( &'life0 self, req: Request<ShortestPathRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ShortestPathResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn watch_graph<'life0, 'async_trait>( &'life0 self, _req: Request<WatchGraphRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchGraphStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,