Struct RunnerAsync 

pub struct RunnerAsync<C: GenericClient = Client> { /* private fields */ }

Implementations

impl<C> RunnerAsync<C>

where C: GenericClient,

pub fn new(client: C) -> Self

pub fn into_inner(self) -> C

impl RunnerAsync<Client>

pub async fn connect_no_tls(config: &str) -> Result<Self, Error>

Helper for tokio_postgres::connect and RunnerAsync::new.

Trait Implementations

impl<C> Run for RunnerAsync<C>

where C: GenericClient,

Available on crate feature tokio-postgres only.

type Error = Error

type Prepared = PreparedProgram

async fn prepare(&self, program: Program) -> Result<Self::Prepared, Self::Error>

Prepares a program for execution and returns a handle, which can be used with Run::execute.

async fn execute( &self, handle: &Self::Prepared, input: &[u8], ) -> Result<Vec<u8>, Self::Error>

Execute a prepared program. Program’s format must match the format supported by this runner.

async fn get_interface(&self) -> Result<String, Self::Error>

Return static interface of this runner as Lutra source code.

fn run<I, O>( &self, program: &TypedProgram<I, O>, input: &I, ) -> impl Future<Output = Result<Result<O, Error>, Self::Error>>

where I: Encode, O: Decode,

Run a program.

fn shutdown(&self) -> impl Future<Output = Result<(), Self::Error>>

Releases any claimed resources or network connections.