pub struct PeerServerSvc { /* private fields */ }Expand description
The hosted-peer gRPC service.
Implementations§
Source§impl PeerServerSvc
impl PeerServerSvc
Sourcepub fn new(connection: Arc<Connection>, config: PeerServerConfig) -> Self
pub fn new(connection: Arc<Connection>, config: PeerServerConfig) -> Self
Hosts connection with the given limits.
Trait Implementations§
Source§impl PeerServer for PeerServerSvc
impl PeerServer for PeerServerSvc
Source§type QueryStream = Pin<Box<dyn Stream<Item = Result<QueryResultChunk, Status>> + Send>>
type QueryStream = Pin<Box<dyn Stream<Item = Result<QueryResultChunk, Status>> + Send>>
Server streaming response type for the Query method.
Source§type DatomsStream = Pin<Box<dyn Stream<Item = Result<DatomChunk, Status>> + Send>>
type DatomsStream = Pin<Box<dyn Stream<Item = Result<DatomChunk, Status>> + Send>>
Server streaming response type for the Datoms method.
Source§type TxRangeStream = Pin<Box<dyn Stream<Item = Result<TxChunk, Status>> + Send>>
type TxRangeStream = Pin<Box<dyn Stream<Item = Result<TxChunk, Status>> + Send>>
Server streaming response type for the TxRange method.
Source§type SubscribeStream = Streaming<SubscribeItem>
type SubscribeStream = Streaming<SubscribeItem>
Server streaming response type for the Subscribe method.
fn query<'life0, 'async_trait>(
&'life0 self,
request: Request<QueryRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::QueryStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn pull<'life0, 'async_trait>(
&'life0 self,
request: Request<PullRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<PullResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transact<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransactResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn datoms<'life0, 'async_trait>(
&'life0 self,
request: Request<DatomsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::DatomsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn tx_range<'life0, 'async_trait>(
&'life0 self,
request: Request<TxRangeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TxRangeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn db_stats<'life0, 'async_trait>(
&'life0 self,
request: Request<DbStatsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DbStatsResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: Request<SubscribeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Auto Trait Implementations§
impl Freeze for PeerServerSvc
impl RefUnwindSafe for PeerServerSvc
impl Send for PeerServerSvc
impl Sync for PeerServerSvc
impl Unpin for PeerServerSvc
impl UnsafeUnpin for PeerServerSvc
impl UnwindSafe for PeerServerSvc
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> 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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request