Struct TraversalService 

pub struct TraversalService<G: SwhOptFullGraph + Clone + Send + Sync + 'static> {
    pub statsd_client: Option<Arc<StatsdClient>>,
    /* private fields */
}

Fields

statsd_client: Option<Arc<StatsdClient>>

Implementations

impl<G: SwhOptFullGraph + Clone + Send + Sync + 'static> TraversalService<G>

pub fn new(graph: G, statsd_client: Option<Arc<StatsdClient>>) -> Self

Trait Implementations

impl<G: SwhOptFullGraph + Send + Sync + Clone + 'static> TraversalService for TraversalService<G>

type TraverseStream = ReceiverStream<Result<Node, Status>>

Server streaming response type for the Traverse method.

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

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

GetNode returns a single Node and its properties.

fn traverse<'life0, 'async_trait>( &'life0 self, request: Request<TraversalRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::TraverseStream>, Status>> + Send + 'async_trait>>

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

Traverse performs a breadth-first graph traversal from a set of source nodes, then streams the nodes it encounters (if they match a given return filter), along with their properties.

fn find_path_to<'life0, 'async_trait>( &'life0 self, request: Request<FindPathToRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Path>, Status>> + Send + 'async_trait>>

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

FindPathTo searches for a shortest path between a set of source nodes and a node that matches a specific criteria.

fn find_path_between<'life0, 'async_trait>( &'life0 self, request: Request<FindPathBetweenRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Path>, Status>> + Send + 'async_trait>>

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

FindPathBetween searches for a shortest path between a set of source nodes and a set of destination nodes.

fn count_nodes<'life0, 'async_trait>( &'life0 self, request: Request<TraversalRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CountResponse>, Status>> + Send + 'async_trait>>

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

CountNodes does the same as Traverse, but only returns the number of nodes accessed during the traversal.

fn count_edges<'life0, 'async_trait>( &'life0 self, request: Request<TraversalRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CountResponse>, Status>> + Send + 'async_trait>>

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

CountEdges does the same as Traverse, but only returns the number of edges accessed during the traversal.

fn stats<'life0, 'async_trait>( &'life0 self, request: Request<StatsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StatsResponse>, Status>> + Send + 'async_trait>>

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

Stats returns various statistics on the overall graph.

impl<G: SwhOptFullGraph + Clone + Send + Sync + 'static> TraversalServiceTrait for TraversalService<G>

type Graph = G

fn try_get_node_id(&self, swhid: &str) -> Result<usize, Status>

fn graph(&self) -> &Self::Graph

fn statsd_client(&self) -> Option<&Arc<StatsdClient>>