Trait LelumProxy 

pub trait LelumProxy {
    type Socket: Socket;

    // Required methods
    async fn health(&mut self) -> Result<Result<HealthReport, LelumError<'_>>>;
    async fn read(
        &mut self,
        path: &str,
    ) -> Result<Result<DataEntryValue, LelumError<'_>>>;
    async fn query(
        &mut self,
        root: Option<&str>,
        depth: Option<u32>,
        include_values: bool,
    ) -> Result<Result<QueryResult<'_>, LelumError<'_>>>;
    async fn update(
        &mut self,
        path: &str,
        value: &Value,
    ) -> Result<Result<DataEntryValue, LelumError<'_>>>;
    fn chain_health<'c, ReplyParams, ReplyError>(
        &'c mut self,
    ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>
       where ReplyParams: Deserialize<'c> + Debug,
             ReplyError: Deserialize<'c> + Debug;
    fn chain_read<'c, '__proxy_params, ReplyParams, ReplyError>(
        &'c mut self,
        path: &'__proxy_params str,
    ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>
       where ReplyParams: Deserialize<'c> + Debug,
             ReplyError: Deserialize<'c> + Debug;
    fn chain_query<'c, '__proxy_params, ReplyParams, ReplyError>(
        &'c mut self,
        root: Option<&'__proxy_params str>,
        depth: Option<u32>,
        include_values: bool,
    ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>
       where ReplyParams: Deserialize<'c> + Debug,
             ReplyError: Deserialize<'c> + Debug;
    fn chain_update<'c, '__proxy_params, ReplyParams, ReplyError>(
        &'c mut self,
        path: &'__proxy_params str,
        value: &'__proxy_params Value,
    ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>
       where ReplyParams: Deserialize<'c> + Debug,
             ReplyError: Deserialize<'c> + Debug;
}

Available on crate feature client only.

Varlink proxy trait for the com.inomotech.Lelum interface.

See: Client for a high-level client implementation.

Required Associated Types

type Socket: Socket

The socket type used for the connection.

Required Methods

async fn health(&mut self) -> Result<Result<HealthReport, LelumError<'_>>>

Retrieves a health report from the Lelum service.

See com.inomotech.Lelum.Health for details.

async fn read( &mut self, path: &str, ) -> Result<Result<DataEntryValue, LelumError<'_>>>

Reads the current value of the data entry node at path.

See com.inomotech.Lelum.Read for details.

async fn query( &mut self, root: Option<&str>, depth: Option<u32>, include_values: bool, ) -> Result<Result<QueryResult<'_>, LelumError<'_>>>

Runs a query against the VSS tree.

See com.inomotech.Lelum.Query for details.

async fn update( &mut self, path: &str, value: &Value, ) -> Result<Result<DataEntryValue, LelumError<'_>>>

Updates the value of the data entry node at path.

See com.inomotech.Lelum.Update for details.

fn chain_health<'c, ReplyParams, ReplyError>( &'c mut self, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

Start a chain with this method call.

fn chain_read<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, path: &'__proxy_params str, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

Start a chain with this method call.

fn chain_query<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, root: Option<&'__proxy_params str>, depth: Option<u32>, include_values: bool, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

Start a chain with this method call.

fn chain_update<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, path: &'__proxy_params str, value: &'__proxy_params Value, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

Start a chain with this method call.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<S> LelumProxy for Connection<S>

where S: Socket,

type Socket = S

async fn health(&mut self) -> Result<Result<HealthReport, LelumError<'_>>>

async fn read( &mut self, path: &str, ) -> Result<Result<DataEntryValue, LelumError<'_>>>

async fn query( &mut self, root: Option<&str>, depth: Option<u32>, include_values: bool, ) -> Result<Result<QueryResult<'_>, LelumError<'_>>>

async fn update( &mut self, path: &str, value: &Value, ) -> Result<Result<DataEntryValue, LelumError<'_>>>

fn chain_health<'c, ReplyParams, ReplyError>( &'c mut self, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

fn chain_read<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, path: &'__proxy_params str, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

fn chain_query<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, root: Option<&'__proxy_params str>, depth: Option<u32>, include_values: bool, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

fn chain_update<'c, '__proxy_params, ReplyParams, ReplyError>( &'c mut self, path: &'__proxy_params str, value: &'__proxy_params Value, ) -> Result<Chain<'c, Self::Socket, ReplyParams, ReplyError>>

where ReplyParams: Deserialize<'c> + Debug, ReplyError: Deserialize<'c> + Debug,

Implementors