Struct noria::prelude::View

pub struct View { /* fields omitted */ }

A View is used to query previously defined external views.

Note that if you create multiple View handles from a single ControllerHandle, they may share connections to the Soup workers.

Implementations

impl View

pub fn columns(&self) -> &[String]

Get the list of columns in this view.

pub fn schema(&self) -> Option<&[ColumnSpecification]>

Get the schema definition of this view.

pub async fn len<'_>(&'_ mut self) -> Result<usize, ViewError>

Get the current size of this view.

Note that you must also continue to poll this View for the returned future to resolve.

pub async fn multi_lookup<'_>(
    &'_ mut self,
    keys: Vec<Vec<DataType>>,
    block: bool
) -> Result<Vec<Results>, ViewError>

Retrieve the query results for the given parameter values.

The method will block if the results are not yet available only when block is true. If block is false, misses will be returned as empty results. Any requested keys that have missing state will be backfilled (asynchronously if block is false).

pub async fn lookup<'_, '_>(
    &'_ mut self,
    key: &'_ [DataType],
    block: bool
) -> Result<Results, ViewError>

Retrieve the query results for the given parameter value.

The method will block if the results are not yet available only when block is true.

pub async fn lookup_first<'_, '_>(
    &'_ mut self,
    key: &'_ [DataType],
    block: bool
) -> Result<Option<Row>, ViewError>

Retrieve the first query result for the given parameter value.

The method will block if the results are not yet available only when block is true.

Trait Implementations

impl Clone for View

fn clone(&self) -> View

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for View

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

Formats the value using the given formatter.

impl Service<(Vec<Vec<DataType>>, bool)> for View

type Response = Vec<Results>

Responses given by the service.

type Error = ViewError

Errors produced by the service.

type Future = Future<Result<Self::Response, Self::Error>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, (keys, block): (Vec<Vec<DataType>>, bool)) -> Self::Future

Process the request and return the response asynchronously.