Struct chaindexing::PostgresRepo
source · pub struct PostgresRepo { /* private fields */ }Implementations§
Trait Implementations§
source§impl Clone for PostgresRepo
impl Clone for PostgresRepo
source§fn clone(&self) -> PostgresRepo
fn clone(&self) -> PostgresRepo
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl ExecutesWithRawQuery for PostgresRepo
impl ExecutesWithRawQuery for PostgresRepo
fn execute_raw_query<'life0, 'life1, 'async_trait>(
client: &'life0 Self::RawQueryClient,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn execute_raw_query_in_txn<'a, 'life0, 'life1, 'async_trait>(
txn_client: &'life0 Self::RawQueryTxnClient<'a>,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn commit_raw_query_txns<'a, 'async_trait>(
client: Self::RawQueryTxnClient<'a>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
fn create_contract_address<'a, 'life0, 'life1, 'async_trait>(
client: &'life0 Self::RawQueryTxnClient<'a>,
contract_address: &'life1 UnsavedContractAddress
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn update_next_block_number_to_handle_from<'a, 'life0, 'async_trait>(
client: &'life0 Self::RawQueryTxnClient<'a>,
contract_address_id: i32,
block_number: i64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn update_every_next_block_number_to_handle_from<'a, 'life0, 'async_trait>(
client: &'life0 Self::RawQueryTxnClient<'a>,
chain_id: i64,
block_number: i64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn update_reorged_blocks_as_handled<'a, 'life0, 'life1, 'async_trait>(
client: &'life0 Self::RawQueryTxnClient<'a>,
reorged_block_ids: &'life1 [i32]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn prune_events<'life0, 'async_trait>(
client: &'life0 Self::RawQueryClient,
min_block_number: u64,
chain_id: u64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn prune_nodes<'life0, 'async_trait>(
client: &'life0 Self::RawQueryClient,
retain_size: u16
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn prune_reset_counts<'life0, 'async_trait>(
client: &'life0 Self::RawQueryClient,
retain_size: u64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
source§impl HasRawQueryClient for PostgresRepo
impl HasRawQueryClient for PostgresRepo
type RawQueryClient = Client
type RawQueryTxnClient<'a> = Transaction<'a>
fn get_raw_query_client<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Self::RawQueryClient> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_raw_query_txn_client<'a, 'async_trait>(
client: &'a mut Self::RawQueryClient
) -> Pin<Box<dyn Future<Output = Self::RawQueryTxnClient<'a>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
source§impl LoadsDataWithRawQuery for PostgresRepo
impl LoadsDataWithRawQuery for PostgresRepo
fn load_latest_events<'a, 'life0, 'life1, 'async_trait>(
client: &'life0 Self::RawQueryClient,
addresses: &'life1 [String]
) -> Pin<Box<dyn Future<Output = Vec<PartialEvent>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn load_data_from_raw_query<'life0, 'life1, 'async_trait, Data>(
client: &'life0 Self::RawQueryClient,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = Option<Data>> + Send + 'async_trait>>where
Data: 'async_trait + Send + DeserializeOwned,
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn load_data_from_raw_query_with_txn_client<'a, 'life0, 'life1, 'async_trait, Data>(
client: &'life0 Self::RawQueryTxnClient<'a>,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = Option<Data>> + Send + 'async_trait>>where
Data: 'async_trait + Send + DeserializeOwned,
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn load_data_list_from_raw_query<'life0, 'life1, 'async_trait, Data>(
client: &'life0 Self::RawQueryClient,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = Vec<Data>> + Send + 'async_trait>>where
Data: 'async_trait + Send + DeserializeOwned,
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn load_data_list_from_raw_query_with_txn_client<'a, 'life0, 'life1, 'async_trait, Data>(
txn_client: &'life0 Self::RawQueryTxnClient<'a>,
query: &'life1 str
) -> Pin<Box<dyn Future<Output = Vec<Data>> + Send + 'async_trait>>where
Data: 'async_trait + Send + DeserializeOwned,
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
source§impl Migratable for PostgresRepo
impl Migratable for PostgresRepo
source§impl Repo for PostgresRepo
impl Repo for PostgresRepo
type Conn<'a> = PooledConnection<'a, AsyncDieselConnectionManager<AsyncPgConnection>>
type Pool = Pool<AsyncDieselConnectionManager<AsyncPgConnection>>
fn get_pool<'life0, 'async_trait>(
&'life0 self,
max_size: u32
) -> Pin<Box<dyn Future<Output = Pool> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_conn<'a, 'async_trait>(
pool: &'a Pool
) -> Pin<Box<dyn Future<Output = Conn<'a>> + Send + 'async_trait>>where
'a: 'async_trait,
fn run_in_transaction<'a, 'life0, 'async_trait, F>( conn: &'life0 mut Conn<'a>, repo_ops: F ) -> Pin<Box<dyn Future<Output = Result<(), RepoError>> + Send + 'async_trait>>
fn create_contract_addresses<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Conn<'a>,
contract_addresses: &'life1 [UnsavedContractAddress]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_all_contract_addresses<'a, 'life0, 'async_trait>(
conn: &'life0 mut Conn<'a>
) -> Pin<Box<dyn Future<Output = Vec<ContractAddress>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
fn create_events<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Conn<'a>,
events: &'life1 [Event]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_all_events<'a, 'life0, 'async_trait>(
conn: &'life0 mut Conn<'a>
) -> Pin<Box<dyn Future<Output = Vec<Event>> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
fn get_events<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
address: String,
from: u64,
to: u64
) -> Pin<Box<dyn Future<Output = Vec<Event>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn delete_events_by_ids<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
ids: &'life1 [Uuid]
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn update_next_block_number_to_ingest_from<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
contract_address: &'life1 ContractAddress,
block_number: i64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn update_next_block_number_to_handle_from<'a, 'life0, 'async_trait>(
conn: &'life0 mut Conn<'a>,
contract_address_id: i32,
block_number: i64
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'a: 'async_trait,
'life0: 'async_trait,
fn create_reorged_block<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
reorged_block: &'life1 UnsavedReorgedBlock
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_unhandled_reorged_blocks<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>
) -> Pin<Box<dyn Future<Output = Vec<ReorgedBlock>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn create_reset_count<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn get_last_reset_count<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>
) -> Pin<Box<dyn Future<Output = Option<ResetCount>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn create_node<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>
) -> Pin<Box<dyn Future<Output = Node> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn get_active_nodes<'a, 'life0, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
node_election_rate_ms: u64
) -> Pin<Box<dyn Future<Output = Vec<Node>> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
fn keep_node_active<'a, 'life0, 'life1, 'async_trait>(
conn: &'life0 mut Self::Conn<'a>,
node: &'life1 Node
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'a: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
source§impl RepoMigrations for PostgresRepo
impl RepoMigrations for PostgresRepo
fn create_nodes_migration() -> &'static [&'static str]
fn create_contract_addresses_migration() -> &'static [&'static str]
fn drop_contract_addresses_migration() -> &'static [&'static str]
fn create_events_migration() -> &'static [&'static str]
fn drop_events_migration() -> &'static [&'static str]
fn create_reorged_blocks_migration() -> &'static [&'static str]
fn drop_reorged_blocks_migration() -> &'static [&'static str]
fn create_reset_counts_migration() -> &'static [&'static str]
fn get_internal_migrations() -> Vec<&'static str>
fn get_reset_internal_migrations() -> Vec<&'static str>
source§impl Streamable for PostgresRepo
impl Streamable for PostgresRepo
type StreamConn<'a> = PooledConnection<'a, AsyncDieselConnectionManager<AsyncPgConnection>>
fn get_contract_addresses_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>> ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>
fn get_contract_addresses_stream_by_chain<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>>, chain_id_: i64 ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>
fn get_events_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>>, from: i64, chain_id_: i64, contract_address_: String ) -> Box<dyn Stream<Item = Vec<Event>> + Send + Unpin + 'a>
Auto Trait Implementations§
impl Freeze for PostgresRepo
impl RefUnwindSafe for PostgresRepo
impl Send for PostgresRepo
impl Sync for PostgresRepo
impl Unpin for PostgresRepo
impl UnwindSafe for PostgresRepo
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FmtForward for T
impl<T> FmtForward for T
source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoSql for T
impl<T> IntoSql for T
source§fn into_sql<T>(self) -> Self::Expression
fn into_sql<T>(self) -> Self::Expression
Convert
self to an expression for Diesel’s query builder. Read moresource§fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
Convert
&self to an expression for Diesel’s query builder. Read moresource§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moresource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moresource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> R
source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.source§impl<T, Conn> RunQueryDsl<Conn> for T
impl<T, Conn> RunQueryDsl<Conn> for T
source§fn execute<'conn, 'query>(
self,
conn: &'conn mut Conn
) -> <Conn as AsyncConnection>::ExecuteFuture<'conn, 'query>
fn execute<'conn, 'query>( self, conn: &'conn mut Conn ) -> <Conn as AsyncConnection>::ExecuteFuture<'conn, 'query>
Executes the given command, returning the number of rows affected. Read more
source§fn load<'query, 'conn, U>(
self,
conn: &'conn mut Conn
) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>, fn(_: Self::Stream<'conn>) -> TryCollect<Self::Stream<'conn>, Vec<U>>>
fn load<'query, 'conn, U>( self, conn: &'conn mut Conn ) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>, fn(_: Self::Stream<'conn>) -> TryCollect<Self::Stream<'conn>, Vec<U>>>
source§fn load_stream<'conn, 'query, U>(
self,
conn: &'conn mut Conn
) -> Self::LoadFuture<'conn>where
Conn: AsyncConnection,
U: 'conn,
Self: LoadQuery<'query, Conn, U> + 'query,
fn load_stream<'conn, 'query, U>(
self,
conn: &'conn mut Conn
) -> Self::LoadFuture<'conn>where
Conn: AsyncConnection,
U: 'conn,
Self: LoadQuery<'query, Conn, U> + 'query,
source§fn get_result<'query, 'conn, U>(
self,
conn: &'conn mut Conn
) -> AndThen<Self::LoadFuture<'conn>, Map<StreamFuture<Pin<Box<Self::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<Self::Stream<'conn>>>)) -> Result<U, Error>>, fn(_: Self::Stream<'conn>) -> Map<StreamFuture<Pin<Box<Self::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<Self::Stream<'conn>>>)) -> Result<U, Error>>>
fn get_result<'query, 'conn, U>( self, conn: &'conn mut Conn ) -> AndThen<Self::LoadFuture<'conn>, Map<StreamFuture<Pin<Box<Self::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<Self::Stream<'conn>>>)) -> Result<U, Error>>, fn(_: Self::Stream<'conn>) -> Map<StreamFuture<Pin<Box<Self::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<Self::Stream<'conn>>>)) -> Result<U, Error>>>
Runs the command, and returns the affected row. Read more
source§fn get_results<'query, 'conn, U>(
self,
conn: &'conn mut Conn
) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>, fn(_: Self::Stream<'conn>) -> TryCollect<Self::Stream<'conn>, Vec<U>>>
fn get_results<'query, 'conn, U>( self, conn: &'conn mut Conn ) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>, fn(_: Self::Stream<'conn>) -> TryCollect<Self::Stream<'conn>, Vec<U>>>
Runs the command, returning an
Vec with the affected rows. Read moresource§fn first<'query, 'conn, U>(
self,
conn: &'conn mut Conn
) -> AndThen<<Self::Output as LoadQuery<'query, Conn, U>>::LoadFuture<'conn>, Map<StreamFuture<Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>)) -> Result<U, Error>>, fn(_: <Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>) -> Map<StreamFuture<Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>)) -> Result<U, Error>>>
fn first<'query, 'conn, U>( self, conn: &'conn mut Conn ) -> AndThen<<Self::Output as LoadQuery<'query, Conn, U>>::LoadFuture<'conn>, Map<StreamFuture<Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>)) -> Result<U, Error>>, fn(_: <Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>) -> Map<StreamFuture<Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>>, fn(_: (Option<Result<U, Error>>, Pin<Box<<Self::Output as LoadQuery<'query, Conn, U>>::Stream<'conn>>>)) -> Result<U, Error>>>
Attempts to load a single record. Read more
source§impl<T> Tap for T
impl<T> Tap for T
source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moresource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moresource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moresource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moresource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moresource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moresource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.