Struct InstanceState 

pub struct InstanceState<CF: ClientFactory> {
    pub semaphore: ConnectionSemaphore,
    /* private fields */
}

Fields

semaphore: ConnectionSemaphore

Trait Implementations

impl<CF: ClientFactory> HasData for InstanceState<CF>

type Data<'a> = &'a mut InstanceState<CF>

The data associated with this trait implementation, chiefly used as a generic associated type to allow plumbing the 'a lifetime into the definition here.

impl<CF: ClientFactory> Host for InstanceState<CF>

fn convert_error(&mut self, error: Error) -> Result<Error>

impl<CF: ClientFactory> Host for InstanceState<CF>

fn convert_error(&mut self, error: Error) -> Result<Error>

impl<CF: ClientFactory> Host for InstanceState<CF>

fn convert_error(&mut self, error: Error) -> Result<Error>

impl<CF: ClientFactory> Host for InstanceState<CF>

impl<CF: ClientFactory> Host for InstanceState<CF>

async fn execute( &mut self, address: String, statement: String, params: Vec<ParameterValue>, ) -> Result<u64, PgError>

execute command to the database: insert, update, delete

async fn query( &mut self, address: String, statement: String, params: Vec<ParameterValue>, ) -> Result<RowSet, PgError>

query the database: select

fn convert_pg_error(&mut self, error: PgError) -> Result<PgError>

impl<CF: ClientFactory> HostConnection for InstanceState<CF>

async fn open(&mut self, address: String) -> Result<Resource<Connection>, Error>

Open a connection to the Postgres instance at address.

async fn execute( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<u64, Error>

Execute command to the database.

async fn query( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<RowSet, Error>

Query the database.

async fn drop(&mut self, connection: Resource<Connection>) -> Result<()>

impl<CF: ClientFactory> HostConnection for InstanceState<CF>

async fn open(&mut self, address: String) -> Result<Resource<Connection>, Error>

Open a connection to the Postgres instance at address.

async fn execute( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<u64, Error>

Execute command to the database.

async fn query( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<RowSet, Error>

Query the database.

async fn drop(&mut self, connection: Resource<Connection>) -> Result<()>

impl<CF: ClientFactory> HostConnection for InstanceState<CF>

async fn open(&mut self, address: String) -> Result<Resource<Connection>, Error>

Open a connection to the Postgres instance at address.

async fn execute( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<u64, Error>

Execute command to the database.

async fn query( &mut self, connection: Resource<Connection>, statement: String, params: Vec<ParameterValue>, ) -> Result<RowSet, Error>

Query the database.

async fn drop(&mut self, connection: Resource<Connection>) -> Result<()>

impl<CF: ClientFactory> HostConnectionBuilder for InstanceState<CF>

async fn new(&mut self, address: String) -> Result<Resource<ConnectionBuilder>>

async fn set_ca_root( &mut self, self_: Resource<ConnectionBuilder>, certificate: String, ) -> Result<(), Error>

async fn build( &mut self, self_: Resource<ConnectionBuilder>, ) -> Result<Resource<Connection>, Error>

async fn drop(&mut self, builder: Resource<ConnectionBuilder>) -> Result<()>

impl<CF: ClientFactory> SelfInstanceBuilder for InstanceState<CF>