Enum ConfigurableGraphs

pub enum ConfigurableGraphs {
    LocalFile(LocalFileSourceGraph),
    GraphStoreHttp(GraphStoreHttpSourceGraph),
}

Variants

LocalFile(LocalFileSourceGraph)

GraphStoreHttp(GraphStoreHttpSourceGraph)

Trait Implementations

impl ConfigurableGraph for ConfigurableGraphs

type Config = GraphConfigs

fn from_config(config: Self::Config) -> Result<Self, SourceError>

impl Debug for ConfigurableGraphs

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Graph for ConfigurableGraphs

type View<'g> = &'g ConfigurableGraphs

fn view(&self) -> impl Future<Output = Self::View<'_>> + Send

async fn add(&mut self, triple: Arc<Triple>) -> Result<(), GraphError>

async fn merge<G>(&mut self, source_graph: G) -> Result<(), GraphError>

where G: GraphView,

fn remove( &mut self, triple: TripleRef<'_>, ) -> impl Future<Output = Result<(), GraphError>> + Send

fn merge_stream<S>( &mut self, stream: S, ) -> impl Future<Output = Result<(), GraphError>> + Send

where S: Stream<Item = Arc<Triple>> + Unpin + Send,

impl<'g> GraphView for &'g ConfigurableGraphs

type Stream = Box<dyn Stream<Item = Arc<Triple>> + Send + Unpin + 'g>

type Filter<FilterType> = DefaultFilter<&'g ConfigurableGraphs, FilterType> where FilterType: TripleFilter + Send + Sync + Unpin

type Matches<'matches> = DefaultMatches<'matches, &'g ConfigurableGraphs>

type Describe<'describe> = DefaultDescribe<'describe, &'g ConfigurableGraphs>

type SubjectStream<'stream> = Map<<<&'g ConfigurableGraphs as GraphView>::Matches<'stream> as GraphView>::Stream, fn(_: Arc<Triple>) -> Arc<Term>>

type PredicateStream<'stream> = Map<<<&'g ConfigurableGraphs as GraphView>::Matches<'stream> as GraphView>::Stream, fn(_: Arc<Triple>) -> Arc<Term>>

type ObjectStream<'stream> = Map<<<&'g ConfigurableGraphs as GraphView>::Matches<'stream> as GraphView>::Stream, fn(_: Arc<Triple>) -> Arc<Term>>

async fn stream(self) -> Result<Self::Stream, GraphError>

async fn filter<FilterType>( self, filter: FilterType, ) -> Result<Self::Filter<FilterType>, GraphError>

where FilterType: TripleFilter + Send + Sync + Unpin,

async fn matches<'matches>( self, subject: Option<&'matches Term>, predicate: Option<&'matches Term>, object: Option<&'matches Term>, limit: Option<usize>, ) -> Result<Self::Matches<'matches>, GraphError>

async fn describe( self, subject: Option<&Term>, limit: Option<usize>, ) -> Result<Self::Describe<'_>, GraphError>

async fn subjects<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::ObjectStream<'stream>, GraphError>

async fn predicates<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::PredicateStream<'stream>, GraphError>

async fn objects<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::ObjectStream<'stream>, GraphError>

fn subject( self, predicate: Option<&Term>, object: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn predicate( self, subject: Option<&Term>, object: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn object( self, subject: Option<&Term>, predicate: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn contains( self, triple: TripleRef<'_>, ) -> impl Future<Output = Result<bool, GraphError>> + Send

fn default_triple_size_hint() -> usize

fn default_buf_size_hint() -> usize

fn triple_size_hint(&self) -> usize

fn buf_size_hint(&self) -> usize